networkInputPowerStream

class networkInputPowerStream : public kotekan::Stage

Stage to take an intensity stream and stream to a remote client.

This is a consumer stage which takes intensity data from a buffer and streams it via TCP (and some day UDP) to a remote client, primarily for visualization purposes.

In TCP mode, the stage should continually attempt to establish a TCP connection, then transmit data once successful.

Buffers

• out_buf Input kotekan buffer containing power data to be sent.

  • Format: Array of uint

  • Metadata: none

Author

Keith Vanderlinde

Note

Lots of updating required once buffers are typed…

Warning

UDP stream receiption doesn’t work at the moment.

Param samples_per_data_set:

Int. Number of time samples to sum.

Param integration_length:

Int. Number of time samples to sum.

Param num_freq:

Int. Number of time samples to sum.

Param num_elements:

Int. Number of time samples to sum.

Param port:

Int. Number of time samples to sum.

Param ip:

Int. Number of time samples to sum.

Param protocol:

String. Should be "TCP" or "UDP"

Public Functions

networkInputPowerStream(kotekan::Config &config, const std::string &unique_name, kotekan::bufferContainer &buffer_container)

Constructor.

virtual ~networkInputPowerStream()

Destructor.

virtual void main_thread() override

Primary loop, which waits on input frames, integrates, and dumps to output.