| /external/rust/crates/crossbeam-channel/src/ |
| D | err.rs | 75 pub enum RecvTimeoutError { enum
329 impl fmt::Display for RecvTimeoutError { implementation
332 RecvTimeoutError::Timeout => "timed out waiting on receive operation".fmt(f), in fmt()
333 RecvTimeoutError::Disconnected => "channel is empty and disconnected".fmt(f), in fmt()
338 impl error::Error for RecvTimeoutError {} implementation
340 impl From<RecvError> for RecvTimeoutError { implementation
341 fn from(err: RecvError) -> RecvTimeoutError { in from() argument
343 RecvError => RecvTimeoutError::Disconnected, in from()
348 impl RecvTimeoutError { impl
353 RecvTimeoutError::Timeout => true, in is_timeout()
[all …]
|
| D | channel.rs | 13 RecvError, RecvTimeoutError, SendError, SendTimeoutError, TryRecvError, TrySendError,
809 Result<Instant, RecvTimeoutError>, in recv()
810 Result<T, RecvTimeoutError>, in recv()
818 Result<Instant, RecvTimeoutError>, in recv()
819 Result<T, RecvTimeoutError>, in recv()
865 pub fn recv_timeout(&self, timeout: Duration) -> Result<T, RecvTimeoutError> { in recv_timeout() argument
908 pub fn recv_deadline(&self, deadline: Instant) -> Result<T, RecvTimeoutError> { in recv_deadline() argument
917 Result<Instant, RecvTimeoutError>, in recv_deadline()
918 Result<T, RecvTimeoutError>, in recv_deadline()
926 Result<Instant, RecvTimeoutError>, in recv_deadline()
[all …]
|
| D | lib.rs | 365 pub use crate::err::{RecvError, RecvTimeoutError, TryRecvError};
|
| D | select_macro.rs | 621 ::std::result::Result::Err($crate::RecvTimeoutError::Timeout) => {
|
| /external/rust/crates/crossbeam-channel/src/flavors/ |
| D | at.rs | 10 use crate::err::{RecvTimeoutError, TryRecvError};
67 pub fn recv(&self, deadline: Option<Instant>) -> Result<Instant, RecvTimeoutError> { in recv() argument
72 return Err(RecvTimeoutError::Timeout); in recv()
83 Some(d) if now >= d => return Err(RecvTimeoutError::Timeout), in recv()
|
| D | never.rs | 9 use crate::err::{RecvTimeoutError, TryRecvError};
38 pub fn recv(&self, deadline: Option<Instant>) -> Result<T, RecvTimeoutError> { in recv() argument
40 Err(RecvTimeoutError::Timeout) in recv()
|
| D | tick.rs | 11 use crate::err::{RecvTimeoutError, TryRecvError};
59 pub fn recv(&self, deadline: Option<Instant>) -> Result<Instant, RecvTimeoutError> { in recv() argument
69 return Err(RecvTimeoutError::Timeout); in recv()
|
| D | zero.rs | 13 use crate::err::{RecvTimeoutError, SendTimeoutError, TryRecvError, TrySendError};
276 pub fn recv(&self, deadline: Option<Instant>) -> Result<T, RecvTimeoutError> { in recv() argument
285 return self.read(token).map_err(|_| RecvTimeoutError::Disconnected); in recv()
290 return Err(RecvTimeoutError::Disconnected); in recv()
310 Err(RecvTimeoutError::Timeout) in recv()
314 Err(RecvTimeoutError::Disconnected) in recv()
|
| D | array.rs | 26 use crate::err::{RecvTimeoutError, SendTimeoutError, TryRecvError, TrySendError};
405 pub fn recv(&self, deadline: Option<Instant>) -> Result<T, RecvTimeoutError> { in recv() argument
413 return res.map_err(|_| RecvTimeoutError::Disconnected); in recv()
425 return Err(RecvTimeoutError::Timeout); in recv()
|
| D | list.rs | 13 use crate::err::{RecvTimeoutError, SendTimeoutError, TryRecvError, TrySendError};
437 pub fn recv(&self, deadline: Option<Instant>) -> Result<T, RecvTimeoutError> { in recv() argument
445 return self.read(token).map_err(|_| RecvTimeoutError::Disconnected); in recv()
458 return Err(RecvTimeoutError::Timeout); in recv()
|
| /external/rust/crates/crossbeam-channel/tests/ |
| D | mpsc.rs | 23 use std::sync::mpsc::{RecvError, RecvTimeoutError, TryRecvError};
89 pub fn recv_timeout(&self, timeout: Duration) -> Result<T, RecvTimeoutError> { in recv_timeout() argument
91 cc::RecvTimeoutError::Timeout => RecvTimeoutError::Timeout, in recv_timeout()
92 cc::RecvTimeoutError::Disconnected => RecvTimeoutError::Disconnected, in recv_timeout()
653 Err(RecvTimeoutError::Timeout) in oneshot_single_thread_recv_timeout()
681 Err(RecvTimeoutError::Timeout) => continue, in stress_recv_timeout_two_threads()
682 Err(RecvTimeoutError::Disconnected) => break, in stress_recv_timeout_two_threads()
697 assert_eq!(rx.recv_timeout(timeout), Err(RecvTimeoutError::Timeout)); in recv_timeout_upgrade()
725 Err(RecvTimeoutError::Timeout) => continue, in stress_recv_timeout_shared()
726 Err(RecvTimeoutError::Disconnected) => break, in stress_recv_timeout_shared()
[all …]
|
| D | list.rs | 10 use crossbeam_channel::{RecvError, RecvTimeoutError, TryRecvError};
29 assert_eq!(r.recv_timeout(ms(1000)), Err(RecvTimeoutError::Timeout)); in smoke()
118 assert_eq!(r.recv_timeout(ms(1000)), Err(RecvTimeoutError::Timeout)); in recv_timeout()
122 Err(RecvTimeoutError::Disconnected) in recv_timeout()
|
| D | array.rs | 10 use crossbeam_channel::{RecvError, RecvTimeoutError, TryRecvError};
29 assert_eq!(r.recv_timeout(ms(1000)), Err(RecvTimeoutError::Timeout)); in smoke()
129 assert_eq!(r.recv_timeout(ms(1000)), Err(RecvTimeoutError::Timeout)); in recv_timeout()
133 Err(RecvTimeoutError::Disconnected) in recv_timeout()
|
| D | zero.rs | 10 use crossbeam_channel::{RecvError, RecvTimeoutError, TryRecvError};
107 assert_eq!(r.recv_timeout(ms(1000)), Err(RecvTimeoutError::Timeout)); in recv_timeout()
111 Err(RecvTimeoutError::Disconnected) in recv_timeout()
|
| /external/rust/crates/tokio/tests/ |
| D | task_local_set.rs | 322 use std::sync::mpsc::RecvTimeoutError; in with_timeout()
343 Err(RecvTimeoutError::Timeout) => panic!( in with_timeout()
350 Err(RecvTimeoutError::Disconnected) => { in with_timeout()
|
| /external/crosvm/src/ |
| D | gdb.rs | 81 VcpuResponse(mpsc::RecvTimeoutError),
|