Loading doh.rs +15 −19 Original line number Diff line number Diff line Loading @@ -382,8 +382,7 @@ impl DohConnection { .timeout() .unwrap_or_else(|| Duration::from_millis(QUICHE_IDLE_TIMEOUT_MS)); match timeout(ts, self.udp_sk.recv_from(&mut buf)).await { Ok(v) => { match v { Ok(v) => match v { Ok((size, from)) => { let recv_info = quiche::RecvInfo { from }; let processed = match self.quic_conn.recv(&mut buf[..size], recv_info) { Loading @@ -393,17 +392,14 @@ impl DohConnection { } }; debug!("processed {} bytes", processed); return Ok(()); } Err(e) => { return Err(anyhow!("socket recv failed: {:?}", e)); } }; Ok(()) } Err(e) => Err(anyhow!("socket recv failed: {:?}", e)), }, Err(_) => { warn!("timeout did not receive value within {:?} ms, {}", ts, self.net_id); self.quic_conn.on_timeout(); return Ok(()); Ok(()) } } } Loading Loading
doh.rs +15 −19 Original line number Diff line number Diff line Loading @@ -382,8 +382,7 @@ impl DohConnection { .timeout() .unwrap_or_else(|| Duration::from_millis(QUICHE_IDLE_TIMEOUT_MS)); match timeout(ts, self.udp_sk.recv_from(&mut buf)).await { Ok(v) => { match v { Ok(v) => match v { Ok((size, from)) => { let recv_info = quiche::RecvInfo { from }; let processed = match self.quic_conn.recv(&mut buf[..size], recv_info) { Loading @@ -393,17 +392,14 @@ impl DohConnection { } }; debug!("processed {} bytes", processed); return Ok(()); } Err(e) => { return Err(anyhow!("socket recv failed: {:?}", e)); } }; Ok(()) } Err(e) => Err(anyhow!("socket recv failed: {:?}", e)), }, Err(_) => { warn!("timeout did not receive value within {:?} ms, {}", ts, self.net_id); self.quic_conn.on_timeout(); return Ok(()); Ok(()) } } } Loading