| /external/rust/crates/tokio/src/process/unix/ |
| D | driver.rs | 5 use crate::park::Park;
18 park: SignalDriver, field
56 pub(crate) fn new(park: SignalDriver) -> io::Result<Self> { in new()
57 let sigchild = signal_with_handle(SignalKind::child(), park.handle())?; in new()
63 Ok(Self { park, inner }) in new()
74 self.park.unpark() in unpark()
77 fn park(&mut self) -> Result<(), Self::Error> { in park() method
78 self.park.park()?; in park()
84 self.park.park_timeout(duration)?; in park_timeout()
90 self.park.shutdown() in shutdown()
|
| /external/rust/crates/tokio/src/signal/unix/ |
| D | driver.rs | 7 use crate::park::Park;
25 park: IoDriver, field
46 pub(crate) fn new(park: IoDriver) -> io::Result<Self> { in new()
80 park.handle(), in new()
84 park, in new()
146 self.park.unpark() in unpark()
149 fn park(&mut self) -> Result<(), Self::Error> { in park() method
150 self.park.park()?; in park()
156 self.park.park_timeout(duration)?; in park_timeout()
162 self.park.shutdown() in shutdown()
|
| /external/rust/crates/tokio/src/runtime/thread_pool/ |
| D | worker.rs | 10 use crate::park::{Park, Unpark};
13 use crate::runtime::park::{Parker, Unparker};
63 park: Option<Parker>, field
128 pub(super) fn create(size: usize, park: Parker) -> (Arc<Shared>, Launch) { in create()
136 let park = park.clone(); in create() localVariable
137 let unpark = park.unpark(); in create()
146 park: Some(park), in create()
242 assert!(core.park.is_some()); in block_in_place()
328 core = self.park(core); in run()
394 fn park(&self, mut core: Box<Core>) -> Box<Core> { in park() method
[all …]
|
| /external/rust/crates/tokio/src/time/driver/ |
| D | mod.rs | 21 use crate::park::{Park, Unpark};
93 park: P, field
172 pub(crate) fn new(park: P, clock: Clock) -> Driver<P> { in new()
175 let inner = Inner::new(time_source.clone(), Box::new(park.unpark())); in new()
180 park, in new()
221 self.park.park_timeout(Duration::from_secs(0))?; in park_internal()
226 self.park.park_timeout(duration)?; in park_internal()
229 self.park.park_timeout(Duration::from_secs(0))?; in park_internal()
235 self.park.park_timeout(Duration::from_secs(0))?; in park_internal()
238 self.park.park_timeout(duration)?; in park_internal()
[all …]
|
| /external/rust/crates/tokio/src/runtime/ |
| D | enter.rs | 28 use crate::park::thread::ParkError;
148 use crate::park::thread::CachedParkThread;
150 let mut park = CachedParkThread::new(); localVariable
151 park.block_on(f)
162 use crate::park::Park;
163 use crate::park::thread::CachedParkThread;
168 let mut park = CachedParkThread::new(); localVariable
169 let waker = park.get_unpark()?.into_waker();
186 park.park_timeout(when - now)?;
|
| D | driver.rs | 2 use crate::park::thread::ParkThread;
3 use crate::park::Park;
12 type IoStack = crate::park::either::Either<ProcessDriver, ParkThread>;
16 use crate::park::either::Either;
101 type TimeDriver = crate::park::either::Either<crate::time::driver::Driver<IoStack>, IoStack>;
115 use crate::park::either::Either;
197 fn park(&mut self) -> Result<(), Self::Error> { in park() method
198 self.inner.park() in park()
|
| D | park.rs | 8 use crate::park::{Park, Unpark};
92 fn park(&mut self) -> Result<(), Self::Error> { in park() method
93 self.inner.park(); in park()
121 fn park(&self) { in park() method
205 driver.park().unwrap(); in park_driver()
|
| D | basic_scheduler.rs | 4 use crate::park::{Park, Unpark};
51 park: P, field
122 pub(crate) fn new(park: P) -> BasicScheduler<P> { in new()
123 let unpark = Box::new(park.unpark()); in new()
140 park, in new()
246 scheduler.park.park().expect("failed to park"); in block_on()
280 .park in block_on()
|
| D | mod.rs | 208 mod park;
209 use park::Parker;
|
| D | shell.rs | 4 use crate::park::{Park, Unpark};
115 driver.park().unwrap(); in block_on()
|
| /external/rust/crates/tokio/src/future/ |
| D | block_on.rs | 12 let mut park = crate::park::thread::CachedParkThread::new(); localVariable
13 park.block_on(f).unwrap()
|
| /external/rust/crates/tokio/src/park/ |
| D | thread.rs | 5 use crate::park::{Park, Unpark};
61 fn park(&mut self) -> Result<(), Self::Error> { in park() method
62 self.inner.park(); in park()
80 fn park(&self) { in park() method
267 self.park()?; in block_on()
280 fn park(&mut self) -> Result<(), Self::Error> { in park() method
281 self.with_current(|park_thread| park_thread.inner.park())?; in park()
|
| D | either.rs | 3 use crate::park::{Park, Unpark};
28 fn park(&mut self) -> Result<(), Self::Error> { in park() function
30 Either::A(a) => a.park().map_err(Either::A), in park()
31 Either::B(b) => b.park().map_err(Either::B), in park()
|
| D | mod.rs | 70 fn park(&mut self) -> Result<(), Self::Error>; in park() method
|
| /external/rust/crates/crossbeam-utils/src/sync/ |
| D | parker.rs | 106 pub fn park(&self) { in park() method
107 self.unparker.inner.park(None); in park()
142 self.unparker.inner.park(Some(deadline)) in park_deadline()
315 fn park(&self, deadline: Option<Instant>) { in park() method
|
| /external/rust/crates/parking_lot_core/src/thread_parker/windows/ |
| D | keyed_event.rs | 122 pub unsafe fn park(&'static self, key: &AtomicUsize) { in park() method
135 self.park(key); in park_until()
153 self.park(key); in park_until()
167 self.park(key); in park_until()
|
| D | mod.rs | 113 pub unsafe fn park(&self) { in park() method
115 Backend::KeyedEvent(ref x) => x.park(&self.key), in park()
116 Backend::WaitAddress(ref x) => x.park(&self.key), in park()
|
| /external/rust/crates/parking_lot_core/src/thread_parker/ |
| D | redox.rs | 52 unsafe fn park(&self) { in park() method
68 self.park(); in park_until()
|
| D | linux.rs | 64 unsafe fn park(&self) { in park() method
80 self.park(); in park_until()
|
| D | wasm.rs | 33 unsafe fn park(&self) { in park() method
|
| D | mod.rs | 28 unsafe fn park(&self); in park() method
|
| D | generic.rs | 43 unsafe fn park(&self) { in park() method
|
| D | sgx.rs | 52 unsafe fn park(&self) { in park() method
|
| /external/rust/crates/parking_lot_core/src/ |
| D | lib.rs | 62 pub use self::parking_lot::{park, unpark_all, unpark_filter, unpark_one, unpark_requeue};
|
| /external/rust/crates/tokio/src/io/driver/ |
| D | mod.rs | 17 use crate::park::{Park, Unpark};
232 fn park(&mut self) -> io::Result<()> { in park() method
|