| /commonlibrary/rust/ylong_http/ylong_http_client/src/async_impl/conn/ |
| H A D | http1.rs | 38 mut conn: Http1Conn<S>,
46 .intercept_connection(conn.raw_mut().conn_detail())?;
55 &mut conn,
59 encode_various_body(message.request.ref_mut(), &mut conn, &mut buf).await?;
65 let size = match conn.raw_mut().read(buf.as_mut_slice()).await {
67 conn.shutdown();
72 conn.shutdown();
82 conn.shutdown();
89 decode_response(message, part, conn, pre)
94 conn
[all...] |
| H A D | http2.rs | 29 use crate::async_impl::conn::StreamData;
42 mut conn: Http2Conn<S>,
62 conn.send_frame_to_controller(stream)?;
63 let frame = conn.receiver.recv().await?;
64 frame_2_response(conn, frame, message)
68 conn: Http2Conn<S>, in frame_2_response()
117 let text_io = TextIo::new(conn); in frame_2_response()
388 use crate::async_impl::conn::http2::build_headers_payload;
459 use crate::async_impl::conn::http2::TextIo; in ut_http2_body_poll_read()
465 let mut conn in ut_http2_body_poll_read() variables
[all...] |
| H A D | mod.rs | 39 pub(crate) async fn request<S>(conn: Conn<S>, message: Message) -> Result<Response, HttpClientError>
43 match conn {
|
| H A D | http3.rs | 30 use crate::async_impl::conn::StreamData;
40 mut conn: Http3Conn<S>,
59 conn.send_frame_to_reader(stream)?;
60 let frame = conn.recv_resp().await?;
61 frame_2_response(conn, frame, message)
103 conn: Http3Conn<S>, in frame_2_response()
138 let data_io = TextIo::new(conn); in frame_2_response()
|
| /commonlibrary/rust/ylong_http/ylong_http_client/src/async_impl/ |
| H A D | client.rs | 20 use super::{conn, Connector, HttpConnector, Request, Response};
191 let conn = self.connect_to(request.ref_mut().uri()).await?;
192 self.send_request_on_conn(conn, request).await
199 Ok(Ok(conn)) => Ok(conn),
209 conn: Conn<C::Stream>,
217 TimeoutFuture::new(conn::request(conn, message), timeout).await
219 conn::request(conn, messag
[all...] |
| H A D | mod.rs | 44 pub(crate) mod conn;
|
| H A D | pool.rs | 73 .conn(
128 async fn conn<C>(
147 if let Some(conn) = self
151 return Ok(conn);
169 if let Some(conn) = self.exist_h1_conn() {
170 return Ok(conn);
191 if let Some(conn) = Self::exist_h2_conn(&mut lock) {
192 return Ok(conn);
224 if let Some(conn) = Self::exist_h3_conn(&mut lock) {
225 return Ok(conn);
362 let mut conn = None; exist_h1_conn() variables
[all...] |
| H A D | http_body.rs | 26 use super::conn::StreamData;
|
| /commonlibrary/rust/ylong_http/ylong_http_client/src/sync_impl/conn/ |
| H A D | http1.rs | 22 use crate::sync_impl::conn::StreamData;
29 mut conn: Http1Conn<S>,
68 conn.raw_mut()
76 conn.raw_mut()
85 let size = conn
114 (true, None, _) => HttpBody::chunk(pre, Box::new(conn), is_trailer),
115 (false, Some(len), _) => HttpBody::text(len, pre, Box::new(conn)),
|
| H A D | mod.rs | 29 conn: Conn<S>,
36 match conn {
|
| /commonlibrary/rust/ylong_http/ylong_http_client/src/sync_impl/ |
| H A D | mod.rs | 29 mod conn; modules
|
| H A D | client.rs | 18 use crate::sync_impl::conn;
164 conn::request(self.inner.connect_to(uri)?, request) in send_request_with_uri()
|
| H A D | pool.rs | 47 .conn(|| self.connector.clone().connect(&uri))
72 fn conn<F, E>(&self, connect_fn: F) -> Result<Conn<S>, HttpClientError> in conn() functions
78 let mut conn = None; in conn() variables
85 if conn.is_none() { in conn()
86 conn = dispatcher.dispatch(); in conn()
91 if let Some(conn) = conn { in conn()
92 Ok(conn) in conn()
98 let conn = dispatcher.dispatch().unwrap(); in conn()
100 Ok(conn) in conn()
[all...] |
| H A D | http_body.rs | 21 use crate::sync_impl::conn::StreamData;
|
| /commonlibrary/rust/ylong_http/ylong_http_client/src/util/h3/ |
| H A D | io_manager.rs | 37 conn: Arc<Mutex<QuicConn>>,
49 conn: Arc<Mutex<QuicConn>>,
55 conn,
85 if let Some(time) = self.conn.lock().unwrap().timeout() {
93 self.conn.lock().unwrap().on_timeout();
106 return match self.conn.lock().unwrap().recv(buf.filled_mut(), recv_info) {
128 let size = match self.conn.lock().unwrap().send(&mut self.send_data.buf) { in poll_io_send()
|
| /commonlibrary/rust/ylong_http/ylong_http_client/src/async_impl/downloader/ |
| H A D | mod.rs | 261 use crate::async_impl::conn::StreamData;
|
| /commonlibrary/rust/ylong_http/ylong_http_client/src/async_impl/connector/ |
| H A D | mod.rs | 414 mut conn: TcpStream,
432 conn.write_all(&req).await?;
438 let n = conn.read(&mut buf[pos..]).await?;
448 return Ok(conn);
|
| /commonlibrary/rust/ylong_http/ylong_http_client/src/util/ |
| H A D | dispatcher.rs | 746 let conn = Arc::new(Mutex::new(quic_connection));
750 conn.clone(),
770 let mut io_manager = IOManager::new(io, conn, io_manager_rx, stream_manager_tx);
928 let conn = ConnDispatcher::http1(b"Data"); in ut_is_shutdown()
929 let res = conn.is_shutdown(); in ut_is_shutdown()
931 let res = conn.dispatch(); in ut_is_shutdown()
|
| /commonlibrary/rust/ylong_http/ylong_http_client/tests/common/ |
| H A D | mod.rs | 204 hyper::server::conn::Http::new()
|