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.