| /commonlibrary/rust/ylong_http/ylong_http/src/h3/qpack/ |
| H A D | encoder.rs | 123 fn ack(&mut self, stream_id: usize) -> Result<(), QpackError> { in ack()
125 if let Some(unacked) = self.tracked_stream.get_mut(&(stream_id as u64)) { in ack()
135 self.tracked_stream.remove(&(stream_id as u64)); in ack()
151 fn cancel_stream(&mut self, stream_id: u64) { in cancel_stream()
153 if let Some(mut fields) = self.tracked_stream.remove(&stream_id) { in cancel_stream()
190 Some(DecoderInstruction::Ack { stream_id }) => self.ack(stream_id)?, in decode_ins()
191 Some(DecoderInstruction::StreamCancel { stream_id }) => { in decode_ins()
192 self.cancel_stream(stream_id as u64); in decode_ins()
202 pub fn encode(&mut self, stream_id
[all...] |
| H A D | decoder.rs | 184 stream_id: u64,
186 if self.blocked.contains_key(&stream_id) {
189 let mut message = match self.streams.remove(&stream_id) {
194 self.decode_buffered_repr(vec.as_slice(), &mut message, stream_id)?;
200 self.decode_buffered_repr(buf, &mut message, stream_id)
202 self.streams.insert(stream_id, message);
211 stream_id: u64, in decode_buffered_repr()
261 self.blocked.insert(stream_id, message.require_insert_count); in decode_buffered_repr()
320 stream_id: u64, in finish()
323 match self.streams.remove(&stream_id) { in finish()
[all...] |
| H A D | mod.rs | 225 Ack { stream_id: usize },
226 StreamCancel { stream_id: usize },
|
| /commonlibrary/rust/ylong_http/ylong_http/src/h2/ |
| H A D | decoder.rs | 199 stream_id: StreamId,
208 stream_id: StreamId,
242 self.stream_id = 0; in reset()
274 stream_id: 0, in new()
285 self.stream_id = 0; in reset()
385 && (self.header.stream_id != self.continuations.stream_id in decode_frame_payload()
422 if !is_connection_frame(self.header.stream_id) { in decode_ping_payload()
438 self.header.stream_id, in decode_ping_payload()
448 if is_connection_frame(self.header.stream_id) { in decode_priority_payload()
[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()
1151 *item = ((stream_id >> (24 - (8 * (buf_index - 5)))) & 0xFF) as u8; in encode_rst_stream_frame()
|
| H A D | frame.rs | 205 pub fn stream_id(&self) -> StreamId { in stream_id() functions
|
| /commonlibrary/rust/ylong_http/ylong_http_client/src/util/h3/ |
| H A D | stream_manager.rs | 377 if let Some(stream_id) = self.streams.peer_control_stream_id() {
378 need_send |= self.try_recv_uni_stream(cx, &mut quic_conn, stream_id)?;
380 if let Some(stream_id) = self.streams.peer_qpack_encode_stream_id() {
381 need_send |= self.try_recv_uni_stream(cx, &mut quic_conn, stream_id)?;
383 if let Some(stream_id) = self.streams.peer_qpack_decode_stream_id() {
384 need_send |= self.try_recv_uni_stream(cx, &mut quic_conn, stream_id)?;
407 stream_id: u64, in try_recv_uni_stream()
409 if quic_conn.stream_finished(stream_id) { in try_recv_uni_stream()
415 match self.read_stream(cx, quic_conn, stream_id) { in try_recv_uni_stream()
417 if quic_conn.stream_finished(stream_id) { in try_recv_uni_stream()
475 let mut stream_id = id; process_recv_data() variables
[all...] |
| /commonlibrary/rust/ylong_http/ylong_http_client/src/util/h2/ |
| H A D | manager.rs | 260 .send_headers_frame(frame.stream_id(), frame.flags().is_end_stream()) in poll_send_frame()
270 .send_data_frame(frame.stream_id(), frame.flags().is_end_stream()) in poll_send_frame()
362 frame.stream_id(), in recv_settings_frame()
412 for stream_id in streams { in recv_go_away_frame()
415 stream_id, in recv_go_away_frame()
439 match self.controller.streams.recv_remote_reset(frame.stream_id()) { in recv_reset_frame()
442 frame.stream_id(), in recv_reset_frame()
458 .recv_headers(frame.stream_id(), frame.flags().is_end_stream()) in recv_header_frame()
462 frame.stream_id(), in recv_header_frame()
477 let id = frame.stream_id();
[all...] |
| /commonlibrary/rust/ylong_http/ylong_http/src/h3/qpack/format/ |
| H A D | encoder.rs | 33 stream_id: u64,
40 pub fn new(stream_id: u64, base: u64, is_huffman: bool, table: &'a mut DynamicTable) -> Self { in new()
42 stream_id, in new()
101 .entry(self.stream_id)
717 DecResult::Decoded(DecoderInstruction::Ack { stream_id: index }) in decode()
720 DecResult::Decoded(DecoderInstruction::StreamCancel { stream_id: index }) in decode()
|
| /commonlibrary/rust/ylong_http/ylong_http/src/h3/ |
| H A D | encoder.rs | 57 stream_id: u64,
116 pub fn set_frame(&mut self, stream_id: u64, frame: Frame) -> Result<(), H3Error> { in set_frame()
119 .entry(stream_id) in set_frame()
120 .or_insert(EncodedH3Stream::new(stream_id)); in set_frame()
181 stream_id: u64, in encode()
190 let stream = self.streams.get_mut(&stream_id).ok_or(InternalError)?; in encode()
331 pub(crate) fn new(stream_id: u64) -> Self {
333 stream_id,
419 let message = qpack_encoder.encode(self.stream_id); in encode_headers_with_qpack()
|
| H A D | decoder.rs | 116 pub fn cancel_stream(&mut self, stream_id: u64, buf: &mut [u8]) -> Result<usize, H3Error> { in cancel_stream()
117 self.streams.remove(&stream_id); in cancel_stream()
119 .stream_cancel(stream_id, buf) in cancel_stream()
|
| /commonlibrary/rust/ylong_http/ylong_http_client/src/async_impl/conn/ |
| H A D | http2.rs | 85 headers_frame.stream_id(), in frame_2_response()
101 headers_frame.stream_id(), in frame_2_response()
110 headers_frame.stream_id(), in frame_2_response()
|