| /commonlibrary/rust/ylong_http/ylong_http/src/h3/ |
| H A D | frame.rs | 48 payload: Payload,
51 /// Http3 frame payload.
54 /// HEADERS frame payload.
56 /// DATA frame payload.
58 /// SETTINGS frame payload.
60 /// CancelPush frame payload.
62 /// PushPromise frame payload.
64 /// GOAWAY frame payload.
66 /// MaxPushId frame payload.
68 /// Unknown frame payload
142 pub fn payload(&self) -> &Payload { payload() functions
[all...] |
| H A D | encoder.rs | 115 /// the encoder is updated based on the payload type of the frame.
131 if let Payload::Headers(h) = frame.payload() { in set_frame()
202 let (payload, inst) = stream.encode_headers_payload( in encode()
207 return Ok((payload + frame_bytes, inst)); in encode()
344 if let Payload::Settings(settings) = frame.payload() { in encode_settings_payload()
422 // encode headers frame payload length in encode_headers_with_qpack()
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::Goaway(away) = frame.payload() { in encode_goaway()
539 if let Payload::MaxPushId(push) = frame.payload() { in encode_max_push_id()
[all...] |
| H A D | decoder.rs | 795 if let Payload::Settings(_setting) = frame.payload() { in ut_decode_stream_control_with_setting()
833 if let Payload::Headers(header) = frame.payload() { in ut_decode_stream_request_with_header()
|
| /commonlibrary/rust/ylong_runtime/ylong_io/src/sys/unix/tcp/ |
| H A D | socket.rs | 103 let mut payload: MaybeUninit<linger> = MaybeUninit::uninit(); variables
110 payload.as_mut_ptr().cast(),
114 let linger = unsafe { payload.assume_init() };
120 let payload = into_linger(duration);
125 (&payload as *const linger).cast::<c_void>(),
|
| /commonlibrary/rust/ylong_http/ylong_http/src/h2/ |
| H A D | decoder.rs | 901 Payload: $payload:expr,
909 match frame.payload() {
914 $payload.1.len(),
917 for (key, value) in $payload.1.iter() {
920 for (key, value) in $payload.0.iter() {
976 Payload: $payload:expr,
984 match frame.payload() {
986 assert_eq!(data.data().as_slice(), $payload.as_bytes())
1020 Payload: $payload:expr,
1038 Payload: $payload,
[all...] |
| H A D | encoder.rs | 42 // The state for encoding the payload of the HEADERS frame, including the header block
56 // The state for encoding the actual data payload of the DATA frame.
62 // The state for encoding the SETTINGS frame payload.
66 // The state for encoding the GOAWAY frame payload.
70 // The state for encoding the WINDOW_UPDATE frame payload.
74 // The state for encoding Priority frame payload.
78 // The state for encoding the RST_STREAM frame payload.
82 // The state for encoding the PING frame payload.
135 /// the encoder is updated based on the payload type of the frame.
143 // Set the initial state based on the frame payload typ in set_frame()
[all...] |
| H A D | frame.rs | 39 /// When set, indicates that the frame payload is followed by a padding field.
50 /// HTTP/2 frame structure, including the stream ID, flags, and payload
58 payload: Payload,
78 /// Enum representing the payload of an HTTP/2 frame.
79 /// The payload differs based on the type of frame.
82 /// HEADERS frame payload.
84 /// DATA frame payload.
86 /// PRIORITY frame payload.
88 /// RST_STREAM frame payload.
90 /// PING frame payload
221 pub fn payload(&self) -> &Payload { payload() functions
[all...] |
| /commonlibrary/rust/ylong_http/ylong_http_client/src/util/h2/ |
| H A D | manager.rs | 187 let headers = Frame::new(id, message.request.flag, message.request.payload); in poll_recv_request()
255 match frame.payload() { in poll_send_frame()
289 match frame.payload() { in poll_recv_frame()
324 let settings = if let Payload::Settings(settings) = frame.payload() { in recv_settings_frame()
358 // The reason for copying the payload is to pass information to the io input to in recv_settings_frame()
360 // payload when it is sent in recv_settings_frame()
364 frame.payload().clone(), in recv_settings_frame()
375 let ping = if let Payload::Ping(ping) = frame.payload() { in recv_ping_frame()
397 let go_away = if let Payload::Goaway(goaway) = frame.payload() { in recv_go_away_frame()
471 let data = if let Payload::Data(data) = frame.payload() { in recv_data_frame()
[all...] |
| H A D | output.rs | 232 if let Payload::Settings(_settings) = frame.payload() { in update_settings()
|
| H A D | streams.rs | 127 pub(crate) payload: Payload,
|
| /commonlibrary/rust/ylong_http/ylong_http_client/src/async_impl/conn/ |
| H A D | http2.rs | 54 let (flag, payload) = build_headers_payload(part, false)
59 payload,
75 let part = match headers_frame.payload() { in frame_2_response()
248 Poll::Ready(frame) => match frame.payload() { in match_channel_message()
312 return match frame.payload() { in read_remaining_data()
426 let (flag, payload) = build_headers_payload(request.part().clone(), true).unwrap(); in ut_http2_build_headers_payload()
428 if let Payload::Headers(headers) = payload { in ut_http2_build_headers_payload()
|
| H A D | http3.rs | 110 let part = match headers_frame.payload() { in frame_2_response()
200 Poll::Ready(RespMessage::Output(frame)) => match frame.payload() { in match_channel_message()
257 return match frame.payload() { in read_remaining_data()
|
| /commonlibrary/rust/ylong_http/ylong_http_client/src/util/h3/ |
| H A D | streams.rs | 191 if let Payload::Headers(_) = frame.payload() {
200 if let Payload::Headers(_) = frame.payload() {
209 if let Payload::Headers(_) = frame.payload() {
|
| H A D | stream_manager.rs | 542 match frame.payload() { in recv_request_stream()
586 match frame.payload() { in recv_control_stream()
|