| /ohos5.0/commonlibrary/rust/ylong_http/ylong_http/src/h2/ |
| H A D | decoder.rs | 16 use super::{Frame, H2Error};
222 fn hpack_decode(&mut self, buf: &[u8]) -> Result<(), H2Error> { in hpack_decode() argument
226 fn hpack_finish(&mut self) -> Result<Parts, H2Error> { in hpack_finish() argument
348 pub fn decode(&mut self, buf: &[u8]) -> Result<Frames, H2Error> { in decode() argument
380 ) -> Result<Option<(&'a [u8], FrameKind)>, H2Error> { in decode_frame_payload() argument
451 return Err(H2Error::StreamError( in decode_priority_payload()
517 return Err(H2Error::StreamError( in decode_window_update_payload()
774 ) -> Result<FrameKind, H2Error> { in push_promise_framing() argument
890 use crate::h2::{ErrorCode, H2Error, PseudoHeaders};
1418 Err(H2Error::ConnectionError(ErrorCode::ProtocolError)) in ut_decode_ping_payload()
[all …]
|
| H A D | error.rs | 33 pub enum H2Error { enum
111 type Error = H2Error;
128 _ => return Err(H2Error::ConnectionError(ErrorCode::ProtocolError)), in try_from()
|
| H A D | frame.rs | 17 use crate::h2::{ErrorCode, H2Error, Parts, PseudoHeaders};
566 pub fn error(&self, id: u32) -> Result<H2Error, H2Error> { in error() argument
567 Ok(H2Error::StreamError( in error()
|
| H A D | mod.rs | 63 pub use error::{ErrorCode, H2Error};
|
| /ohos5.0/commonlibrary/rust/ylong_http/ylong_http_client/src/util/h2/ |
| H A D | streams.rs | 20 use ylong_http::h2::{Data, ErrorCode, Frame, FrameFlags, H2Error, Payload};
35 Err(H2Error),
49 Err(H2Error),
279 return Err(H2Error::ConnectionError(ErrorCode::FlowControlError)); in release_conn_recv_window()
362 ) -> Result<(), H2Error> { in reassign_stream_send_window() argument
407 pub(crate) fn headers(&mut self, id: u32) -> Result<Option<Frame>, H2Error> { in headers() argument
409 None => Err(H2Error::ConnectionError(ErrorCode::IntervalError)), in headers()
421 ) -> Result<DataReadState, H2Error> { in poll_read_body() argument
428 None => Err(H2Error::ConnectionError(ErrorCode::IntervalError)), in poll_read_body()
458 ) -> Result<DataReadState, H2Error> { in poll_sized_data() argument
[all …]
|
| H A D | manager.rs | 22 ErrorCode, Frame, FrameFlags, Goaway, H2Error, Payload, Ping, RstStream, Setting,
305 H2Error::ConnectionError(ErrorCode::ProtocolError).into() in poll_recv_frame()
402 ) -> Poll<Result<(), H2Error>> { in recv_go_away_frame() argument
444 ) -> Poll<Result<(), H2Error>> { in recv_reset_frame() argument
464 ) -> Poll<Result<(), H2Error>> { in recv_header_frame() argument
539 H2Error::StreamError(id, code) => self.manage_stream_error(cx, id, code), in manage_resp_error()
540 H2Error::ConnectionError(code) => self.manage_conn_error(cx, code), in manage_resp_error()
631 self.exit_with_error(cx, DispatchErrorKind::H2(H2Error::ConnectionError(code))); in manage_conn_error()
635 self.next_state = ManagerState::Exit(H2Error::ConnectionError(code).into()); in manage_conn_error()
641 Poll::Ready(Err(H2Error::ConnectionError(code).into())) in manage_conn_error()
[all …]
|
| H A D | data_ref.rs | 19 use ylong_http::h2::{ErrorCode, H2Error};
43 ) -> Poll<Result<usize, H2Error>> { in poll_read() argument
54 Poll::Ready(Err(H2Error::ConnectionError(ErrorCode::IntervalError))) in poll_read()
|
| H A D | output.rs | 22 ErrorCode, Frame, FrameDecoder, FrameKind, FramesIntoIter, H2Error, Payload, Setting,
231 fn update_settings(&mut self, frame: &Frame) -> Result<(), H2Error> { in update_settings() argument
240 fn update_decoder_settings(&mut self) -> Result<(), H2Error> { in update_decoder_settings() argument
254 SettingsState::Synced => Err(H2Error::ConnectionError(ErrorCode::ConnectError)), in update_decoder_settings()
|
| H A D | input.rs | 21 use ylong_http::h2::{ErrorCode, Frame, FrameEncoder, H2Error, Payload, Setting, Settings};
100 DispatchErrorKind::H2(H2Error::ConnectionError(ErrorCode::IntervalError)) in poll()
158 DispatchErrorKind::H2(H2Error::ConnectionError(ErrorCode::IntervalError)) in poll_writer_frame()
|
| /ohos5.0/commonlibrary/rust/ylong_http/ylong_http/src/h2/hpack/ |
| H A D | decoder.rs | 21 use crate::h2::{H2Error, Parts};
55 pub(crate) fn decode(&mut self, buf: &[u8]) -> Result<(), H2Error> { in decode() argument
76 pub(crate) fn finish(&mut self) -> Result<Parts, H2Error> { in finish() argument
78 return Err(H2Error::ConnectionError(ErrorCode::CompressionError)); in finish()
113 fn update(&mut self, repr: Representation) -> Result<(), H2Error> { in update() argument
132 fn update_indexed(&mut self, index: usize) -> Result<(), H2Error> { in update_indexed() argument
136 .ok_or(H2Error::ConnectionError(ErrorCode::CompressionError))?; in update_indexed()
154 ) -> Result<(), H2Error> { in update_literal_without_indexing() argument
170 Err(H2Error::ConnectionError(ErrorCode::ConnectError)) in check_header_list_size()
184 ) -> Result<(Header, String), H2Error> { in get_header_by_name_and_value() argument
[all …]
|
| H A D | integer.rs | 28 use crate::h2::H2Error;
69 pub(crate) fn next_byte(&mut self, byte: u8) -> Result<Option<usize>, H2Error> { in next_byte() argument
74 .ok_or(H2Error::ConnectionError(ErrorCode::CompressionError))?; in next_byte()
|
| /ohos5.0/commonlibrary/rust/ylong_http/ylong_http/src/ |
| H A D | error.rs | 30 use crate::h2::H2Error;
52 impl From<H2Error> for HttpError {
53 fn from(err: H2Error) -> Self { in from()
86 H2(H2Error),
|
| /ohos5.0/commonlibrary/rust/ylong_http/ylong_http_client/src/util/h2/buffer/ |
| H A D | window.rs | 16 use ylong_http::h2::{ErrorCode, Frame, FrameFlags, H2Error, Payload, WindowUpdate};
42 pub(crate) fn increase_size(&mut self, size: u32) -> Result<(), H2Error> { in increase_size() argument
45 return Err(H2Error::ConnectionError(ErrorCode::FlowControlError)); in increase_size()
48 return Err(H2Error::ConnectionError(ErrorCode::FlowControlError)); in increase_size()
|
| H A D | settings.rs | 16 use ylong_http::h2::{Frame, H2Error};
50 pub(crate) fn increase_send_size(&mut self, size: u32) -> Result<(), H2Error> { in increase_send_size() argument
|
| /ohos5.0/commonlibrary/rust/ylong_http/ylong_http/src/h2/hpack/representation/ |
| H A D | decoder.rs | 19 use crate::h2::H2Error;
46 pub(crate) fn decode(&mut self) -> Result<Option<Representation>, H2Error> { in decode() argument
173 H2Error::ConnectionError(ErrorCode::CompressionError).into() in decode()
498 return H2Error::ConnectionError(ErrorCode::CompressionError).into(); in decode()
503 Err(_) => H2Error::ConnectionError(ErrorCode::CompressionError).into(), in decode()
508 return H2Error::ConnectionError(ErrorCode::CompressionError).into(); in decode()
559 Error(H2Error),
562 impl<D, S> From<H2Error> for DecResult<D, S> {
563 fn from(e: H2Error) -> Self { in from()
|
| /ohos5.0/commonlibrary/rust/ylong_http/ylong_http_client/src/util/ |
| H A D | dispatcher.rs | 160 ErrorCode, Frame, FrameDecoder, FrameEncoder, FrameFlags, Goaway, H2Error, Payload,
202 H2(H2Error),
456 ) -> Result<Vec<u32>, H2Error> { in get_unsent_streams() argument
460 return Err(H2Error::ConnectionError(ErrorCode::ProtocolError)); in get_unsent_streams()
471 ) -> Poll<Result<(), H2Error>> { in send_message_to_stream() argument
485 Poll::Ready(Err(H2Error::StreamError(stream_id, ErrorCode::NoError))) in send_message_to_stream()
493 Poll::Ready(Err(H2Error::StreamError(stream_id, ErrorCode::NoError))) in send_message_to_stream()
641 impl From<H2Error> for DispatchErrorKind {
642 fn from(err: H2Error) -> Self { in from()
|
| /ohos5.0/commonlibrary/rust/ylong_http/ylong_http_client/src/async_impl/conn/ |
| H A D | http2.rs | 22 use ylong_http::h2::{ErrorCode, Frame, FrameFlags, H2Error, Payload, PseudoHeaders};
82 HttpError::from(H2Error::StreamError(conn.id, ErrorCode::ProtocolError)), in frame_2_response()
95 HttpError::from(H2Error::StreamError( in frame_2_response()
104 HttpError::from(H2Error::StreamError(conn.id, ErrorCode::ProtocolError)), in frame_2_response()
273 HttpError::from(H2Error::ConnectionError(ErrorCode::ProtocolError)), in match_channel_message()
279 HttpError::from(H2Error::ConnectionError(ErrorCode::ProtocolError)), in match_channel_message()
329 HttpError::from(H2Error::ConnectionError(ErrorCode::ProtocolError)), in read_remaining_data()
|