DoH: Increase the size of Network mpsc channel am: 153b3fe1 am: 1f651757 am: 87e2eeda

        // If the request has already timed out, don't issue it to the server.

        if let Some(expiry) = request.expiry {

            if BootTime::now() > expiry {

                warn!("Abandoning expired DNS request");

                return Ok(());

            }

        }

use crate::connection::Connection;

use crate::dispatcher::{QueryError, Response};

use crate::encoding;

use anyhow::{anyhow, Result};

use anyhow::{anyhow, bail, Result};

use std::sync::Arc;

use tokio::sync::{mpsc, watch};

use tokio::task;

}

impl Driver {

    const MAX_BUFFERED_COMMANDS: usize = 10;

    const MAX_BUFFERED_COMMANDS: usize = 50;

    pub async fn new(

        info: ServerInfo,

    }

    async fn send_query(&mut self, query: Query) -> Result<()> {

        // If the associated receiver has been closed, meaning that the request has already

        // timed out, just drop it. This check helps drain the channel quickly in the case

        // where the network is stalled.

        if query.response.is_closed() {

            bail!("Abandoning expired DNS request")

        }

        if !self.connection.wait_for_live().await {

            // Try reconnecting

            self.connection =

// Note: This test is subject to MAX_BUFFERED_COMMANDS. If the value is changed, this test might

// need to be modified as well.

TEST_F(PrivateDnsDohTest, ExcessDnsRequests) {

    const int total_queries = 20;

    const int total_queries = 70;

    // The number is from MAX_BUFFERED_COMMANDS + 2 (one that will be queued in

    // connection mpsc channel; the other one that will get blocked at dispatcher sending channel).

    const int timeout_queries = 12;

    const int timeout_queries = 52;

    const int initial_max_idle_timeout_ms = 2000;

    ASSERT_TRUE(doh.stopServer());