| /commonlibrary/rust/ylong_http/ylong_http_client/src/util/h3/ |
| D | stream_manager.rs | 57 io_manager_tx: UnboundedSender<Result<(), DispatchErrorKind>>, in new() argument
84 ) -> Poll<Result<Result<(), DispatchErrorKind>, DispatchErrorKind>> { in poll_recv_signal() argument
102 ) -> Poll<Result<ReqMessage, DispatchErrorKind>> { in poll_recv_request() argument
121 ) -> Result<(), DispatchErrorKind> { in send_inst_to_peer() argument
138 error: DispatchErrorKind, in transmit_error()
139 ) -> Result<(), DispatchErrorKind> { in transmit_error() argument
143 fn poll_input_request(&mut self, cx: &mut Context<'_>) -> Result<(), DispatchErrorKind> { in poll_input_request() argument
162 ) -> Result<(), DispatchErrorKind> { in input_stream_frame() argument
210 fn poll_send_header(&mut self, id: u64, frame: Frame) -> Result<(), DispatchErrorKind> { in poll_send_header() argument
254 fn poll_send_frame(&mut self, id: u64, frame: Option<Frame>) -> Result<(), DispatchErrorKind> { in poll_send_frame() argument
[all …]
|
| D | io_manager.rs | 51 io_manager_rx: UnboundedReceiver<Result<(), DispatchErrorKind>>, in new() argument
68 ) -> Poll<Result<Result<(), DispatchErrorKind>, DispatchErrorKind>> { in poll_recv_signal() argument
83 fn poll_io_recv(&mut self, cx: &mut Context<'_>) -> Poll<Result<(), DispatchErrorKind>> { in poll_io_recv() argument
124 fn poll_io_send(&mut self, cx: &mut Context<'_>) -> Poll<Result<(), DispatchErrorKind>> { in poll_io_send() argument
|
| D | streams.rs | 90 ) -> Poll<Result<(), DispatchErrorKind>> { in transmit_message() argument
165 ) -> Result<(), DispatchErrorKind> { in new_unidirectional_stream() argument
187 ) -> Result<(), DispatchErrorKind> { in send_frame() argument
242 error: DispatchErrorKind, in send_error()
243 ) -> Result<(), DispatchErrorKind> { in send_error() argument
308 ) -> Result<(), DispatchErrorKind> { in set_peer_qpack_encode_stream_id() argument
321 pub(crate) fn set_peer_control_stream_id(&mut self, id: u64) -> Result<(), DispatchErrorKind> { in set_peer_control_stream_id() argument
337 ) -> Result<(), DispatchErrorKind> { in set_peer_qpack_decode_stream_id() argument
351 pub(crate) fn set_goaway_id(&mut self, id: u64) -> Result<(), DispatchErrorKind> { in set_goaway_id() argument
363 pub(crate) fn get_header(&mut self, id: u64) -> Result<Option<Frame>, DispatchErrorKind> { in get_header() argument
[all …]
|
| /commonlibrary/rust/ylong_http/ylong_http_client/src/util/h2/ |
| D | manager.rs | 148 ) -> Poll<Result<(), DispatchErrorKind>> { in manage_pending_state() argument
159 fn poll_recv_request(&mut self, cx: &mut Context<'_>) -> Result<(), DispatchErrorKind> { in poll_recv_request() argument
197 fn poll_input_request(&mut self, cx: &mut Context<'_>) -> Result<(), DispatchErrorKind> { in poll_input_request() argument
219 ) -> Result<(), DispatchErrorKind> { in input_stream_frame() argument
253 ) -> Result<(), DispatchErrorKind> { in deal_poll_body_error() argument
263 fn poll_send_frame(&mut self, frame: Frame) -> Result<(), DispatchErrorKind> { in poll_send_frame() argument
298 ) -> Poll<Result<(), DispatchErrorKind>> { in poll_recv_frame() argument
333 fn recv_settings_frame(&mut self, frame: Frame) -> Result<(), DispatchErrorKind> { in recv_settings_frame() argument
383 fn recv_ping_frame(&mut self, frame: Frame) -> Result<(), DispatchErrorKind> { in recv_ping_frame() argument
483 ) -> Poll<Result<(), DispatchErrorKind>> { in recv_data_frame() argument
[all …]
|
| D | output.rs | 79 fn poll_read_frame(&mut self, cx: &mut Context<'_>) -> Poll<Result<(), DispatchErrorKind>> { in poll_read_frame() argument
146 fn poll_blocked_task(&mut self, cx: &mut Context<'_>) -> Poll<Result<(), DispatchErrorKind>> { in poll_blocked_task() argument
170 ) -> Poll<Result<(), DispatchErrorKind>> { in poll_iterator_frames() argument
202 exit_err: DispatchErrorKind, in transmit_error()
203 ) -> Poll<Result<(), DispatchErrorKind>> { in transmit_error() argument
217 ) -> Poll<Result<(), DispatchErrorKind>> { in transmit_message() argument
|
| D | input.rs | 135 fn poll_writer_frame(&mut self, cx: &mut Context<'_>) -> Poll<Result<(), DispatchErrorKind>> { in poll_writer_frame() argument
190 fn poll_recv_frame(&mut self, cx: &mut Context<'_>) -> Poll<Result<Frame, DispatchErrorKind>> { in poll_recv_frame() argument
|
| D | streams.rs | 278 ) -> Result<(), DispatchErrorKind> { in release_stream_recv_window() argument
303 ) -> Result<(), DispatchErrorKind> { in release_conn_recv_window() argument
732 pub(crate) fn generate_id(&mut self) -> Result<StreamId, DispatchErrorKind> { in generate_id() argument
|
| /commonlibrary/rust/ylong_http/ylong_http_client/src/util/ |
| D | dispatcher.rs | 370 pub(crate) enum DispatchErrorKind { enum
814 impl From<std::io::Error> for DispatchErrorKind { implementation
820 impl From<H2Error> for DispatchErrorKind { implementation
891 pub(crate) enum DispatchErrorKind { enum
1067 impl From<std::io::Error> for DispatchErrorKind { implementation
1073 impl From<H3Error> for DispatchErrorKind { implementation
1079 impl From<quiche::Error> for DispatchErrorKind { implementation
|