194     command_tube: &Tube,  in handle_stats_queue()
229         if let Err(e) = command_tube.send(&result) {  in handle_stats_queue()
248     command_tube: &AsyncTube,  in handle_command_tube()
254         match command_tube.next().await {  in handle_command_tube()
308     command_tube: Tube,  in run_worker()
318     let command_tube = command_tube.into_async_tube(&ex).unwrap();  in run_worker()  localVariable
359             &command_tube,  in run_worker()
366         let command = handle_command_tube(&command_tube, interrupt.clone(), config, stats_tx);  in run_worker()
383     command_tube.into()  in run_worker()
388     command_tube: Option<Tube>,  field
397     pub fn new(base_features: u64, command_tube: Tube) -> Result<Balloon> {  in new()
399             command_tube: Some(command_tube),  in new()
438         vec![self.command_tube.as_ref().unwrap().as_raw_descriptor()]  in keep_rds()
490         let command_tube = self.command_tube.take().unwrap();  in activate()  localVariable
497                     command_tube,  in activate()
529                 Ok(command_tube) => {  in reset()
530                     self.command_tube = Some(command_tube);  in reset()