Searched refs:last_stream_id (Results 1 – 6 of 6) sorted by relevance
| /ohos5.0/commonlibrary/rust/ylong_http/ylong_http/src/h2/ |
| H A D | frame.rs | 176 last_stream_id: StreamId, field
477 pub fn new(error_code: u32, last_stream_id: StreamId, debug_data: Vec<u8>) -> Self { in new()
480 last_stream_id, in new()
492 self.last_stream_id in get_last_stream_id()
|
| H A D | encoder.rs | 1746 let last_stream_id = 1; in ut_goaway_frame_encoding() localVariable
1752 Payload::Goaway(Goaway::new(error_code, last_stream_id, debug_data.clone())), in ut_goaway_frame_encoding()
1770 expected_encoded_goaway[0..4].copy_from_slice(&(last_stream_id as u32).to_be_bytes()); in ut_goaway_frame_encoding()
|
| H A D | decoder.rs | 488 let last_stream_id = get_stream_id(&buf[..4]) as usize; in decode_goaway_payload() localVariable
495 frame::Payload::Goaway(Goaway::new(error_code, last_stream_id, debug_data)), in decode_goaway_payload()
|
| /ohos5.0/commonlibrary/rust/ylong_http/ylong_http_client/src/util/ |
| H A D | dispatcher.rs | 455 last_stream_id: u32, in get_unsent_streams()
459 if self.streams.max_send_id < last_stream_id { in get_unsent_streams()
462 self.streams.max_send_id = last_stream_id; in get_unsent_streams()
463 Ok(self.streams.get_go_away_streams(last_stream_id)) in get_unsent_streams()
|
| /ohos5.0/commonlibrary/rust/ylong_http/ylong_http_client/src/util/h2/ |
| H A D | manager.rs | 412 let last_stream_id = go_away.get_last_stream_id(); in recv_go_away_frame() localVariable
413 let streams = self.controller.get_unsent_streams(last_stream_id as u32)?; in recv_go_away_frame()
650 let last_stream_id = self.controller.streams.latest_remote_id as usize; in poll_deal_with_go_away() localVariable
651 let go_away_payload = Goaway::new(error_code, last_stream_id, vec![]); in poll_deal_with_go_away()
|
| H A D | streams.rs | 495 pub(crate) fn get_go_away_streams(&mut self, last_stream_id: u32) -> Vec<u32> { in get_go_away_streams()
498 if *id >= last_stream_id { in get_go_away_streams()
|