Searched refs:Handle (Results 1 - 13 of 13) sorted by relevance
| /commonlibrary/rust/ylong_runtime/ylong_runtime/src/executor/ |
| H A D | driver_handle.rs | 39 pub(crate) struct Handle {
46 impl Handle { impls
53 pub(crate) fn get_handle() -> io::Result<Arc<Handle>> {
61 impl Handle { impls
86 impl Handle { impls
103 impl Handle { impls
125 pub(crate) struct Handle {
129 impl Handle { impls
130 pub(crate) fn get_handle() -> io::Result<Arc<Handle>> {
131 Ok(Arc::new(Handle{i
[all...] |
| H A D | driver.rs | 17 pub(crate) use crate::executor::driver_handle::Handle;
49 pub(crate) fn initialize() -> (Arc<Handle>, Arc<Mutex<Driver>>) {
54 let handle = Handle {
|
| H A D | parker.rs | 20 use crate::executor::driver::{Driver, Handle, ParkFlag};
55 pub(crate) fn unpark(&self, handle: Arc<Handle>) {
165 fn unpark(&self, handle: Arc<Handle>) { in unpark()
|
| H A D | worker.rs | 21 use crate::executor::driver::Handle;
60 pub(crate) _handle: Arc<Handle>,
91 pub(crate) fn run_worker(worker: Arc<Worker>, handle: Arc<Handle>) {
|
| H A D | current_thread.rs | 25 use crate::executor::driver::{Driver, Handle, ParkFlag};
43 pub(crate) handle: Arc<Handle>,
84 handle: Arc<Handle>,
88 fn new(driver: Arc<Mutex<Driver>>, handle: Arc<Handle>) -> Parker { in new()
|
| H A D | mod.rs | 31 pub(crate) use driver_handle::Handle;
88 pub(crate) fn get_handle(&self) -> std::sync::Arc<Handle> {
|
| H A D | async_pool.rs | 22 use super::driver::{Driver, Handle};
53 pub(crate) handle: Arc<Handle>,
68 pub(crate) fn new(thread_num: usize, handle: Arc<Handle>) -> Self {
373 /// Handle for shutting down the pool
392 fn async_thread_proc(inner: Arc<Inner>, worker: Arc<Worker>, handle: Arc<Handle>) { in async_thread_proc()
|
| /commonlibrary/rust/ylong_runtime/ylong_io/src/sys/windows/ |
| H A D | handle.rs | 20 pub(crate) struct Handle(HANDLE);
22 impl Handle { impls
39 impl Drop for Handle {
|
| H A D | iocp.rs | 18 use super::Handle;
29 handle: Handle,
40 handle: Handle::new(handle),
|
| H A D | mod.rs | 34 use handle::Handle;
|
| /commonlibrary/rust/ylong_runtime/ylong_runtime/src/signal/unix/ |
| H A D | driver.rs | 19 use crate::executor::driver::Handle;
49 pub(crate) fn initialize(handle: &Handle) -> SignalDriver {
|
| /commonlibrary/rust/ylong_http/ylong_http_client/src/util/ |
| H A D | dispatcher.rs | 15 type Handle; types
17 fn dispatch(&self) -> Option<Self::Handle>; in dispatch()
37 type Handle = Conn<S>; types
39 fn dispatch(&self) -> Option<Self::Handle> { in dispatch()
135 type Handle = Http1Conn<S>; types
137 fn dispatch(&self) -> Option<Self::Handle> { in dispatch()
156 /// Handle returned to other threads for I/O operations.
384 type Handle = Http2Conn<S>; types
386 fn dispatch(&self) -> Option<Self::Handle> { in dispatch()
847 type Handle types
[all...] |
| /commonlibrary/rust/ylong_runtime/ylong_runtime/src/net/ |
| H A D | async_source.rs | 26 use crate::executor::Handle;
41 /// Handle to the IO Driver, used for deregistration
42 pub(crate) handle: Arc<Handle>,
64 let inner = Handle::get_handle()?; in new()
|
Completed in 6 milliseconds