liftof_cc::threads::global_data_sink

Function global_data_sink

Source 
pub fn global_data_sink(
    incoming: &Receiver<TofPacket>,
    thread_control: Arc<Mutex<ThreadControl>>,
)
Expand description

Manages “outgoing” 0MQ PUB socket and writing data to disk

All received packets will be either forwarded over zmq or saved to disk

§Arguments:

  • incoming : incoming connection for TofPackets from any source
  • thread_control : inter-thread communications, start/stop signals. Keeps global settings.