| /commonlibrary/rust/ylong_runtime/ylong_runtime/src/builder/ |
| H A D | common_builder.rs | 102 self.common.worker_name = Some(name); in worker_name()
108 self.common.is_affinity = is_affinity; in is_affinity()
114 self.common.schedule_algo = schedule_algo; in schedule_algo()
123 self.common.after_start = Some(Arc::new(f)); in after_start()
132 self.common.before_stop = Some(Arc::new(f)); in before_stop()
141 self.common.blocking_permanent_thread_num = blocking_permanent_thread_num; in blocking_permanent_thread_num()
151 self.common.max_blocking_pool_size = Some(1); in max_blocking_pool_size()
153 self.common.max_blocking_pool_size = Some(64); in max_blocking_pool_size()
155 self.common.max_blocking_pool_size = Some(max_blocking_pool_size); in max_blocking_pool_size()
163 self.common in keep_alive_time()
[all...] |
| H A D | multi_thread_builder.rs | 37 pub(crate) common: CommonBuilder,
51 common: CommonBuilder::new(),
76 for (qos, stack_size) in self.common.stack_size_by_qos.iter() { in build_global()
110 self.common.worker_name = Some(name); in worker_name()
213 self.common.stack_size_by_qos.insert(qos, stack_size); in stack_size_by_qos()
354 .common in ut_set_stack_size()
363 .common in ut_set_stack_size()
371 let num = builder.common.stack_size_by_qos.get(&Default).unwrap(); in ut_set_stack_size()
377 .common in ut_set_stack_size()
|
| H A D | current_thread_builder.rs | 23 pub(crate) common: CommonBuilder,
29 common: CommonBuilder::new(),
|
| /commonlibrary/rust/ylong_runtime/ylong_runtime/src/executor/ |
| H A D | blocking_pool.rs | 425 let blocking_pool = BlockPoolSpawner::new(&thread_pool_builder.common); in ut_blocking_pool_new()
428 thread_pool_builder.common.stack_size in ut_blocking_pool_new()
436 thread_pool_builder.common.keep_alive_time.unwrap() in ut_blocking_pool_new()
440 thread_pool_builder.common.blocking_permanent_thread_num in ut_blocking_pool_new()
457 let mut blocking_pool = BlockPoolSpawner::new(&thread_pool_builder.common); in ut_blocking_pool_shutdown()
462 let mut blocking_pool = BlockPoolSpawner::new(&thread_pool_builder.common); in ut_blocking_pool_shutdown()
471 let mut blocking_pool = BlockPoolSpawner::new(&thread_pool_builder.common); in ut_blocking_pool_shutdown()
493 let blocking_pool = BlockPoolSpawner::new(&thread_pool_builder.common); in ut_blocking_pool_spawner_create_permanent_threads()
499 let common = RuntimeBuilder::new_multi_thread().blocking_permanent_thread_num(4); in ut_blocking_pool_spawner_create_permanent_threads()
500 let blocking_pool = BlockPoolSpawner::new(&common in ut_blocking_pool_spawner_create_permanent_threads()
[all...] |
| H A D | async_pool.rs | 420 is_affinity: builder.common.is_affinity,
422 after_start: builder.common.after_start.clone(),
423 before_stop: builder.common.before_stop.clone(),
424 worker_name: builder.common.worker_name.clone(),
425 stack_size: builder.common.stack_size,
968 thread_pool_builder.common.worker_name in ut_async_pool_spawner_new()
972 thread_pool_builder.common.stack_size in ut_async_pool_spawner_new()
|
| H A D | mod.rs | 142 match initialize_blocking_spawner(&global_builder.as_ref().unwrap_unchecked().common) {
|
| /commonlibrary/rust/ylong_http/ylong_http/src/body/mime/ |
| H A D | mod.rs | 19 mod common; modules
25 pub(crate) use common::{
28 pub use common::{MimeMulti, MimeMultiBuilder, MimePart, MimePartBuilder, TokenStatus, XPart};
|
| /commonlibrary/rust/ylong_runtime/ylong_signal/src/ |
| H A D | lib.rs | 19 mod common; modules
20 pub use common::SIGNAL_BLOCK_LIST;
76 common::Signal::register_action(sig_num, move |_| handler()) in register_signal_action()
98 common::Signal::deregister_action(sig_num) in deregister_signal_action()
113 common::Signal::deregister_hook(sig_num) in deregister_signal_hook()
|
| H A D | sig_map.rs | 20 use crate::common::{SigAction, Signal};
|
| H A D | windows.rs | 20 use crate::common::{siginfo_t, SigAction, Signal};
|
| H A D | unix.rs | 20 use crate::common::{SigAction, Signal};
|
| /commonlibrary/rust/ylong_http/ylong_http_client/tests/ |
| H A D | sdv_sync_http.rs | 17 mod common; modules
23 use crate::common::init_test_work_runtime;
|
| H A D | sdv_sync_https_c_ssl.rs | 25 use crate::common::init_test_work_runtime;
28 mod common; modules
|
| H A D | sdv_async_http.rs | 17 mod common; modules
19 use crate::common::init_test_work_runtime;
|
| H A D | sdv_async_https_c_ssl.rs | 22 mod common; modules
26 use crate::common::init_test_work_runtime;
|
| H A D | sdv_async_https_pinning.rs | 22 mod common; modules
28 use crate::common::init_test_work_runtime;
|
| /commonlibrary/rust/ylong_http/ylong_http/src/body/mime/encode/ |
| H A D | multi.rs | 18 use crate::body::mime::common::{data_copy, SizeResult};
|
| H A D | part.rs | 20 use crate::body::mime::common::{data_copy, SizeResult, TokenStatus};
|
| /commonlibrary/rust/ylong_http/ylong_http/src/body/mime/common/ |
| H A D | mix.rs | 20 use crate::body::mime::common::{data_copy, SizeResult, TokenStatus};
220 use crate::body::mime::common::mix::MixFrom;
|
| H A D | headers.rs | 17 use crate::body::mime::common::{
318 use crate::body::mime::common::headers::DecodeHeaders;
428 /// 3. The headers is common.
|
| H A D | mod.rs | 218 use crate::body::mime::common::get_content_type_boundary;
229 // common in ut_get_content_type_boundary()
|
| /commonlibrary/rust/ylong_http/ylong_http/src/body/mime/decode/ |
| H A D | part.rs | 16 use crate::body::mime::common::{get_crlf_contain, trim_back_lwsp_if_end_with_lf, trim_front_lwsp};
189 // common in ut_mime_part_decoder_new_by_crlf()
240 // common in ut_mime_part_decoder_new_by_lf()
|
| H A D | multi.rs | 16 use crate::body::mime::common::{
|