Skip to main content

handle_results

Function handle_results 

Source
fn handle_results(
    tx: &UnboundedSender<ReplyBatch>,
    rx_f: Arc<AtomicBool>,
    worker_id: u16,
    reply_rx: Receiver<Reply>,
    origin_id: u32,
)
Expand description

Forward results to the Worker handler

ยงArguments

  • tx - sender to put task results in
  • rx_f - channel that is used to signal the end of the measurement
  • worker_id - the unique worker ID of this worker
  • reply_rx - channel receiver for replies from the listener thread
  • origin_id - origin ID associated with this inbound handler