X-Git-Url: http://sraa.de/git/?a=blobdiff_plain;f=dol%2Fexamples%2Fexample5%2Fsrc%2Fconsumer.c;fp=dol%2Fexamples%2Fexample5%2Fsrc%2Fconsumer.c;h=376eceea9a151032b441e4ecde148e20b68c09b8;hb=8c411cf24ed0eb889191aaeafd8fa1e69081df42;hp=0000000000000000000000000000000000000000;hpb=dea7a4fb1ed110d3ce6e6d9255103d724bd66c0e;p=jump.git

diff --git a/dol/examples/example5/src/consumer.c b/dol/examples/example5/src/consumer.c
new file mode 100644
index 0000000..376ecee
--- /dev/null
+++ b/dol/examples/example5/src/consumer.c
@@ -0,0 +1,29 @@
+#include <stdio.h>
+
+#include "consumer.h"
+
+void consumer_init(DOLProcess *p)
+{
+  ; //nothing to be done here
+}
+
+int consumer_fire(DOLProcess *p)
+{
+  CREATEPORTVAR(input_port);
+
+  for (p->local->index = 0; p->local->index < NUMBER_OF_FFT_POINTS;
+       p->local->index++) {
+    CREATEPORT(input_port, PORT_OUTPUT_COEFFICIENTS, 1,
+            p->local->index, NUMBER_OF_FFT_POINTS);
+    DOL_read((void*)input_port, &(p->local->coeffs[p->local->index]),
+        sizeof(ComplexNumber), p);
+    printf("%15s: coeff[%d]: %9f + j * %9f\n",
+           "output_consumer", p->local->index,
+           p->local->coeffs[p->local->index].real,
+           p->local->coeffs[p->local->index].imag);
+  }
+
+  DOL_detach(p);
+  return -1;
+}
+