Searched refs:handle_command_tube (Results 1 – 2 of 2) sorted by relevance
247 async fn handle_command_tube( in handle_command_tube() function366 let command = handle_command_tube(&command_tube, interrupt.clone(), config, stats_tx); in run_worker()
381 async fn handle_command_tube( in handle_command_tube() function534 let control = handle_command_tube(control_tube, interrupt.clone(), disk_state.clone()); in run_worker()