networkPowerStream¶

class networkPowerStream : 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

in_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 doesn’t work at the moment.

Param samples_per_data_set:: Int. Number of time samples to sum.
Param power_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 freq0:: Float (default 1420.0).
Param sample_bw:: Float (default 10.0).
Param dest_port:: Int. Number of time samples to sum.
Param dest_server_ip:: Int. Number of time samples to sum.
Param dest_protocol:: String. Should be "TCP" or "UDP"

Public Functions

networkPowerStream(kotekan::Config &config, const std::string &unique_name, kotekan::bufferContainer &buffer_container)¶: Constructor.

virtual ~networkPowerStream()¶: Destructor.

virtual void main_thread() override¶: Primary loop, which waits on input frames, integrates, and dumps to output.