[Swift-commit] r5013 - branches/release-0.93/src/org/griphyn/vdl/karajan

[hategan at ci.uchicago.edu]

Author: hategan
Date: 2011-08-27 18:43:36 -0500 (Sat, 27 Aug 2011)
New Revision: 5013

Modified:
   branches/release-0.93/src/org/griphyn/vdl/karajan/DSHandleFutureWrapper.java
Log:
route future notification through event bus

Modified: branches/release-0.93/src/org/griphyn/vdl/karajan/DSHandleFutureWrapper.java
===================================================================
--- branches/release-0.93/src/org/griphyn/vdl/karajan/DSHandleFutureWrapper.java	2011-08-25 21:31:27 UTC (rev 5012)
+++ branches/release-0.93/src/org/griphyn/vdl/karajan/DSHandleFutureWrapper.java	2011-08-27 23:43:36 UTC (rev 5013)
@@ -7,6 +7,7 @@
 import java.util.List;
 
 import org.globus.cog.karajan.stack.VariableStack;
+import org.globus.cog.karajan.workflow.events.EventBus;
 import org.globus.cog.karajan.workflow.events.EventTargetPair;
 import org.globus.cog.karajan.workflow.futures.FutureEvaluationException;
 import org.globus.cog.karajan.workflow.futures.FutureListener;
@@ -55,9 +56,13 @@
             listeners = null;
         }
         
-        for (ListenerStackPair lsp : l) {
+        for (final ListenerStackPair lsp : l) {
             WaitingThreadsMonitor.removeThread(lsp.stack);
-            lsp.listener.futureModified(this, lsp.stack);
+            EventBus.post(new Runnable() {
+                public void run() {
+                    lsp.listener.futureModified(DSHandleFutureWrapper.this, lsp.stack);
+                } 
+            });
         }
     }