| /commonlibrary/rust/ylong_http/ylong_http/src/h2/ |
| H A D | frame.rs | 102 /// Enum representing the different settings that can be included in a SETTINGS
169 settings: Vec<Setting>,
200 settings: Vec<Setting>,
360 /// Creates a new Settings instance containing the provided settings.
361 pub fn new(settings: Vec<Setting>) -> Self { in new()
362 Settings { settings } in new()
365 /// Returns a slice of the settings.
367 &self.settings in get_settings()
374 .settings
380 self.settings
[all...] |
| H A D | encoder.rs | 337 if let Payload::Settings(settings) = frame.payload_mut() { in update_setting()
338 settings.update_setting(setting); in update_setting()
882 if let Payload::Settings(settings) = frame.payload() { in encode_settings_frame()
893 settings.get_settings().len() * 6, in encode_settings_frame()
948 if let Payload::Settings(settings) = frame.payload() { in encode_settings_payload()
949 let settings_len = settings.get_settings().len() * 6; in encode_settings_payload()
953 self.iterate_settings_payload(settings, buf, bytes_to_write)?; in encode_settings_payload()
970 settings: &Settings, in iterate_settings_payload()
979 if let Some(setting) = settings.get_settings().get(setting_index) { in iterate_settings_payload()
1427 let settings in ut_settings_frame_encoding()
[all...] |
| H A D | decoder.rs | 572 let settings = Frame::new( in decode_settings_payload()
578 return Ok(FrameKind::Complete(settings)); in decode_settings_payload()
580 let mut settings = vec![]; in decode_settings_payload() variables
583 settings.push(setting); in decode_settings_payload()
589 frame::Payload::Settings(Settings::new(settings)), in decode_settings_payload()
1619 /// Tests the case of a settings payload.
1634 // Mock a settings payload: [0x00, 0x01, 0x00, 0x00, 0x00, 0x80, 0x00, 0x02, in ut_decode_settings_payload()
1643 Payload::Settings(settings) => { in ut_decode_settings_payload()
1644 let settings_vec = settings.get_settings(); in ut_decode_settings_payload()
1656 // Test the case where the settings fram in ut_decode_settings_payload()
[all...] |
| /commonlibrary/rust/ylong_http/ylong_http_client/src/util/h2/buffer/ |
| H A D | mod.rs | 23 mod settings; modules
26 pub(crate) use settings::FlowControl;
|
| /commonlibrary/rust/ylong_http/ylong_http_client/src/util/h3/ |
| H A D | stream_manager.rs | 348 let mut settings = Settings::default(); variables
349 settings.set_max_field_section_size(config.max_field_section_size());
350 settings.set_qpack_max_table_capacity(config.qpack_max_table_capacity());
351 settings.set_qpack_block_stream(config.qpack_blocked_streams());
354 let settings = Frame::new(SETTINGS_FRAME_TYPE, Payload::Settings(settings));
355 self.encoder.set_frame(control_stream_id, settings)?;
587 Payload::Settings(settings) => { in recv_control_stream()
588 self.recv_setting_frame(settings)?; in recv_control_stream()
624 fn recv_setting_frame(&mut self, settings
[all...] |
| /commonlibrary/rust/ylong_http/ylong_http_client/src/util/h2/ |
| H A D | manager.rs | 43 settings: Arc<Mutex<SettingsSync>>,
126 settings: Arc<Mutex<SettingsSync>>,
135 settings,
324 let settings = if let Payload::Settings(settings) = frame.payload() { in recv_settings_frame()
325 settings in recv_settings_frame()
332 let mut connection = self.settings.lock().unwrap(); in recv_settings_frame()
334 if let SettingsState::Acknowledging(ref acknowledged) = connection.settings { in recv_settings_frame()
343 connection.settings = SettingsState::Synced; in recv_settings_frame()
347 for setting in settings in recv_settings_frame()
[all...] |
| H A D | output.rs | 42 settings: Arc<Mutex<SettingsSync>>,
63 settings: Arc<Mutex<SettingsSync>>,
69 settings,
241 let connection = self.settings.lock().unwrap(); in update_decoder_settings()
242 match &connection.settings { in update_decoder_settings()
243 SettingsState::Acknowledging(settings) => { in update_decoder_settings()
244 for setting in settings.get_settings() { in update_decoder_settings()
|
| H A D | input.rs | 28 settings: Arc<Mutex<SettingsSync>>,
89 let mut sync = sender.settings.lock().unwrap();
90 sync.settings = SettingsState::Acknowledging(setting.clone());
120 settings: Arc<Mutex<SettingsSync>>,
126 settings,
206 let settings = if let Payload::Settings(settings) = frame.payload() { in update_settings()
207 settings in update_settings()
216 for setting in settings.get_settings() { in update_settings()
226 SettingState::Local(settings in update_settings()
[all...] |
| /commonlibrary/rust/ylong_http/ylong_http_client/src/util/config/ |
| H A D | mod.rs | 17 mod settings; modules
26 pub use settings::{Proxy, ProxyBuilder, Redirect, Retry, SpeedLimit, Timeout};
|
| /commonlibrary/rust/ylong_http/ylong_http/src/h3/ |
| H A D | encoder.rs | 344 if let Payload::Settings(settings) = frame.payload() { in encode_settings_payload()
348 if let Some(v) = settings.max_fied_section_size() { in encode_settings_payload()
355 if let Some(v) = settings.connect_protocol_enabled() { in encode_settings_payload()
362 if let Some(v) = settings.qpack_max_table_capacity() { in encode_settings_payload()
369 if let Some(v) = settings.qpack_block_stream() { in encode_settings_payload()
376 if let Some(v) = settings.h3_datagram() { in encode_settings_payload()
381 if let Some(v) = settings.additional() { in encode_settings_payload()
557 if let Payload::Settings(settings) = frame.payload() { in encode_settings_len()
558 if let Some(v) = settings.max_fied_section_size() { in encode_settings_len()
562 if let Some(v) = settings in encode_settings_len()
[all...] |
| H A D | decoder.rs | 671 let mut settings = Settings::default(); in decode_settings_payload() variables
687 settings.set_qpack_max_table_capacity(value); in decode_settings_payload()
690 settings.set_connect_protocol_enabled(value) in decode_settings_payload()
692 frame::SETTING_H3_DATAGRAM => settings.set_h3_datagram(value), in decode_settings_payload()
693 frame::SETTING_MAX_FIELD_SECTION_SIZE => settings.set_max_field_section_size(value), in decode_settings_payload()
694 frame::SETTING_QPACK_BLOCKED_STREAMS => settings.set_qpack_block_stream(value), in decode_settings_payload()
701 settings.set_additional(addition); in decode_settings_payload()
703 let frame = Frame::new(SETTINGS_FRAME_TYPE, Payload::Settings(settings)); in decode_settings_payload()
|
| /commonlibrary/rust/ylong_http/ylong_http_client/src/util/c_openssl/ffi/ |
| H A D | mod.rs | 31 pub(crate) fn OPENSSL_init_ssl(opts: u64, settings: *const OPENSSL_INIT_SETTINGS) -> c_int;
|
| /commonlibrary/rust/ylong_http/ylong_http_client/src/util/ |
| H A D | dispatcher.rs | 278 pub(crate) settings: SettingsState,
307 let settings = create_initial_settings(&config);
322 if input_tx.send(settings).is_ok() {
632 let settings = SettingsBuilder::new()
640 Frame::new(0, FrameFlags::new(0), Payload::Settings(settings))
|