5 void consumer_init(DOLProcess *p)
7 ; //nothing to be done here
10 int consumer_fire(DOLProcess *p)
12 CREATEPORTVAR(input_port);
14 for (p->local->index = 0; p->local->index < NUMBER_OF_FFT_POINTS;
16 CREATEPORT(input_port, PORT_OUTPUT_COEFFICIENTS, 1,
17 p->local->index, NUMBER_OF_FFT_POINTS);
18 DOL_read((void*)input_port, &(p->local->coeffs[p->local->index]),
19 sizeof(ComplexNumber), p);
20 printf("%15s: coeff[%d]: %9f + j * %9f\n",
21 "output_consumer", p->local->index,
22 p->local->coeffs[p->local->index].real,
23 p->local->coeffs[p->local->index].imag);