working on tags python support

1 files changed, 37 insertions, 15 deletions

diff --git a/tests/demo_blocks.py b/tests/demo_blocks.py
index 3a5d5cb..7187ec7 100644
--- a/tests/demo_blocks.py
+++ b/tests/demo_blocks.py
@@ -1,21 +1,6 @@
 import gras
 import numpy
 
-class add_2x(gras.Block):
-    def __init__(self, sig):
-        gras.Block.__init__(self,
-            name = "add 2x",
-            in_sig = [sig, sig],
-            out_sig = [sig],
-        )
-
-    def work(self, ins, outs):
-        nitems = min(*map(len, (ins[0], ins[1], outs[0])))
-        outs[0][:nitems] = ins[0][:nitems] + ins[1][:nitems]
-        self.consume(0, nitems)
-        self.consume(1, nitems)
-        self.produce(0, nitems)
-
 class NullSource(gras.Block):
     def __init__(self, out_sig):
         gras.Block.__init__(self, 'NullSource', out_sig=[out_sig])
@@ -29,7 +14,10 @@ class NullSink(gras.Block):
         gras.Block.__init__(self, 'NullSink', in_sig=[in_sig])
 
     def work(self, ins, outs):
+        print 'consume',len(ins[0])
         self.consume(0, len(ins[0]))
+        #FIXME should not need == 0 part!!
+        if len(ins[0]) == 0: self.mark_done()
 
 class VectorSource(gras.Block):
     def __init__(self, out_sig, vec):
@@ -55,3 +43,37 @@ class VectorSink(gras.Block):
     def work(self, ins, outs):
         self._vec.extend(ins[0].copy())
         self.consume(0, len(ins[0]))
+
+class Add2X(gras.Block):
+    def __init__(self, sig):
+        gras.Block.__init__(self,
+            name = "Add2X",
+            in_sig = [sig, sig],
+            out_sig = [sig],
+        )
+
+    def work(self, ins, outs):
+        nitems = min(*map(len, (ins[0], ins[1], outs[0])))
+        outs[0][:nitems] = ins[0][:nitems] + ins[1][:nitems]
+        self.consume(0, nitems)
+        self.consume(1, nitems)
+        self.produce(0, nitems)
+
+class TagSource(gras.Block):
+    def __init__(self, tags):
+        gras.Block.__init__(self,
+            name = "TagSource",
+            out_sig = [numpy.uint8],
+        )
+        self._tags = tags
+
+    def work(self, ins, outs):
+        offset = self.nitems_written(0)
+        self.post_output_tag(0, gras.Tag(offset, 'key', self._tags[0]))
+        self.produce(0, len(outs[0]))
+        self._tags = self._tags[1:]
+        print 'produce', len(outs[0])
+        print 'self._tags', self._tags
+        if not self._tags:
+            self.mark_done()
+            print 'done!'