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/23 22:15:20 UTC
svn commit: r1401432 -
/airavata/trunk/modules/xbaya-gui/src/main/java/org/apache/airavata/xbaya/interpretor/WorkflowInterpretorSkeleton.java
Author: lahiru
Date: Tue Oct 23 20:15:19 2012
New Revision: 1401432
URL: http://svn.apache.org/viewvc?rev=1401432&view=rev
Log:
minor fix to handle proper shutdown.
Modified:
airavata/trunk/modules/xbaya-gui/src/main/java/org/apache/airavata/xbaya/interpretor/WorkflowInterpretorSkeleton.java
Modified: airavata/trunk/modules/xbaya-gui/src/main/java/org/apache/airavata/xbaya/interpretor/WorkflowInterpretorSkeleton.java
URL: http://svn.apache.org/viewvc/airavata/trunk/modules/xbaya-gui/src/main/java/org/apache/airavata/xbaya/interpretor/WorkflowInterpretorSkeleton.java?rev=1401432&r1=1401431&r2=1401432&view=diff
==============================================================================
--- airavata/trunk/modules/xbaya-gui/src/main/java/org/apache/airavata/xbaya/interpretor/WorkflowInterpretorSkeleton.java (original)
+++ airavata/trunk/modules/xbaya-gui/src/main/java/org/apache/airavata/xbaya/interpretor/WorkflowInterpretorSkeleton.java Tue Oct 23 20:15:19 2012
@@ -382,22 +382,23 @@ public class WorkflowInterpretorSkeleton
}
return defaultVal;
}
- public void shutDown(ConfigurationContext configctx, AxisService service) {
- AiravataRegistry2 registry = jcrComponentRegistry.getRegistry();
- URI gfacURL = (URI) configctx.getProperty(SERVICE_URL);
- if(registry != null && thread != null){
- registry.removeWorkflowInterpreterURI(gfacURL);
- thread.interrupt();
- try {
- thread.join();
- } catch (InterruptedException e) {
- log.info("GFacURL update thread is interrupted");
- }
- }
- if (runner != null) {
- runner.shutDown();
- }
- notInterrupted = false;
+
+ public void shutDown(ConfigurationContext configctx, AxisService service) {
+ URI gfacURL = (URI) configctx.getProperty(SERVICE_URL);
+ if (jcrComponentRegistry != null && thread != null) {
+ AiravataRegistry2 registry = jcrComponentRegistry.getRegistry();
+ registry.removeWorkflowInterpreterURI(gfacURL);
+ thread.interrupt();
+ try {
+ thread.join();
+ } catch (InterruptedException e) {
+ log.info("GFacURL update thread is interrupted");
+ }
+ }
+ if (runner != null) {
+ runner.shutDown();
+ }
+ notInterrupted = false;
}
private List<HostDescription> getDefinedHostDescriptions() {