Home
last modified time | relevance | path

Searched refs:Frame (Results 1 - 20 of 20) sorted by relevance

/commonlibrary/rust/ylong_http/ylong_http_client/src/util/h2/
H A Dmanager.rs22 ErrorCode, Frame, FrameFlags, Goaway, H2Error, Payload, Ping, RstStream, Setting, StreamId,
45 input_tx: UnboundedSender<Frame>,
127 input_tx: UnboundedSender<Frame>,
151 // The manager previously accepted a GOAWAY Frame. in manage_pending_state()
187 let headers = Frame::new(id, message.request.flag, message.request.payload); in poll_recv_request()
254 fn poll_send_frame(&mut self, frame: Frame) -> Result<(), DispatchErrorKind> { in poll_send_frame()
287 frame: Frame, in poll_recv_frame()
323 fn recv_settings_frame(&mut self, frame: Frame) -> Result<(), DispatchErrorKind> { in recv_settings_frame()
361 let new_settings = Frame::new( in recv_settings_frame()
374 fn recv_ping_frame(&mut self, frame: Frame)
[all...]
H A Dstreams.rs20 use ylong_http::h2::{Data, ErrorCode, Frame, FrameFlags, H2Error, Payload, StreamId};
44 Ready(Frame),
45 Finish(Frame),
121 pub(crate) header: Option<Frame>,
310 pub(crate) fn insert(&mut self, id: StreamId, headers: Frame, data: BodyDataRef) {
386 sender: &UnboundedSender<Frame>,
398 sender: &UnboundedSender<Frame>,
419 pub(crate) fn headers(&mut self, id: StreamId) -> Result<Option<Frame>, H2Error> {
484 Ok(DataReadState::Ready(Frame::new( in poll_sized_data()
493 Ok(DataReadState::Finish(Frame in poll_sized_data()
[all...]
H A Dinput.rs14 //! Frame send coroutine.
21 use ylong_http::h2::{ErrorCode, Frame, FrameEncoder, H2Error, Payload, Setting, Settings};
30 req_rx: UnboundedReceiver<Frame>,
80 // Errors in the Frame Writer are thrown directly to exit the coroutine.
122 req_rx: UnboundedReceiver<Frame>,
190 fn poll_recv_frame(&mut self, cx: &mut Context<'_>) -> Poll<Result<Frame, DispatchErrorKind>> { in poll_recv_frame()
205 fn update_settings(&mut self, frame: &Frame) -> SettingState { in update_settings()
H A Doutput.rs14 //! Frame recv coroutine.
22 ErrorCode, Frame, FrameDecoder, FrameKind, FramesIntoIter, H2Error, Payload, Setting,
231 fn update_settings(&mut self, frame: &Frame) -> Result<(), H2Error> { in update_settings()
/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};
119 pub(crate) fn check_window_update(&mut self, id: StreamId) -> Option<Frame> {
123 let frame = Frame::new(id, FrameFlags::new(0), Payload::WindowUpdate(window_update));
H A Dsettings.rs16 use ylong_http::h2::{Frame, H2Error};
34 pub(crate) fn check_conn_recv_window_update(&mut self) -> Option<Frame> {
/commonlibrary/rust/ylong_http/ylong_http/src/h2/
H A Ddecoder.rs17 use super::{Frame, H2Error};
155 Complete(Frame),
160 /// Frame bytes sequence decoder, supporting fragment deserialization of Frames.
183 // The Headers Frame flags information is saved to ensure the continuity between Headers Frames
315 /// Frame.
382 // Frames of other types or streams are not allowed between Headers Frame and in decode_frame_payload()
383 // Continuation Frame. in decode_frame_payload()
437 let ping = Frame::new( in decode_ping_payload()
467 let priority = Frame::new( in decode_priority_payload()
493 let goaway = Frame in decode_goaway_payload()
[all...]
H A Dencoder.rs17 use crate::h2::{Frame, Goaway, HpackEncoder, Settings};
92 current_frame: Option<Frame>,
136 pub fn set_frame(&mut self, frame: Frame) -> Result<(), FrameEncoderErr> { in set_frame()
424 frame: &Frame, in iterate_headers_header()
570 frame: &Frame, in iterate_data_header()
694 frame: &Frame, in iterate_goaway_header()
812 frame: &Frame, in iterate_window_update_header()
911 frame: &Frame, in iterate_settings_header()
1035 frame: &Frame, in iterate_priority_header()
1234 frame: &Frame, in iterate_ping_header()
[all...]
H A Dframe.rs55 pub struct Frame { structure names
203 impl Frame { impls
209 /// Constructs a new `Frame` with the given `StreamId`, `FrameFlags`,
212 Frame { id, flags, payload } in new()
393 pub fn ack() -> Frame { in ack()
394 Frame::new( in ack()
593 pub fn ack(ping: Ping) -> Frame { in ack()
594 Frame::new(0, FrameFlags::new(0x1), Payload::Ping(ping)) in ack()
H A Dmod.rs65 Data, Frame, FrameFlags, Goaway, Headers, Payload, Ping, RstStream, Setting, Settings,
/commonlibrary/rust/ylong_http/ylong_http/src/h3/
H A Dstream.rs16 use crate::h3::Frame;
45 Complete(Box<Frame>),
H A Dframe.rs16 /// Data Frame type code.
18 /// HEADERS Frame type code.
20 /// CANCEL_PUSH Frame type code.
22 /// SETTINGS Frame type code.
24 /// PUSH_PROMISE Frame type code.
26 /// GOAWAY Frame type code.
28 /// MAX_PUSH_ID Frame type code.
46 pub struct Frame { structure names
130 impl Frame { impls
131 /// Constructs a Frame wit
[all...]
H A Dmod.rs30 Data, Frame, Headers, Payload, Settings, DATA_FRAME_TYPE, HEADERS_FRAME_TYPE,
H A Ddecoder.rs31 use crate::h3::{frame, is_bidirectional, stream, Frame, H3ErrorCode};
35 /// data, including stream type, Frame, etc.
135 /// including stream type, Frame, etc.
512 let frame = Frame::new( in decode_data_payload()
522 let frame = Frame::new( 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()
631 let frame = Frame::new( in decode_variable_payload()
638 let frame = Frame in decode_variable_payload()
[all...]
H A Dencoder.rs32 use crate::h3::{frame, is_bidirectional, octets, Frame};
39 // Header Frame
42 // Data Frame
45 // CancelPush Frame
47 // Settings Frame
50 // Goaway Frame
52 // MaxPushId Frame
59 current_frame: Option<Frame>,
70 /// HTTP3 frame encoder, which serializes a Frame into a byte stream in the
76 /// use ylong_http::h3::{Data, Frame, FrameEncode
[all...]
/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};
66 pub(crate) header: Option<Frame>,
74 fn new(frame_tx: BoundedSender<RespMessage>, header: Frame, data: BodyDataRef) -> Self { in new()
162 header: Frame,
186 frame: Frame,
363 pub(crate) fn get_header(&mut self, id: u64) -> Result<Option<Frame>, DispatchErrorKind> {
491 Ok(DataReadState::Ready(Box::new(Frame::new(
706 Ready(Box<Frame>),
H A Dstream_manager.rs24 Frame, FrameDecoder, FrameEncoder, FrameKind, Frames, H3Error, H3ErrorCode, Headers, Payload,
210 fn poll_send_header(&mut self, id: u64, frame: Frame) -> Result<(), DispatchErrorKind> { in poll_send_header()
254 fn poll_send_frame(&mut self, id: u64, frame: Option<Frame>) -> Result<(), DispatchErrorKind> { in poll_send_frame()
354 let settings = Frame::new(SETTINGS_FRAME_TYPE, Payload::Settings(settings));
/commonlibrary/rust/ylong_http/ylong_http_client/src/util/
H A Ddispatcher.rs192 ErrorCode, Frame, FrameDecoder, FrameEncoder, FrameFlags, Goaway, H2Error, Payload,
215 Output(Frame),
220 Output(Frame),
346 input_channel: (UnboundedSender<Frame>, UnboundedReceiver<Frame>), in launch()
508 input_tx: &UnboundedSender<Frame>,
525 let frame = Frame::new(
557 pub(crate) async fn recv(&mut self) -> Result<Frame, HttpClientError> {
581 "Invalid Frame Receiver !",
589 ) -> Poll<Result<Frame, HttpClientErro
[all...]
/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};
69 headers_frame: Frame, in frame_2_response()
203 pub(crate) remain: Option<Frame>,
243 poll_result: Poll<Frame>, in match_channel_message()
455 use ylong_http::h2::{Data, Frame, FrameFlags}; in ut_http2_body_poll_read()
468 let data_1 = Frame::new( in ut_http2_body_poll_read()
473 let data_2 = Frame::new( in ut_http2_body_poll_read()
478 let data_3 = Frame::new( in ut_http2_body_poll_read()
H A Dhttp3.rs22 Frame, H3Error, H3ErrorCode, Headers, Parts, Payload, PseudoHeaders, HEADERS_FRAME_TYPE,
64 pub(crate) fn build_headers_frame(mut part: RequestPart) -> Result<Frame, HttpError> {
72 Ok(Frame::new(
104 headers_frame: Frame, in frame_2_response()
155 pub(crate) remain: Option<Frame>,

Completed in 13 milliseconds