Searched refs:DispatchErrorKind (Results 1 – 5 of 5) sorted by relevance
| /ohos5.0/commonlibrary/rust/ylong_http/ylong_http_client/src/util/h2/ |
| H A D | manager.rs | 36 Exit(DispatchErrorKind),
60 type Output = Result<(), DispatchErrorKind>;
150 ) -> Poll<Result<(), DispatchErrorKind>> { in manage_pending_state() argument
232 ) -> Result<(), DispatchErrorKind> { in input_stream_frame() argument
294 ) -> Poll<Result<(), DispatchErrorKind>> { in poll_recv_frame() argument
535 kind: DispatchErrorKind, in manage_resp_error() argument
536 ) -> Poll<Result<(), DispatchErrorKind>> { in manage_resp_error() argument
560 ) -> Poll<Result<(), DispatchErrorKind>> { in manage_stream_error() argument
604 ) -> Poll<Result<(), DispatchErrorKind>> { in manage_conn_error() argument
669 ) -> Result<(), DispatchErrorKind> { in send_peer_goaway() argument
[all …]
|
| H A D | output.rs | 27 DispatchErrorKind, OutputMessage, SettingsState, SettingsSync,
37 Exit(DispatchErrorKind),
52 type Output = Result<(), DispatchErrorKind>;
96 return self.transmit_error(cx, DispatchErrorKind::Disconnect); in poll_read_frame()
146 return Poll::Ready(Err(DispatchErrorKind::ChannelClosed)); in poll_blocked_task()
165 ) -> Poll<Result<(), DispatchErrorKind>> { in poll_iterator_frames() argument
172 OutputMessage::OutputExit(DispatchErrorKind::H2(e)) in poll_iterator_frames()
197 exit_err: DispatchErrorKind, in transmit_error() argument
198 ) -> Poll<Result<(), DispatchErrorKind>> { in transmit_error() argument
212 ) -> Poll<Result<(), DispatchErrorKind>> { in transmit_message() argument
[all …]
|
| H A D | input.rs | 24 use crate::util::dispatcher::http2::{DispatchErrorKind, SettingsState, SettingsSync};
70 type Output = Result<(), DispatchErrorKind>;
100 DispatchErrorKind::H2(H2Error::ConnectionError(ErrorCode::IntervalError)) in poll()
135 fn poll_writer_frame(&mut self, cx: &mut Context<'_>) -> Poll<Result<(), DispatchErrorKind>> { in poll_writer_frame() argument
140 .map_err(|e| DispatchErrorKind::Io(e.kind()))? in poll_writer_frame()
158 DispatchErrorKind::H2(H2Error::ConnectionError(ErrorCode::IntervalError)) in poll_writer_frame()
169 .map_err(|e| DispatchErrorKind::Io(e.kind()))? in poll_writer_frame()
190 fn poll_recv_frame(&mut self, cx: &mut Context<'_>) -> Poll<Result<Frame, DispatchErrorKind>> { in poll_recv_frame() argument
193 Poll::Ready(None) => Poll::Ready(Err(DispatchErrorKind::ChannelClosed)), in poll_recv_frame()
199 Poll::Ready(Err(_e)) => Poll::Ready(Err(DispatchErrorKind::ChannelClosed)), in poll_recv_frame()
|
| H A D | streams.rs | 23 use crate::util::dispatcher::http2::DispatchErrorKind;
375 ) -> Result<(), DispatchErrorKind> { in window_update_conn() argument
379 .map_err(|_e| DispatchErrorKind::ChannelClosed)?; in window_update_conn()
387 ) -> Result<(), DispatchErrorKind> { in window_update_streams() argument
399 .map_err(|_e| DispatchErrorKind::ChannelClosed)?; in window_update_streams()
|
| /ohos5.0/commonlibrary/rust/ylong_http/ylong_http_client/src/util/ |
| H A D | dispatcher.rs | 186 OutputExit(DispatchErrorKind),
191 OutputExit(DispatchErrorKind),
201 pub(crate) enum DispatchErrorKind { enum
620 .map_err(|e| DispatchErrorKind::Io(e.kind())) in async_send_preface()
635 impl From<std::io::Error> for DispatchErrorKind { implementation
637 DispatchErrorKind::Io(value.kind()) in from()
641 impl From<H2Error> for DispatchErrorKind { implementation
643 DispatchErrorKind::H2(err) in from()
650 DispatchErrorKind::Io(e) => { in dispatch_client_error()
653 DispatchErrorKind::ChannelClosed => { in dispatch_client_error()
[all …]
|