Home
last modified time | relevance | path

Searched refs:streams (Results 1 - 8 of 8) sorted by relevance

/commonlibrary/rust/ylong_http/ylong_http_client/src/util/h2/
H A Dmanager.rs30 use crate::util::h2::streams::{DataReadState, FrameRecvState, StreamEndState};
155 self.controller.streams.window_update_conn(&self.input_tx)?; in manage_pending_state()
157 .streams in manage_pending_state()
180 let id = match self.controller.streams.generate_id() { in poll_recv_request()
188 if self.controller.streams.reach_max_concurrency() in poll_recv_request()
189 || !self.controller.streams.is_pending_concurrency_empty() in poll_recv_request()
191 self.controller.streams.push_pending_concurrency(id) in poll_recv_request()
193 self.controller.streams.increase_current_concurrency(); in poll_recv_request()
194 self.controller.streams.push_back_pending_send(id) in poll_recv_request()
198 .streams in poll_recv_request()
[all...]
H A Dmod.rs20 //! -[`Streams`] is used to manage the state of individual streams.
22 //! receiving of multiple streams.
28 mod streams; modules
39 pub(crate) use streams::{H2StreamState, RequestWrapper, StreamEndState, Streams};
/commonlibrary/rust/ylong_http/ylong_http_client/src/util/h3/
H A Dstream_manager.rs33 use crate::util::h3::streams::{DataReadState, QUICStreamType, Streams};
39 pub(crate) streams: Streams,
65 streams: Streams::new(),
124 self.streams in send_inst_to_peer()
140 self.streams.send_error(cx, id, error) in transmit_error()
144 self.streams.try_consume_pending_concurrency(); in poll_input_request()
145 let len = self.streams.pending_stream_len();
146 // Some streams may be blocked due to the server not reading the message. Avoid
147 // reading these streams twice in one loop
149 if let Some(id) = self.streams
[all...]
/commonlibrary/rust/ylong_http/ylong_http/src/h3/
H A Ddecoder.rs48 streams: HashMap<u64, DecodedH3Stream>,
103 streams: HashMap::new(), in new()
117 self.streams.remove(&stream_id); in cancel_stream()
130 self.streams.remove(&id); in finish_stream()
147 let mut stream = if let Some(stream) = self.streams.remove(&id) { in decode()
158 self.streams.insert(id, stream); in decode()
164 self.streams.insert(id, stream); in decode()
173 self.streams.insert(id, stream); in decode()
180 self.streams.insert(id, stream); in decode()
187 self.streams in decode()
[all...]
H A Dencoder.rs91 streams: HashMap<u64, EncodedH3Stream>,
118 .streams in set_frame()
190 let stream = self.streams.get_mut(&stream_id).ok_or(InternalError)?; in encode()
271 self.streams.remove(&id); in finish_stream()
/commonlibrary/rust/ylong_http/ylong_http_client/src/util/
H A Ddispatcher.rs264 pub(crate) streams: Streams,
312 let streams = Streams::new(config.stream_window_size(), DEFAULT_WINDOW_SIZE, flow);
314 let controller = StreamController::new(streams, shutdown_flag.clone());
446 pub(crate) fn new(streams: Streams, shutdown: Arc<AtomicBool>) -> Self {
451 streams,
467 if self.streams.max_send_id < last_stream_id {
470 self.streams.max_send_id = last_stream_id;
471 Ok(self.streams.get_go_away_streams(last_stream_id))
520 if let Some(state) = self.streams.stream_state(key) {
522 if let StreamEndState::OK = self.streams
[all...]
/commonlibrary/rust/ylong_http/ylong_http/src/h3/qpack/
H A Ddecoder.rs74 streams: HashMap<u64, ReprMessage>,
86 streams: HashMap::new(),
98 self.streams.remove(&id);
189 let mut message = match self.streams.remove(&stream_id) {
202 self.streams.insert(stream_id, message);
323 match self.streams.remove(&stream_id) { in finish()
355 self.streams.remove(&stream_id); in stream_cancel()
/commonlibrary/rust/ylong_http/ylong_http/src/h2/
H A Ddecoder.rs382 // Frames of other types or streams are not allowed between Headers Frame and in decode_frame_payload()
1302 /// Test the function of inserting HEADERS of other streams between HEADERS
1324 /// Test the function of inserting CONTINUATION of other streams between
1777 Some(Setting::MaxConcurrentStreams(streams)) => { in ut_get_setting()
1778 assert_eq!(streams, 100); in ut_get_setting()

Completed in 7 milliseconds