--- /dev/null
+#ifndef CONSUMER_H
+#define CONSUMER_H
+
+#include <dol.h>
+#include "global.h"
+
+#define PORT_IN "data_input"
+#define PORT_IN_DELAYED "data2_input_delayed"
+
+typedef struct _local_states
+{
+ ComplexNumber Channels[NUMBER_OF_DOPPLER_CHANNELS][NUMBER_OF_PULSES][NUMBER_OF_RANGE_BINS];
+ ComplexNumber Channels_Delayed[NUMBER_OF_DOPPLER_CHANNELS][NUMBER_OF_PULSES][NUMBER_OF_RANGE_BINS];
+ int channel_cntr;
+ int pulse_cntr;
+ int bin_cntr;
+ int n_iterations;
+
+ int excount;
+#ifdef PRINT_CONSUMER
+ FILE *out;
+#endif
+} Consumer_State;
+
+void Consumer_init(DOLProcess *);
+int Consumer_fire(DOLProcess *);
+
+#endif