You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@airavata.apache.org by la...@apache.org on 2012/10/03 22:00:41 UTC
svn commit: r1393738 - in
/airavata/trunk/modules/gfac-core/src/main/java/org/apache/airavata/core/gfac:
exception/JobSubmissionFault.java provider/impl/GramProvider.java
Author: lahiru
Date: Wed Oct 3 20:00:41 2012
New Revision: 1393738
URL: http://svn.apache.org/viewvc?rev=1393738&view=rev
Log:
fixing error handling issue in airavata.
Modified:
airavata/trunk/modules/gfac-core/src/main/java/org/apache/airavata/core/gfac/exception/JobSubmissionFault.java
airavata/trunk/modules/gfac-core/src/main/java/org/apache/airavata/core/gfac/provider/impl/GramProvider.java
Modified: airavata/trunk/modules/gfac-core/src/main/java/org/apache/airavata/core/gfac/exception/JobSubmissionFault.java
URL: http://svn.apache.org/viewvc/airavata/trunk/modules/gfac-core/src/main/java/org/apache/airavata/core/gfac/exception/JobSubmissionFault.java?rev=1393738&r1=1393737&r2=1393738&view=diff
==============================================================================
--- airavata/trunk/modules/gfac-core/src/main/java/org/apache/airavata/core/gfac/exception/JobSubmissionFault.java (original)
+++ airavata/trunk/modules/gfac-core/src/main/java/org/apache/airavata/core/gfac/exception/JobSubmissionFault.java Wed Oct 3 20:00:41 2012
@@ -42,4 +42,13 @@ public class JobSubmissionFault extends
public void setReason(String reason) {
this.reason = reason;
}
+
+ public void sendFaultNotification(String message,
+ InvocationContext invocationContext, Exception e,
+ String... additionalExceptiondata) {
+ if (additionalExceptiondata==null || additionalExceptiondata.length==0){
+ additionalExceptiondata=new String[]{message,e.getLocalizedMessage()};
+ }
+ invocationContext.getExecutionContext().getNotifier().executionFail(invocationContext,e,additionalExceptiondata);
+ }
}
Modified: airavata/trunk/modules/gfac-core/src/main/java/org/apache/airavata/core/gfac/provider/impl/GramProvider.java
URL: http://svn.apache.org/viewvc/airavata/trunk/modules/gfac-core/src/main/java/org/apache/airavata/core/gfac/provider/impl/GramProvider.java?rev=1393738&r1=1393737&r2=1393738&view=diff
==============================================================================
--- airavata/trunk/modules/gfac-core/src/main/java/org/apache/airavata/core/gfac/provider/impl/GramProvider.java (original)
+++ airavata/trunk/modules/gfac-core/src/main/java/org/apache/airavata/core/gfac/provider/impl/GramProvider.java Wed Oct 3 20:00:41 2012
@@ -228,6 +228,7 @@ public class GramProvider extends Abstra
} catch (GramException e) {
JobSubmissionFault error = new JobSubmissionFault(this, e, host.getHostAddress(), gateKeeper, job.getRSL(), invocationContext);
int errCode = listener.getError();
+ error.sendFaultNotification(error.getMessage(),invocationContext,error,host.getHostAddress()+ "," + job.getRSL());
throw errorReason(errCode, error);
} catch (GSSException e) {
throw new ProviderException(e.getMessage(), e, invocationContext);