Searched defs:StreamId (Results 1 – 6 of 6) sorted by relevance
| /commonlibrary/rust/ylong_http/ylong_http_client/src/util/h2/ |
| D | streams.rs | 275 id: StreamId, in release_stream_recv_window()
333 pub(crate) fn insert(&mut self, id: StreamId, headers: Frame, data: BodyDataRef) { in insert()
340 pub(crate) fn push_back_pending_send(&mut self, id: StreamId) { in push_back_pending_send()
344 pub(crate) fn push_pending_concurrency(&mut self, id: StreamId) { in push_pending_concurrency()
352 pub(crate) fn next_pending_stream(&mut self) -> Option<StreamId> { in next_pending_stream()
395 id: StreamId, in reassign_stream_send_window()
420 id: StreamId, in poll_read_body()
456 id: StreamId, in poll_sized_data()
498 pub(crate) fn get_unset_streams(&mut self, last_stream_id: StreamId) -> Vec<StreamId> { in get_unset_streams()
523 pub(crate) fn get_all_unclosed_streams(&mut self) -> Vec<StreamId> { in get_all_unclosed_streams()
[all …]
|
| D | manager.rs | 218 id: StreamId, in input_stream_frame()
557 id: StreamId, in manage_stream_error()
759 id: StreamId, in update_window()
|
| /commonlibrary/rust/ylong_http/ylong_http/src/h2/ |
| D | frame.rs | 22 pub type StreamId = u32; typedef
205 pub fn stream_id(&self) -> StreamId { in stream_id()
211 pub fn new(id: StreamId, flags: FrameFlags, payload: Payload) -> Self { in new()
479 pub fn new(error_code: u32, last_stream_id: StreamId, debug_data: Vec<u8>) -> Self { in new()
493 pub fn get_last_stream_id(&self) -> StreamId { in get_last_stream_id()
600 pub fn new(promised_stream_id: StreamId, parts: Parts) -> Self { in new()
|
| D | decoder.rs | 774 promised_stream_id: StreamId, in push_promise_framing()
838 fn get_stream_id(token: &[u8]) -> StreamId { in get_stream_id()
|
| /commonlibrary/rust/ylong_http/ylong_http_client/src/async_impl/conn/ |
| D | http2.rs | 205 fn build_client_error(id: StreamId, code: ErrorCode) -> HttpClientError { in build_client_error()
|
| /commonlibrary/rust/ylong_http/ylong_http_client/src/util/ |
| D | dispatcher.rs | 634 last_stream_id: StreamId, in get_unsent_streams()
635 ) -> Result<Vec<StreamId>, H2Error> { in get_unsent_streams()
648 stream_id: StreamId, in send_message_to_stream()
|