Home
last modified time | relevance | path

Searched refs:command_tx (Results 1 – 3 of 3) sorted by relevance

/packages/modules/DnsResolver/doh/tests/doh_frontend/src/
Ddns_https_frontend.rs88 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/
Dmod.rs72 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()
Ddriver.rs95 let (command_tx, command_rx) = mpsc::channel(Self::MAX_BUFFERED_COMMANDS); in new()
101 command_tx, in new()