[Swift-commit] r7090 - trunk/src/org/griphyn/vdl/karajan/lib

[hategan at ci.uchicago.edu]

Author: hategan
Date: 2013-09-19 15:45:13 -0500 (Thu, 19 Sep 2013)
New Revision: 7090

Modified:
   trunk/src/org/griphyn/vdl/karajan/lib/Mark.java
Log:
files are passed as a channel not a list

Modified: trunk/src/org/griphyn/vdl/karajan/lib/Mark.java
===================================================================
--- trunk/src/org/griphyn/vdl/karajan/lib/Mark.java	2013-09-19 18:03:00 UTC (rev 7089)
+++ trunk/src/org/griphyn/vdl/karajan/lib/Mark.java	2013-09-19 20:45:13 UTC (rev 7090)
@@ -22,6 +22,7 @@
 
 import java.util.List;
 
+import k.rt.Channel;
 import k.rt.ExecutionException;
 import k.rt.Stack;
 
@@ -33,7 +34,7 @@
 import org.griphyn.vdl.mapping.Path;
 
 public class Mark extends SwiftFunction {
-    private ArgRef<List<List<Object>>> restarts;
+    private ArgRef<Channel<List<Object>>> restarts;
     private ArgRef<Boolean> err;
     private ArgRef<Boolean> mapping;
     
@@ -47,7 +48,7 @@
         try {
             if (err.getValue(stack)) {
                 boolean mapping = this.mapping.getValue(stack);
-                List<List<Object>> files = this.restarts.getValue(stack);
+                Channel<List<Object>> files = this.restarts.getValue(stack);
                 for (List<Object> pv : files) {
                     Path p = parsePath(pv.get(0));
                     DSHandle handle = (DSHandle) pv.get(1);