| /external/rust/crates/crossbeam-utils/tests/ |
| D | parker.rs | 13 p.park_timeout(Duration::from_millis(u32::MAX as u64)); in park_timeout_unpark_before()
21 p.park_timeout(Duration::from_millis(10)) in park_timeout_unpark_not_called()
37 p.park_timeout(Duration::from_millis(u32::MAX as u64)) in park_timeout_unpark_called_other_thread()
|
| /external/rust/crates/tokio/src/park/ |
| D | either.rs | 35 fn park_timeout(&mut self, duration: Duration) -> Result<(), Self::Error> { in park_timeout() function
37 Either::A(a) => a.park_timeout(duration).map_err(Either::A), in park_timeout()
38 Either::B(b) => b.park_timeout(duration).map_err(Either::B), in park_timeout()
|
| D | thread.rs | 66 fn park_timeout(&mut self, duration: Duration) -> Result<(), Self::Error> { in park_timeout() method
67 self.inner.park_timeout(duration); in park_timeout()
127 fn park_timeout(&self, dur: Duration) { in park_timeout() method
285 fn park_timeout(&mut self, duration: Duration) -> Result<(), Self::Error> { in park_timeout() method
286 self.with_current(|park_thread| park_thread.inner.park_timeout(duration))?; in park_timeout()
|
| D | mod.rs | 86 fn park_timeout(&mut self, duration: Duration) -> Result<(), Self::Error>; in park_timeout() method
|
| /external/rust/crates/tokio/src/time/driver/ |
| D | mod.rs | 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()
401 fn park_timeout(&mut self, duration: Duration) -> Result<(), Self::Error> { in park_timeout() function
|
| /external/rust/crates/tokio/src/process/unix/ |
| D | driver.rs | 83 fn park_timeout(&mut self, duration: Duration) -> Result<(), Self::Error> { in park_timeout() method
84 self.park.park_timeout(duration)?; in park_timeout()
|
| /external/rust/crates/tokio/src/signal/unix/ |
| D | driver.rs | 155 fn park_timeout(&mut self, duration: Duration) -> Result<(), Self::Error> { in park_timeout() method
156 self.park.park_timeout(duration)?; in park_timeout()
|
| /external/rust/crates/tokio/src/runtime/ |
| D | park.rs | 97 fn park_timeout(&mut self, duration: Duration) -> Result<(), Self::Error> { in park_timeout() method
102 driver.park_timeout(duration).map_err(|_| ()) in park_timeout()
|
| D | driver.rs | 201 fn park_timeout(&mut self, duration: Duration) -> Result<(), Self::Error> { in park_timeout() method
202 self.inner.park_timeout(duration) in park_timeout()
|
| D | enter.rs | 186 park.park_timeout(when - now)?;
|
| D | basic_scheduler.rs | 281 .park_timeout(Duration::from_millis(0)) in block_on()
|
| /external/rust/crates/tokio/src/runtime/thread_pool/ |
| D | worker.rs | 385 core = self.park_timeout(core, Some(Duration::from_millis(0))); in maintenance()
398 core = self.park_timeout(core, None); in park()
411 fn park_timeout(&self, mut core: Box<Core>, duration: Option<Duration>) -> Box<Core> { in park_timeout() method
420 park.park_timeout(timeout).expect("park failed"); in park_timeout()
|
| /external/rust/crates/crossbeam-utils/src/sync/ |
| D | parker.rs | 123 pub fn park_timeout(&self, timeout: Duration) { in park_timeout() method
|
| /external/rust/crates/crossbeam-channel/src/ |
| D | context.rs | 166 thread::park_timeout(end - now); in wait_until()
|
| /external/rust/crates/tokio/src/io/driver/ |
| D | mod.rs | 237 fn park_timeout(&mut self, duration: Duration) -> io::Result<()> { in park_timeout() method
|