manycast::worker::inbound

Function handle_results

Source 
fn handle_results(
    tx: &UnboundedSender<TaskResult>,
    rx_f: Arc<AtomicBool>,
    worker_id: u16,
    rq_sender: Arc<Mutex<Vec<(Reply, bool)>>>,
)
Expand description

Thread for handling the received replies, wrapping them in a TaskResult, and streaming them back to the main worker class.

ยง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

  • rq_sender - contains a vector of all received replies as Reply results