Searched refs:quic_conn (Results 1 - 3 of 3) sorted by relevance
/commonlibrary/rust/ylong_http/ylong_http_client/src/util/h3/ |
H A D | stream_manager.rs | 40 pub(crate) quic_conn: Arc<Mutex<QuicConn>>, 56 quic_conn: Arc<Mutex<QuicConn>>, 66 quic_conn, 120 quic_conn: &mut QuicConn, in send_inst_to_peer() 129 quic_conn.stream_send(qpack_decode_stream_id, vec, false)?; in send_inst_to_peer() 200 let mut quic_conn = self.quic_conn.lock().unwrap(); in input_stream_frame() variables 201 quic_conn.stream_send(id, b"", true)?; in input_stream_frame() 213 let quic_conn = self.quic_conn in poll_send_header() 220 let mut quic_conn = quic_conn.lock().unwrap(); poll_send_header() variables 259 let mut quic_conn = self.quic_conn.lock().unwrap(); poll_send_frame() variables 338 let mut quic_conn = self.quic_conn.lock().unwrap(); global() variables 353 let mut quic_conn = self.quic_conn.lock().unwrap(); global() variables 375 let mut quic_conn = lock.lock().unwrap(); global() variables [all...] |
/commonlibrary/rust/ylong_http/ylong_http_client/src/async_impl/connector/ |
H A D | stream.rs | 35 fn quic_conn(&mut self) -> Option<QuicConn>; in quic_conn() functions 43 quic_conn: Option<QuicConn>, 92 fn quic_conn(&mut self) -> Option<QuicConn> { in poll_flush() functions 93 self.quic_conn.take() in poll_flush() 104 quic_conn: None, in new() 110 self.quic_conn = Some(conn); in set_quic_conn()
|
H A D | mod.rs | 310 let Ok(quic_conn) = in connect() 315 stream.set_quic_conn(quic_conn); in connect()
|
Completed in 4 milliseconds