| /ohos5.0/commonlibrary/rust/ylong_runtime/ylong_runtime/src/executor/ |
| H A D | worker.rs | 162 fn get_task(&self, inner: &mut Inner, worker_ctx: &WorkerContext) -> Option<Task> { in get_task()
173 fn check_cancel(&self, inner: &mut Inner) { in check_cancel()
177 fn has_work(&self, inner: &mut Inner, worker_ctx: &WorkerContext) -> bool { in has_work()
181 fn park_timeout(&self, inner: &mut Inner, worker_ctx: &WorkerContext) { in park_timeout()
212 pub(crate) unsafe fn get_inner_ptr(&self) -> &Inner { in get_inner_ptr()
224 pub(crate) struct Inner { struct
235 impl Inner { argument
249 impl Inner { implementation
|
| H A D | parker.rs | 27 struct Inner { struct
42 inner: Arc::new(Inner { in new() argument
73 impl Inner { implementation
|
| H A D | blocking_pool.rs | 107 struct Inner { struct
109 shared: Mutex<Shared>,
112 condvar: Condvar,
115 shutdown_shared: Mutex<bool>,
118 shutdown_condvar: Condvar,
121 stack_size: Option<usize>,
124 after_start: Option<CallbackHook>,
130 max_thread_num: u8,
133 keep_alive_time: Duration,
136 max_permanent_thread_num: u8,
[all …]
|
| H A D | async_pool.rs | 141 pub(crate) fn turn_to_sleep(&self, worker_inner: &mut worker::Inner, worker_index: usize) { in turn_to_sleep()
293 worker_inner: &mut worker::Inner, in dequeue()
367 pub(crate) struct Inner { struct
392 fn async_thread_proc(inner: Arc<Inner>, worker: Arc<Worker>, handle: Arc<Handle>) { in async_thread_proc()
|
| /ohos5.0/commonlibrary/rust/ylong_runtime/ylong_runtime/src/net/ |
| H A D | driver.rs | 102 fn new(inner: Arc<Inner>, waker: ylong_io::Waker) -> Self { in new()
135 pub(crate) struct Inner { struct
151 metrics: InnerMetrics, argument
154 /// Metrics of Inner argument
350 impl Inner { impl
368 impl Inner { impl
405 impl Inner { implementation
448 impl Drop for Inner { implementation
|
| /ohos5.0/commonlibrary/rust/ylong_runtime/ylong_runtime/src/sync/ |
| H A D | wake_list.rs | 27 pub(crate) struct Inner { struct
34 inner: UnsafeCell<Inner>, argument
104 impl Inner { implementation
155 fn deref(&self) -> &Inner { in deref()
161 fn deref_mut(&mut self) -> &mut Inner { in deref_mut()
|
| /ohos5.0/base/request/request/services/src/manage/scheduler/queue/ |
| H A D | keeper.rs | 31 struct Inner { struct
43 inner: Arc::new(Mutex::new(Inner { in new() argument
|
| /ohos5.0/base/msdp/device_status/rust/subsystem/dsoftbus/sys/src/ |
| H A D | dsoftbus.rs | 135 struct Inner { struct
154 impl Inner { argument
|
| /ohos5.0/base/useriam/user_auth_framework/services/core/src/ |
| H A D | schedule_node_impl.h | 39 class Inner; variable
|
| /ohos5.0/commonlibrary/rust/ylong_http/ylong_http/src/ |
| H A D | version.rs | 86 enum Inner { enum
|
| /ohos5.0/commonlibrary/rust/ylong_http/ylong_http_client/src/util/config/tls/alpn/ |
| H A D | mod.rs | 24 enum Inner { enum
|
| /ohos5.0/commonlibrary/rust/ylong_runtime/ylong_runtime/src/task/ |
| H A D | raw.rs | 181 pub(crate) struct Inner<T: Future, S: Schedule> { struct
193 impl<T, S> Inner<T, S> impl
|
| /ohos5.0/commonlibrary/rust/ylong_http/ylong_http/src/request/ |
| H A D | method.rs | 158 enum Inner { enum
|
| /ohos5.0/base/useriam/face_auth/services_ex/src/ |
| H A D | finite_state_machine_impl.cpp | 137 FiniteStateMachineImpl::Inner::Inner(std::shared_ptr<FiniteStateMachineImpl> &machine) : machine_(m… in Inner() function in OHOS::UserIam::FaceAuth::FiniteStateMachineImpl::Inner
|
| /ohos5.0/base/useriam/user_auth_framework/services/base/src/ |
| H A D | finite_state_machine_impl.cpp | 135 FiniteStateMachineImpl::Inner::Inner(std::shared_ptr<FiniteStateMachineImpl> &machine) : machine_(m… in Inner() function in OHOS::UserIam::UserAuth::FiniteStateMachineImpl::Inner
|
| /ohos5.0/commonlibrary/rust/ylong_http/ylong_http_client/src/util/ |
| H A D | dispatcher.rs | 82 pub(crate) struct Inner<S> { struct
92 unsafe impl<S> Sync for Inner<S> {} implementation
|