Home
last modified time | relevance | path

Searched refs:RstStream (Results 1 – 7 of 7) sorted by relevance

/ohos5.0/commonlibrary/rust/ylong_http/ylong_http/src/h2/
H A Dframe.rs64 RstStream = 0x03, enumerator
85 RstStream(RstStream), enumerator
149 pub struct RstStream { struct
314 Payload::RstStream(_) => FrameType::RstStream, in frame_type()
554 impl RstStream { impl
723 let payload_rst_stream = Payload::RstStream(RstStream::new(20)); in ut_payload()
724 assert_eq!(payload_rst_stream.frame_type(), FrameType::RstStream); in ut_payload()
H A Dmod.rs65 Data, Frame, FrameFlags, Goaway, Headers, Payload, Ping, RstStream, Setting, Settings,
H A Dencoder.rs159 Payload::RstStream(_) => self.state = FrameEncoderState::EncodingRstStreamFrame, in set_frame()
1144 *item = FrameType::RstStream as u8; in encode_rst_stream_frame()
1172 if let Payload::RstStream(rst_stream) = frame.payload() { in encode_rst_stream_payload()
1325 Data, FrameFlags, Goaway, Headers, Ping, Priority, RstStream, Settings, WindowUpdate,
1601 let rst_stream_payload = Payload::RstStream(RstStream::new(error_code)); in ut_rst_stream_frame_encoding()
1621 assert_eq!(buf[3], FrameType::RstStream as u8); in ut_rst_stream_frame_encoding()
H A Ddecoder.rs22 Data, FrameFlags, Goaway, Ping, Priority, RstStream, WindowUpdate, ACK_MASK, END_HEADERS_MASK,
548 frame::Payload::RstStream(RstStream::new(code)), in decode_reset_payload()
1586 Payload::RstStream(reset_stream) => { in ut_decode_reset_payload()
/ohos5.0/commonlibrary/rust/ylong_http/ylong_http_client/src/util/h2/
H A Dmanager.rs22 ErrorCode, Frame, FrameFlags, Goaway, H2Error, Payload, Ping, RstStream, Setting,
311 Payload::RstStream(_reset) => { in poll_recv_frame()
561 let rest_payload = RstStream::new(code.into_code()); in manage_stream_error()
565 Payload::RstStream(rest_payload), in manage_stream_error()
/ohos5.0/commonlibrary/rust/ylong_http/ylong_http_client/src/util/
H A Ddispatcher.rs161 RstStream, Settings, SettingsBuilder,
516 RstStream::new(ErrorCode::NoError.into_code()); in poll_blocked_message()
520 Payload::RstStream(rest_payload), in poll_blocked_message()
/ohos5.0/commonlibrary/rust/ylong_http/ylong_http_client/src/async_impl/conn/
H A Dhttp2.rs92 Payload::RstStream(reset) => { in frame_2_response()
266 Payload::RstStream(reset) => { in match_channel_message()