| /commonlibrary/rust/ylong_runtime/ylong_runtime/src/executor/ |
| 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 { implementation
249 impl Inner { impl
|
| D | parker.rs | 27 struct Inner { struct
42 inner: Arc::new(Inner { in new() argument
73 impl Inner { implementation
|
| 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>,
127 before_stop: Option<CallbackHook>,
130 max_thread_num: u8,
133 keep_alive_time: Duration,
[all …]
|
| 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()
|
| /commonlibrary/rust/ylong_runtime/ylong_runtime/src/net/ |
| 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 { implementation
405 impl Inner { implementation
448 impl Drop for Inner { implementation
|
| /commonlibrary/rust/ylong_runtime/ylong_runtime/src/sync/ |
| D | wake_list.rs | 30 pub(crate) struct Inner { struct
44 inner: UnsafeCell<Inner>, argument
137 impl Inner { impl
207 fn deref(&self) -> &Inner { in deref()
213 fn deref_mut(&mut self) -> &mut Inner { in deref_mut()
|
| /commonlibrary/rust/ylong_runtime/ylong_runtime/src/task/ |
| D | raw.rs | 181 pub(crate) struct Inner<T: Future, S: Schedule> { struct
193 impl<T, S> Inner<T, S> argument
|
| /commonlibrary/rust/ylong_http/ylong_http/src/ |
| D | version.rs | 86 enum Inner { enum
|
| /commonlibrary/rust/ylong_http/ylong_http_client/src/util/config/tls/alpn/ |
| D | mod.rs | 24 enum Inner { enum
|
| /commonlibrary/rust/ylong_http/ylong_http/src/request/ |
| D | method.rs | 158 enum Inner { enum
|
| /commonlibrary/rust/ylong_http/ylong_http_client/src/util/ |
| D | dispatcher.rs | 153 pub(crate) struct Inner<S> { struct
154 pub(crate) io: UnsafeCell<S>,
158 pub(crate) occupied: AtomicBool,
160 pub(crate) shutdown: AtomicBool,
163 unsafe impl<S> Sync for Inner<S> {} implementation
|