Loading tests/doh/src/dns_https_frontend.rs +1 −0 Original line number Original line Diff line number Diff line Loading @@ -366,6 +366,7 @@ async fn worker_thread(params: WorkerParams) -> Result<()> { } } } } Some(command) = command_rx.recv() => { Some(command) = command_rx.recv() => { debug!("ControlCommand: {:?}", command); match command { match command { ControlCommand::Stats {resp} => { ControlCommand::Stats {resp} => { let stats = Stats { let stats = Stats { Loading tests/doh_frontend.cpp +8 −0 Original line number Original line Diff line number Diff line Loading @@ -97,6 +97,14 @@ void DohFrontend::clearQueries() { std::lock_guard guard(mMutex); std::lock_guard guard(mMutex); if (mRustDoh) { if (mRustDoh) { frontend_stats_clear_queries(mRustDoh); frontend_stats_clear_queries(mRustDoh); // Because frontend_stats_clear_queries() is asynchronous, query the stat here to ensure // that mRustDoh reset the query count before clearQueries() returns. rust::Stats stats; rust::frontend_stats(mRustDoh, &stats); if (stats.queries_received != 0) { LOG(ERROR) << "queries_received is not 0"; } } } } } Loading Loading
tests/doh/src/dns_https_frontend.rs +1 −0 Original line number Original line Diff line number Diff line Loading @@ -366,6 +366,7 @@ async fn worker_thread(params: WorkerParams) -> Result<()> { } } } } Some(command) = command_rx.recv() => { Some(command) = command_rx.recv() => { debug!("ControlCommand: {:?}", command); match command { match command { ControlCommand::Stats {resp} => { ControlCommand::Stats {resp} => { let stats = Stats { let stats = Stats { Loading
tests/doh_frontend.cpp +8 −0 Original line number Original line Diff line number Diff line Loading @@ -97,6 +97,14 @@ void DohFrontend::clearQueries() { std::lock_guard guard(mMutex); std::lock_guard guard(mMutex); if (mRustDoh) { if (mRustDoh) { frontend_stats_clear_queries(mRustDoh); frontend_stats_clear_queries(mRustDoh); // Because frontend_stats_clear_queries() is asynchronous, query the stat here to ensure // that mRustDoh reset the query count before clearQueries() returns. rust::Stats stats; rust::frontend_stats(mRustDoh, &stats); if (stats.queries_received != 0) { LOG(ERROR) << "queries_received is not 0"; } } } } } Loading