Searched defs:streams (Results 1 – 9 of 9) sorted by relevance
| /commonlibrary/rust/ylong_http/ylong_http_client/src/util/h2/ |
| D | streams.rs | 834 let mut streams = Streams::new(100, 200, FlowControl::new(300, 400)); in ut_streams_apply_max_concurrent_streams() localVariable
852 let mut streams = Streams::new(100, 100, FlowControl::new(100, 100)); in ut_streams_apply_send_initial_window_size() localVariable
894 let mut streams = Streams::new(100, 100, FlowControl::new(100, 100)); in ut_streams_get_unset_streams() localVariable
937 let mut streams = Streams::new(1000, 1000, FlowControl::new(1000, 1000)); in ut_streams_get_all_unclosed_streams() localVariable
957 let mut streams = Streams::new(1000, 1000, FlowControl::new(1000, 1000)); in ut_streams_clear_streams_states() localVariable
973 let mut streams = Streams::new(1000, 1000, FlowControl::new(1000, 1000)); in ut_streams_send_local_reset() localVariable
1004 let mut streams = Streams::new(100, 100, FlowControl::new(100, 100)); in ut_streams_send_headers_frame() localVariable
1030 let mut streams = Streams::new(100, 100, FlowControl::new(100, 100)); in ut_streams_send_data_frame() localVariable
1059 let mut streams = Streams::new(100, 100, FlowControl::new(100, 100)); in ut_streams_recv_remote_reset() localVariable
1086 let mut streams = Streams::new(100, 100, FlowControl::new(100, 100)); in ut_streams_recv_headers() localVariable
[all …]
|
| D | mod.rs | 28 mod streams; module
|
| D | manager.rs | 416 let streams = self.controller.get_unsent_streams(last_stream_id)?; in recv_go_away_frame() localVariable
|
| /commonlibrary/rust/ylong_http/ylong_http_client/src/util/h3/ |
| D | mod.rs | 18 pub(crate) mod streams; module
|
| D | stream_manager.rs | 39 pub(crate) streams: Streams, field
|
| /commonlibrary/rust/ylong_http/ylong_http/src/h3/qpack/ |
| D | decoder.rs | 74 streams: HashMap<u64, ReprMessage>, field
|
| /commonlibrary/rust/ylong_http/ylong_http/src/h3/ |
| D | encoder.rs | 91 streams: HashMap<u64, EncodedH3Stream>, field
|
| D | decoder.rs | 48 streams: HashMap<u64, DecodedH3Stream>, field
|
| /commonlibrary/rust/ylong_http/ylong_http_client/src/util/ |
| D | dispatcher.rs | 409 pub(crate) streams: Streams, field
455 let streams = Streams::new(config.stream_window_size(), DEFAULT_WINDOW_SIZE, flow); in new() localVariable
|