Home
last modified time | relevance | path

Searched refs:config (Results 1 - 19 of 19) sorted by relevance

/commonlibrary/rust/ylong_http/ylong_http_client/src/async_impl/uploader/
H A Dbuilder.rs66 config: UploadConfig::default(), in reader()
86 config: UploadConfig { total_bytes }, in multipart()
101 config: UploadConfig,
139 config: self.state.config, in operator()
163 config: self.state.config, in console()
173 config: UploadConfig,
193 self.state.config.total_bytes = total_bytes; in total_bytes()
213 config in build()
[all...]
H A Dmod.rs91 config: UploadConfig,
147 this.config.total_bytes, in poll_read()
/commonlibrary/rust/ylong_http/ylong_http_client/src/async_impl/quic/
H A Dmod.rs47 let mut config = quiche::Config::new(quiche::PROTOCOL_VERSION)?; in quic_config() variables
48 config.verify_peer(true); in quic_config()
49 config.set_application_protos(quiche::h3::APPLICATION_PROTOCOL)?; in quic_config()
50 config.set_max_idle_timeout(MAX_IDLE_TIME); in quic_config()
51 config.set_max_recv_udp_payload_size(MAX_DATAGRAM_SIZE); in quic_config()
52 config.set_max_send_udp_payload_size(MAX_DATAGRAM_SIZE); in quic_config()
53 config.set_initial_max_data(MAX_TOTAL_DATA); in quic_config()
54 config.set_initial_max_stream_data_bidi_local(MAX_STREAM_DATA); in quic_config()
55 config.set_initial_max_stream_data_bidi_remote(MAX_STREAM_DATA); in quic_config()
56 config in quic_config()
[all...]
/commonlibrary/rust/ylong_http/ylong_http_client/src/async_impl/downloader/
H A Dbuilder.rs127 config: DownloadConfig::default(), in operator()
149 config: DownloadConfig::default(), in console()
159 config: DownloadConfig,
181 self.state.config.timeout = timeout; in timeout()
203 self.state.config.speed_limit = speed_limit; in speed_limit()
222 config: self.state.config, in build()
H A Dmod.rs111 config: DownloadConfig,
207 if let Some(timeout) = self.config.timeout.inner() { in check_timeout()
/commonlibrary/rust/ylong_http/ylong_http_client/src/async_impl/
H A Dpool.rs34 use crate::util::config::H2Config;
36 use crate::util::config::H3Config;
37 use crate::util::config::{HttpConfig, HttpVersion};
48 config: HttpConfig,
52 pub(crate) fn new(config: HttpConfig, connector: C) -> Self {
58 config,
74 self.config.clone(),
130 config: HttpConfig,
138 match config.version {
140 HttpVersion::Http3 => self.conn_h3(connector, url, config
[all...]
H A Dclient.rs29 use crate::util::config::FchownConfig;
30 use crate::util::config::{
74 config: ClientConfig,
139 config: ClientConfig::default(), in with_connector()
162 let mut retries = self.config.retry.times().unwrap_or(0);
196 if let Some(dur) = self.config.connect_timeout.inner() {
216 if let Some(timeout) = self.config.request_timeout.inner() {
232 .config
513 let config = ConnectorConfig { in build()
522 let connector = HttpConnector::new(config, sel in build()
[all...]
/commonlibrary/rust/ylong_http/ylong_http_client/src/util/config/
H A Dconnector.rs37 use crate::util::config::ConnectorConfig;
46 let config = ConnectorConfig::default(); in ut_connector_config_default()
48 assert!(config.proxies.match_proxy(&uri).is_none()) in ut_connector_config_default()
/commonlibrary/rust/ylong_http/ylong_http_client/src/sync_impl/
H A Dclient.rs20 use crate::util::config::{
50 config: ClientConfig,
91 config: ClientConfig::new(), in with_connector()
118 let mut retries = self.config.retry.times().unwrap_or(0); in retry_send_request()
145 .config in redirect_request()
312 let config = ConnectorConfig { in build()
318 let connector = HttpConnector::new(config); in build()
322 config: self.client, in build()
H A Dconnector.rs18 use crate::util::config::ConnectorConfig;
36 config: ConnectorConfig,
41 pub(crate) fn new(config: ConnectorConfig) -> HttpConnector {
42 HttpConnector { config }
66 let addr = if let Some(proxy) = self.config.proxies.match_proxy(uri) { in connect()
98 if let Some(proxy) = self.config.proxies.match_proxy(uri) { in connect()
131 .config in connect()
/commonlibrary/rust/ylong_http/ylong_http_client/src/async_impl/connector/
H A Dmod.rs30 use crate::util::config::{ConnectorConfig, HttpVersion};
54 config: ConnectorConfig,
60 pub(crate) fn new(config: ConnectorConfig, resolver: Arc<dyn Resolver>) -> Self {
61 Self { config, resolver }
71 config: Default::default(),
80 config: Default::default(), in default()
155 use crate::util::config::HttpVersion;
167 if let Some(proxy) = self.config.proxies.match_proxy(uri) { in connect()
173 let timeout = self.config.timeout.clone(); in connect()
214 use crate::config
[all...]
/commonlibrary/rust/ylong_runtime/ylong_ffrt/src/
H A Dlib.rs16 mod config; modules
20 pub use config::*;
/commonlibrary/rust/ylong_http/ylong_http_client/src/async_impl/dns/
H A Dhappy_eyeballs.rs133 pub(crate) fn new(socket_addr: Vec<SocketAddr>, config: EyeBallConfig) -> Self {
143 config
150 let delay = if let Some(delay) = config.delay {
158 config
166 config
317 let config = EyeBallConfig::new(None, Some(delay_time)); in ut_happy_eyeballs_connect()
318 let happy_eyeballs = HappyEyeballs::new(addrs, config); in ut_happy_eyeballs_connect()
/commonlibrary/rust/ylong_http/ylong_http_client/src/util/
H A Ddispatcher.rs200 use crate::util::config::H2Config;
297 pub(crate) fn http2(config: H2Config, io: S) -> Self {
298 Self::Http2(Http2Dispatcher::new(config, io))
306 pub(crate) fn new(config: H2Config, io: S) -> Self {
307 let settings = create_initial_settings(&config);
310 flow.setup_recv_window(config.conn_window_size());
312 let streams = Streams::new(config.stream_window_size(), DEFAULT_WINDOW_SIZE, flow);
324 config.allowed_cache_frame_size(),
325 config.use_huffman_coding(),
334 allowed_cache: config
[all...]
H A Dalt_svc.rs23 use crate::util::config::HttpVersion;
/commonlibrary/rust/ylong_http/ylong_http_client/src/util/h3/
H A Dstream_manager.rs31 use crate::util::config::H3Config;
299 pub(crate) fn init(&mut self, config: H3Config) -> Result<(), DispatchErrorKind> {
301 .local_allowed_max_field_section_size(config.max_field_section_size() as usize);
302 self.send_settings(config)?;
345 pub(crate) fn send_settings(&mut self, config: H3Config) -> Result<(), DispatchErrorKind> {
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());
/commonlibrary/rust/ylong_http/ylong_http_client/src/util/c_openssl/
H A Dadapter.rs25 use crate::util::config::tls::DefaultCertVerifier;
826 let config = TlsConfigBuilder::new() in ut_tls_ssl()
829 let _ssl = config in ut_tls_ssl()
851 let config = TlsConfigBuilder::new() in ut_tls_ssl_verify_hostname()
858 let ssl = config in ut_tls_ssl_verify_hostname()
/commonlibrary/rust/ylong_http/ylong_http_client/src/util/c_openssl/ssl/
H A Dctx.rs41 use crate::util::config::tls::DefaultCertVerifier;
/commonlibrary/ets_utils/js_sys_module/test/
H A Dtest_process.cpp667 napi_value config = nullptr; in HWTEST_F() local
668 napi_create_int32(env, _SC_NPROCESSORS_CONF, &config); in HWTEST_F()
669 napi_value result = process.GetSystemConfig(env, config); in HWTEST_F()

Completed in 10 milliseconds