| /commonlibrary/rust/ylong_runtime/ylong_runtime/src/executor/ |
| D | worker.rs | 145 fn pre_shutdown(&self, inner: &mut Inner, worker_ctx: &WorkerContext) { in pre_shutdown()
171 fn get_task(&self, inner: &mut Inner, worker_ctx: &WorkerContext) -> Option<Task> { in get_task()
182 fn check_cancel(&self, inner: &mut Inner) { in check_cancel()
186 fn park_timeout(&self, inner: &mut Inner, worker_ctx: &WorkerContext) { in park_timeout()
211 pub(crate) unsafe fn get_inner_ptr(&self) -> &Inner { in get_inner_ptr()
223 pub(crate) struct Inner { struct
233 impl Inner { argument
246 impl Inner { impl
|
| D | parker.rs | 26 struct Inner { struct
41 inner: Arc::new(Inner { in new() argument
72 impl Inner { impl
|
| 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 | netpoller.rs | 33 struct Inner { struct
40 inner: Arc::new(Inner { in new() argument
|
| D | async_pool.rs | 307 pub(crate) struct Inner { struct
331 fn async_thread_proc(inner: Arc<Inner>, worker: Arc<Worker>, handle: Arc<Handle>) { in async_thread_proc()
|
| /commonlibrary/rust/ylong_runtime/ylong_runtime/src/sync/ |
| D | wake_list.rs | 27 pub(crate) struct Inner { struct
34 inner: UnsafeCell<Inner>, argument
104 impl Inner { impl
155 fn deref(&self) -> &Inner { in deref()
161 fn deref_mut(&mut self) -> &mut Inner { in deref_mut()
|
| /commonlibrary/rust/ylong_runtime/ylong_runtime/src/net/ |
| D | driver.rs | 95 fn new(inner: Arc<Inner>, waker: ylong_io::Waker) -> Self { in new()
128 pub(crate) struct Inner { struct
144 metrics: InnerMetrics, argument
147 /// Metrics of Inner argument
318 impl Inner { implementation
400 impl Drop for Inner { implementation
|
| /commonlibrary/rust/ylong_runtime/ylong_runtime/src/task/ |
| D | raw.rs | 133 pub(crate) struct Inner<T: Future, S: Schedule> { struct
145 impl<T, S> Inner<T, S> argument
|
| /commonlibrary/rust/ylong_http/ylong_http/src/ |
| D | version.rs | 82 enum Inner { enum
|
| /commonlibrary/rust/ylong_http/ylong_http_client/src/util/ |
| D | dispatcher.rs | 81 pub(crate) struct Inner<S> { struct
82 pub(crate) io: S,
86 pub(crate) occupied: AtomicBool,
88 pub(crate) shutdown: AtomicBool,
252 pub(crate) struct Inner<S> { struct
253 pub(crate) io: S,
254 pub(crate) encoder: FrameEncoder,
255 pub(crate) decoder: FrameDecoder,
|
| /commonlibrary/rust/ylong_http/ylong_http/src/request/ |
| D | method.rs | 158 enum Inner { enum
|
| /commonlibrary/rust/ylong_http/ylong_http_client/src/util/config/tls/alpn/ |
| D | mod.rs | 33 enum Inner { enum
|