| /commonlibrary/rust/ylong_http/ylong_http_client/src/util/h2/ |
| D | manager.rs | 129 input_tx: UnboundedSender<Frame>, in new()
297 frame: Frame, in poll_recv_frame()
404 frame: Frame, in recv_go_away_frame()
446 frame: Frame, in recv_reset_frame()
462 frame: Frame, in recv_header_frame()
482 frame: Frame, in recv_data_frame()
663 frame: Frame, in send_peer_goaway()
692 frame: Frame, in poll_recv_message()
|
| D | input.rs | 122 req_rx: UnboundedReceiver<Frame>, in new()
190 fn poll_recv_frame(&mut self, cx: &mut Context<'_>) -> Poll<Result<Frame, DispatchErrorKind>> { in poll_recv_frame()
|
| D | streams.rs | 277 sender: &UnboundedSender<Frame>, in release_stream_recv_window()
302 sender: &UnboundedSender<Frame>, in release_conn_recv_window()
333 pub(crate) fn insert(&mut self, id: StreamId, headers: Frame, data: BodyDataRef) { in insert()
407 pub(crate) fn headers(&mut self, id: StreamId) -> Result<Option<Frame>, H2Error> { in headers()
749 headers: Frame, in new()
|
| /commonlibrary/rust/ylong_http/ylong_http/src/h3/ |
| D | frame.rs | 46 pub struct Frame { struct
47 ty: u64,
48 payload: Payload,
130 impl Frame { implementation
|
| /commonlibrary/rust/ylong_http/ylong_http/src/h2/ |
| D | frame.rs | 55 pub struct Frame { struct
57 flags: FrameFlags, argument
64 pub enum FrameType { argument
203 impl Frame { impl
593 pub fn ack(ping: Ping) -> Frame { in ack()
|
| D | encoder.rs | 374 fn try_retrieve_current_frame(&self) -> Result<&Frame, FrameEncoderErr> { in try_retrieve_current_frame()
428 frame: &Frame, in iterate_headers_header()
565 frame: &Frame, in iterate_data_header()
682 frame: &Frame, in iterate_goaway_header()
794 frame: &Frame, in iterate_window_update_header()
887 frame: &Frame, in iterate_settings_header()
1005 frame: &Frame, in iterate_priority_header()
1191 frame: &Frame, in iterate_ping_header()
|
| /commonlibrary/rust/ylong_http/ylong_http_client/src/async_impl/conn/ |
| D | http3.rs | 66 pub(crate) fn build_headers_frame(mut part: RequestPart) -> Result<Frame, HttpError> { in build_headers_frame()
106 headers_frame: Frame, in frame_2_response()
|
| D | http2.rs | 84 headers_frame: Frame, in frame_2_response()
255 poll_result: Poll<Frame>, in match_channel_message()
|
| /commonlibrary/rust/ylong_http/ylong_http_client/src/util/h3/ |
| D | streams.rs | 74 fn new(frame_tx: BoundedSender<RespMessage>, header: Frame, data: BodyDataRef) -> Self { in new()
162 header: Frame, in new_unidirectional_stream()
186 frame: Frame, in send_frame()
363 pub(crate) fn get_header(&mut self, id: u64) -> Result<Option<Frame>, DispatchErrorKind> { in get_header()
|
| /commonlibrary/rust/ylong_http/ylong_http_client/src/util/ |
| D | dispatcher.rs | 501 input_channel: (UnboundedSender<Frame>, UnboundedReceiver<Frame>), in launch()
679 input_tx: &UnboundedSender<Frame>, in poll_blocked_message()
728 pub(crate) async fn recv(&mut self) -> Result<Frame, HttpClientError> { in recv()
760 ) -> Poll<Result<Frame, HttpClientError>> { in poll_recv()
802 pub(crate) fn create_initial_settings(config: &H2Config) -> Frame { in create_initial_settings()
1000 pub(crate) async fn recv_resp(&mut self) -> Result<Frame, HttpClientError> { in recv_resp()
|
| /commonlibrary/rust/ylong_http/ylong_http_client/src/util/h2/buffer/ |
| D | settings.rs | 34 pub(crate) fn check_conn_recv_window_update(&mut self) -> Option<Frame> { in check_conn_recv_window_update()
|
| D | window.rs | 119 pub(crate) fn check_window_update(&mut self, id: StreamId) -> Option<Frame> { in check_window_update()
|