| /commonlibrary/rust/ylong_http/ylong_http_client/src/sync_impl/conn/ |
| D | mod.rs | 31 pub(crate) fn request<S, T>( in request()
32 conn: Conn<S>, in request()
|
| D | http1.rs | 29 pub(crate) fn request<S, T>( in request()
30 mut conn: Http1Conn<S>, in request()
|
| /commonlibrary/rust/ylong_http/ylong_http_client/src/async_impl/conn/ |
| D | mod.rs | 34 pub(crate) async fn request<S, T>( in request()
35 conn: Conn<S>, in request()
|
| D | http1.rs | 28 pub(crate) async fn request<S, T>( in request()
29 mut conn: Http1Conn<S>, in request()
|
| D | http2.rs | 38 pub(crate) async fn request<S, T>( in request()
39 mut conn: Http2Conn<S>, in request()
82 conn: Http2Conn<S>, in frame_2_response()
|
| /commonlibrary/rust/ylong_http/ylong_http_client/src/async_impl/ |
| D | pool.rs | 87 ) -> Result<Conn<S>, HttpClientError> in conn()
132 fn dispatch_conn(&self, dispatcher: ConnDispatcher<S>) -> Conn<S> { in dispatch_conn()
140 fn get_exist_conn(&self) -> Option<Conn<S>> { in get_exist_conn()
|
| /commonlibrary/rust/ylong_runtime/ylong_io/src/ |
| D | poll.rs | 42 pub fn register<S>(&self, source: &mut S, token: Token, interests: Interest) -> io::Result<()> in register()
50 pub fn reregister<S>(&self, source: &mut S, token: Token, interests: Interest) -> io::Result<()> in reregister()
|
| /commonlibrary/rust/ylong_http/ylong_http_client/src/util/ |
| D | dispatcher.rs | 128 pub(crate) fn raw_mut(&mut self) -> &mut S { in raw_mut()
301 inner: Inner<S>, in new()
505 inner: Inner<S>, in new()
596 controller: Arc<StreamController<S>>, in new()
765 io_manager: &mut MutexGuard<IoManager<S>>, in poll_match_result()
861 io_manager: &mut MutexGuard<IoManager<S>>, in poll_io()
900 io_manager: &mut MutexGuard<IoManager<S>>, in poll_dispatch_frame()
915 io_manager: &mut MutexGuard<IoManager<S>>, in poll_send_preface()
949 io_manager: &mut MutexGuard<IoManager<S>>, in poll_send_go_away()
963 io_manager: &mut MutexGuard<IoManager<S>>, in poll_send_reset()
[all …]
|
| /commonlibrary/rust/ylong_http/ylong_http_client/src/sync_impl/ |
| D | pool.rs | 71 fn conn<F, E>(&self, connect_fn: F) -> Result<Conn<S>, HttpClientError> in conn()
73 F: FnOnce() -> Result<S, E>, in conn()
|
| /commonlibrary/rust/ylong_runtime/ylong_runtime/src/task/ |
| D | mod.rs | 91 scheduler: Weak<S>, in create_task()
108 scheduler: Weak<S>, in create_raw_task()
|
| D | raw.rs | 398 scheduler: Weak<S>, in new()
422 pub(crate) fn inner(&self) -> &Inner<T, S> { in inner() argument
|
| D | task_handle.rs | 49 fn inner(&self) -> &Inner<T, S> { in inner() argument
|
| /commonlibrary/rust/ylong_http/ylong_http_client/src/util/c_openssl/ |
| D | bio.rs | 134 unsafe fn get_state<'a, S: 'a>(bio: *mut BIO) -> &'a mut StreamState<S> { in get_state() argument
148 pub(crate) unsafe fn get_stream_ref<'a, S: 'a>(bio: *mut BIO) -> &'a S { in get_stream_ref() argument
153 pub(crate) unsafe fn get_stream_mut<'a, S: 'a>(bio: *mut BIO) -> &'a mut S { in get_stream_mut() argument
|
| /commonlibrary/rust/ylong_http/ylong_http_client/src/async_impl/ssl_stream/ |
| D | wrapper.rs | 34 unsafe fn inner(&mut self) -> (Pin<&mut S>, &mut Context<'_>) { in inner()
|
| D | c_ssl_stream.rs | 45 fn get_pin_mut(self: Pin<&mut Self>) -> Pin<&mut S> { in get_pin_mut()
|
| /commonlibrary/rust/ylong_http/ylong_http_client/src/util/c_openssl/ssl/ |
| D | stream.rs | 71 pub(crate) fn get_ref(&self) -> &S { in get_ref()
78 pub(crate) fn get_mut(&mut self) -> &mut S { in get_mut()
|
| D | ssl_base.rs | 56 pub(crate) fn connect<S>(self, stream: S) -> Result<SslStream<S>, HandshakeError<S>> in connect()
|
| D | error.rs | 147 fn from(e: ErrorStack) -> HandshakeError<S> { in from()
|