| /ohos5.0/commonlibrary/rust/ylong_http/ylong_http/src/h2/ |
| H A D | decoder.rs | 198 stream_id: usize, field
207 stream_id: usize, field
241 self.stream_id = 0; in reset()
273 stream_id: 0, in new()
284 self.stream_id = 0; in reset()
384 && (self.header.stream_id != self.continuations.stream_id in decode_frame_payload()
721 self.continuations.stream_id = self.header.stream_id; in decode_headers_payload()
789 self.continuations.stream_id = self.header.stream_id; in push_promise_framing()
818 stream_id, in decode_frame_header()
906 assert_eq!(frame.stream_id(), $stream_id);
[all …]
|
| H A D | encoder.rs | 453 *item = (frame.stream_id() >> (24 - (8 * stream_id_byte_index))) as u8; in iterate_headers_header()
514 (frame.stream_id() >> (24 - (8 * stream_id_byte_index))) as u8; in encode_continuation_frames()
599 *item = (frame.stream_id() >> (24 - (8 * stream_id_byte_index))) as u8; in iterate_data_header()
717 *item = (frame.stream_id() >> (24 - (8 * stream_id_byte_index))) as u8; in iterate_goaway_header()
840 *item = (frame.stream_id() >> (24 - (8 * stream_id_byte_index))) as u8; in iterate_window_update_header()
1059 *item = (frame.stream_id() >> (24 - (8 * stream_id_byte_index))) as u8; in iterate_priority_header()
1150 let stream_id = frame.stream_id(); in encode_rst_stream_frame() localVariable
1151 *item = ((stream_id >> (24 - (8 * (buf_index - 5)))) & 0xFF) as u8; in encode_rst_stream_frame()
|
| H A D | frame.rs | 203 pub fn stream_id(&self) -> StreamId { in stream_id() method
|
| /ohos5.0/commonlibrary/rust/ylong_http/ylong_http/src/h3/ |
| H A D | decoder.rs | 25 stream_id: usize, field
32 stream_id: usize, in new()
39 stream_id: stream_id, in new()
52 self.stream_id, in finish_decode_header()
|
| H A D | encoder.rs | 53 stream_id: usize, field
70 stream_id: usize, in new()
73 qpack_encoder: QpackEncoder::new(table, stream_id, qpack_all_post, qpack_drain_index), in new()
74 stream_id, in new()
|
| /ohos5.0/commonlibrary/rust/ylong_http/ylong_http/src/h3/qpack/ |
| H A D | encoder.rs | 85 stream_id: usize, field
110 stream_id: usize, in new()
122 stream_id, in new()
166 fn ack(&mut self, stream_id: usize) -> Result<Option<DecoderInst>, H3errorQpack> { in ack()
167 assert_eq!(stream_id, self.stream_id); in ack()
195 Some(DecoderInstruction::Ack { stream_id }) => self.ack(stream_id), in decode_ins()
197 Some(DecoderInstruction::StreamCancel { stream_id }) => { in decode_ins()
198 assert_eq!(stream_id, self.stream_id); in decode_ins()
|
| H A D | mod.rs | 224 Ack { stream_id: usize },
225 StreamCancel { stream_id: usize },
|
| H A D | decoder.rs | 306 stream_id: usize, in finish()
314 let ack = Integer::index(0x80, stream_id, 0x7f); in finish()
350 stream_id: usize, in stream_cancel()
353 let ack = Integer::index(0x40, stream_id, 0x3f); in stream_cancel()
|
| /ohos5.0/commonlibrary/rust/ylong_http/ylong_http_client/src/util/h2/ |
| H A D | manager.rs | 368 frame.stream_id(), in recv_settings_frame()
418 for stream_id in streams { in recv_go_away_frame()
421 stream_id, in recv_go_away_frame()
448 .recv_remote_reset(frame.stream_id() as u32) in recv_reset_frame()
452 frame.stream_id() as u32, in recv_reset_frame()
472 frame.stream_id() as u32, in recv_header_frame()
487 let id = frame.stream_id() as u32; in recv_data_frame()
502 frame.stream_id() as u32, in recv_data_frame()
517 let id = frame.stream_id(); in recv_window_frame()
745 for stream_id in ids { in exit_with_error()
[all …]
|
| /ohos5.0/commonlibrary/rust/ylong_http/ylong_http_client/src/util/ |
| H A D | dispatcher.rs | 469 stream_id: u32, in send_message_to_stream()
472 if let Some(sender) = self.senders.get(&stream_id) { in send_message_to_stream()
484 self.senders.remove(&stream_id); in send_message_to_stream()
485 Poll::Ready(Err(H2Error::StreamError(stream_id, ErrorCode::NoError))) in send_message_to_stream()
488 self.curr_message.insert(stream_id, tx); in send_message_to_stream()
493 Poll::Ready(Err(H2Error::StreamError(stream_id, ErrorCode::NoError))) in send_message_to_stream()
|
| /ohos5.0/commonlibrary/rust/ylong_http/ylong_http/src/h3/qpack/format/ |
| H A D | encoder.rs | 797 DecResult::Decoded(DecoderInstruction::Ack { stream_id: index }) in decode()
800 DecResult::Decoded(DecoderInstruction::StreamCancel { stream_id: index }) in decode()
|
| /ohos5.0/commonlibrary/rust/ylong_http/ylong_http_client/src/async_impl/conn/ |
| H A D | http2.rs | 420 assert_eq!(frame.stream_id(), 1); in ut_http2_build_headers_frame()
|