Home
last modified time | relevance | path

Searched refs:Payload (Results 1 - 18 of 18) sorted by relevance

/commonlibrary/rust/ylong_http/ylong_http/src/h2/
H A Dframe.rs51 /// information. The frame type information is represented by the `Payload`
58 payload: Payload,
81 pub enum Payload { enum
210 /// `Payload`.
211 pub fn new(id: StreamId, flags: FrameFlags, payload: Payload) -> Self { in new()
220 /// Returns a reference to the frame's payload (`Payload`).
221 pub fn payload(&self) -> &Payload { in payload()
225 /// Returns a mutable reference to the frame's payload (`Payload`).
227 pub(crate) fn payload_mut(&mut self) -> &mut Payload {
296 impl Payload { impls
[all...]
H A Ddecoder.rs20 use crate::h2::decoder::Stage::{Header, Payload};
190 Payload,
357 self.stage = Payload; in decode()
363 Payload => match self.decode_frame_payload(buffer)? { in decode()
440 frame::Payload::Ping(Ping::new(opaque_data)), in decode_ping_payload()
470 frame::Payload::Priority(Priority::new(exclusive, stream_dependency, weight)), in decode_priority_payload()
496 frame::Payload::Goaway(Goaway::new(error_code, last_stream_id, debug_data)), in decode_goaway_payload()
526 frame::Payload::WindowUpdate(WindowUpdate::new(increment_size)), in decode_window_update_payload()
549 frame::Payload::RstStream(RstStream::new(code)), in decode_reset_payload()
575 frame::Payload in decode_settings_payload()
[all...]
H A Dencoder.rs16 use crate::h2::frame::{FrameFlags, FrameType, Payload, Priority, Setting};
146 Payload::Headers(headers) => { in set_frame()
158 Payload::Priority(_) => self.state = FrameEncoderState::EncodingPriorityFrame, in set_frame()
159 Payload::RstStream(_) => self.state = FrameEncoderState::EncodingRstStreamFrame, in set_frame()
160 Payload::Ping(_) => self.state = FrameEncoderState::EncodingPingFrame, in set_frame()
161 Payload::Data(data) => { in set_frame()
168 Payload::Settings(_) => self.state = FrameEncoderState::EncodingSettingsFrame, in set_frame()
169 Payload::Goaway(_) => self.state = FrameEncoderState::EncodingGoawayFrame, in set_frame()
170 Payload::WindowUpdate(_) => { in set_frame()
337 if let Payload in update_setting()
[all...]
H A Dmod.rs65 Data, Frame, FrameFlags, Goaway, Headers, Payload, Ping, RstStream, Setting, Settings,
/commonlibrary/rust/ylong_http/ylong_http_client/src/util/h2/
H A Dmanager.rs22 ErrorCode, Frame, FrameFlags, Goaway, H2Error, Payload, Ping, RstStream, Setting, StreamId,
256 Payload::Headers(_) => { in poll_send_frame()
266 Payload::Data(_) => { in poll_send_frame()
290 Payload::Settings(_settings) => { in poll_recv_frame()
293 Payload::Ping(_ping) => { in poll_recv_frame()
296 Payload::PushPromise(_) => { in poll_recv_frame()
302 Payload::Goaway(_go_away) => { in poll_recv_frame()
305 Payload::RstStream(_reset) => { in poll_recv_frame()
308 Payload::Headers(_headers) => { in poll_recv_frame()
311 Payload in poll_recv_frame()
[all...]
H A Doutput.rs22 ErrorCode, Frame, FrameDecoder, FrameKind, FramesIntoIter, H2Error, Payload, Setting,
232 if let Payload::Settings(_settings) = frame.payload() { in update_settings()
H A Dstreams.rs20 use ylong_http::h2::{Data, ErrorCode, Frame, FrameFlags, H2Error, Payload, StreamId};
127 pub(crate) payload: Payload,
487 Payload::Data(Data::new(data_vec)), in poll_sized_data()
496 Payload::Data(Data::new(data_vec)), in poll_sized_data()
H A Dinput.rs21 use ylong_http::h2::{ErrorCode, Frame, FrameEncoder, H2Error, Payload, Setting, Settings};
206 let settings = if let Payload::Settings(settings) = frame.payload() { in update_settings()
/commonlibrary/rust/ylong_http/ylong_http_client/src/async_impl/conn/
H A Dhttp2.rs22 use ylong_http::h2::{ErrorCode, Frame, FrameFlags, H2Error, Payload, PseudoHeaders};
76 Payload::Headers(headers) => { in frame_2_response()
97 Payload::RstStream(reset) => { in frame_2_response()
136 ) -> Result<(FrameFlags, Payload), HttpError> {
149 Ok((flag, Payload::Headers(headers_payload)))
249 Payload::Headers(_) => { in match_channel_message()
254 Payload::Data(data) => { in match_channel_message()
269 Payload::RstStream(reset) => { in match_channel_message()
313 Payload::Headers(_) => Some(Poll::Ready(Ok(()))), in read_remaining_data()
314 Payload in read_remaining_data()
[all...]
H A Dhttp3.rs22 Frame, H3Error, H3ErrorCode, Headers, Parts, Payload, PseudoHeaders, HEADERS_FRAME_TYPE,
74 Payload::Headers(headers_payload),
111 Payload::Headers(headers) => { in frame_2_response()
130 Payload::PushPromise(_) => { in frame_2_response()
201 Payload::Headers(_) => { in match_channel_message()
206 Payload::Data(data) => { in match_channel_message()
258 Payload::Headers(_) => Some(Poll::Ready(Ok(()))), in read_remaining_data()
259 Payload::Data(data) => { in read_remaining_data()
/commonlibrary/rust/ylong_http/ylong_http/src/h3/
H A Dframe.rs48 payload: Payload,
53 pub enum Payload { enum
132 pub fn new(ty: u64, payload: Payload) -> Self { in new()
142 pub fn payload(&self) -> &Payload { in payload()
147 pub(crate) fn payload_mut(&mut self) -> &mut Payload {
H A Dencoder.rs25 use crate::h3::frame::{Headers, Payload};
76 /// use ylong_http::h3::{Data, Frame, FrameEncoder, Payload};
81 /// Payload::Data(Data::new(vec![b'h', b'e', b'l', b'l', b'o'])),
131 if let Payload::Headers(h) = frame.payload() { in set_frame()
167 /// use ylong_http::h3::{Data, Frame, FrameEncoder, Payload};
172 /// Payload::Data(Data::new(vec![b'h', b'e', b'l', b'l', b'o'])),
344 if let Payload::Settings(settings) = frame.payload() { in encode_settings_payload()
494 if let Payload::Data(d) = frame.payload() { in encode_data_len()
509 if let Payload::CancelPush(push) = frame.payload() { in encode_cancel_push()
522 if let Payload in encode_goaway()
[all...]
H A Ddecoder.rs21 CancelPush, Data, GoAway, Headers, MaxPushId, Payload, PushPromise, Settings, DATA_FRAME_TYPE,
514 Payload::Data(Data::new(Vec::from(reader.remaining()))), in decode_data_payload()
524 Payload::Data(Data::new(Vec::from(reader.slice(payload_len)?))), in decode_data_payload()
558 Frame::new(HEADERS_FRAME_TYPE, Payload::Headers(headers_payload)) in get_qpack_decoded_header()
566 Frame::new(PUSH_PROMISE_FRAME_TYPE, Payload::PushPromise(push_promise)) in get_qpack_decoded_header()
627 Frame::new(frame::GOAWAY_FRAME_TYPE, Payload::Goaway(GoAway::new(id))); in decode_variable_payload()
633 Payload::MaxPushId(MaxPushId::new(id)), in decode_variable_payload()
640 Payload::CancelPush(CancelPush::new(id)), in decode_variable_payload()
703 let frame = Frame::new(SETTINGS_FRAME_TYPE, Payload::Settings(settings)); in decode_settings_payload()
771 use crate::h3::{FrameDecoder, FrameKind, Payload, StreamMessag
[all...]
H A Dmod.rs30 Data, Frame, Headers, Payload, Settings, DATA_FRAME_TYPE, HEADERS_FRAME_TYPE,
/commonlibrary/rust/ylong_http/ylong_http_client/src/util/h2/buffer/
H A Dwindow.rs16 use ylong_http::h2::{ErrorCode, Frame, FrameFlags, H2Error, Payload, StreamId, WindowUpdate};
123 let frame = Frame::new(id, FrameFlags::new(0), Payload::WindowUpdate(window_update));
/commonlibrary/rust/ylong_http/ylong_http_client/src/util/h3/
H A Dstreams.rs20 use ylong_http::h3::{Data, Frame, H3Error, H3ErrorCode, Payload, DATA_FRAME_TYPE};
191 if let Payload::Headers(_) = frame.payload() {
200 if let Payload::Headers(_) = frame.payload() {
209 if let Payload::Headers(_) = frame.payload() {
493 Payload::Data(Data::new(data_vec)),
H A Dstream_manager.rs24 Frame, FrameDecoder, FrameEncoder, FrameKind, Frames, H3Error, H3ErrorCode, Headers, Payload,
354 let settings = Frame::new(SETTINGS_FRAME_TYPE, Payload::Settings(settings));
543 Payload::Headers(headers) => { in recv_request_stream()
547 Payload::Data(_) => { in recv_request_stream()
550 Payload::PushPromise(_) => { in recv_request_stream()
587 Payload::Settings(settings) => { in recv_control_stream()
591 Payload::Goaway(goaway) => { in recv_control_stream()
594 Payload::CancelPush(_cancel) => { in recv_control_stream()
/commonlibrary/rust/ylong_http/ylong_http_client/src/util/
H A Ddispatcher.rs192 ErrorCode, Frame, FrameDecoder, FrameEncoder, FrameFlags, Goaway, H2Error, Payload,
528 Payload::RstStream(rest_payload),
640 Frame::new(0, FrameFlags::new(0), Payload::Settings(settings))

Completed in 11 milliseconds