Lines Matching refs:driver
99 driver: Driver, field
254 fn new(driver: Driver, h3_conn: h3::Connection) -> Self { in new()
256 driver, in new()
265 let _ = self.driver.status_tx.send(Status::H3); in drive()
269 .driver in drive()
271 .send(Status::Dead { session: self.driver.quiche_conn.session() }); in drive()
280 let timer = optional_timeout(self.driver.quiche_conn.timeout(), self.driver.net_id); in drive_once()
289 …msg = self.driver.request_rx.recv(), if !self.driver.closing && self.buffered_request.is_none() =>… in drive_once()
297 debug!("H3Driver: Timer expired on network {}", self.driver.net_id); in drive_once()
298 self.driver.quiche_conn.on_timeout() in drive_once()
301 Ok((size, from)) = self.driver.socket.recv_from(self.driver.buffer.as_mut()) => { in drive_once()
302 …self.driver.quiche_conn.recv(&mut self.driver.buffer[..size], quiche::RecvInfo { from }).map(|_| (… in drive_once()
303 debug!("Received {} bytes on network {}", size, self.driver.net_id); in drive_once()
308 self.driver.flush_tx().await?; in drive_once()
317 self.driver.handle_draining(); in drive_once()
320 self.driver.handle_closed() in drive_once()
325 …self.driver.net_id, self.driver.quiche_conn.stats(), self.driver.quiche_conn.peer_streams_left_bid… in handle_request()
336 match self.h3_conn.send_request(&mut self.driver.quiche_conn, &request.headers, true) { in handle_request()
352 self.driver.net_id, in handle_request()
353 self.driver.quiche_conn.stream_capacity(stream_id) in handle_request()
366 &mut self.driver.quiche_conn, in recv_body()
383 recvd, stream_id, self.driver.net_id in recv_body()
396 match self.h3_conn.recv_dgram(&mut self.driver.quiche_conn, self.driver.buffer.as_mut()) in discard_datagram()
407 match self.h3_conn.poll(&mut self.driver.quiche_conn) { in flush_h3()
423 stream_id, self.driver.net_id in process_h3_event()
436 stream_id, self.driver.net_id in process_h3_event()
443 stream_id, self.driver.net_id in process_h3_event()
466 self.driver.quiche_conn.trace_id(), in shutdown()
467 self.driver.net_id, in shutdown()
470 self.driver.request_rx.close(); in shutdown()
471 while self.driver.request_rx.recv().await.is_some() {} in shutdown()
472 self.driver.closing = true; in shutdown()
474 self.h3_conn.send_goaway(&mut self.driver.quiche_conn, 0)?; in shutdown()
476 if self.driver.quiche_conn.close(true, 0, msg).is_err() { in shutdown()
487 stream_id, self.driver.net_id in respond()