Searched refs:command_tx (Results 1 – 3 of 3) sorted by relevance
/packages/modules/DnsResolver/doh/tests/doh_frontend/src/ |
D | dns_https_frontend.rs | 88 command_tx: Option<mpsc::UnboundedSender<ControlCommand>>, field 113 command_tx: None, in new() 140 self.command_tx.as_ref().unwrap().send(ControlCommand::CloseConnection)?; in stop() 197 self.command_tx.is_some(), in request_stats() 200 let command_tx = self.command_tx.as_ref().unwrap(); in request_stats() localVariable 202 if command_tx.is_closed() { in request_stats() 207 command_tx.send(ControlCommand::Stats { resp: resp_tx })?; in request_stats() 225 self.command_tx.is_some(), in stats_clear_queries() 229 .command_tx in stats_clear_queries() 252 let (command_tx, command_rx) = mpsc::unbounded_channel::<ControlCommand>(); in init_worker_thread_params() [all …]
|
/packages/modules/DnsResolver/doh/network/ |
D | mod.rs | 72 command_tx: mpsc::Sender<Command>, field 82 let (driver, command_tx, status_rx) = in new() 85 Ok(Network { info, command_tx, status_rx }) in new() 89 self.command_tx.send(Command::Probe(timeout)).await?; in probe() 109 Status::Live => self.command_tx.try_send(Command::Query(query))?, in query()
|
D | driver.rs | 95 let (command_tx, command_rx) = mpsc::channel(Self::MAX_BUFFERED_COMMANDS); in new() 101 command_tx, in new()
|