| /external/rust/crates/crossbeam-channel/src/ |
| D | err.rs | 28 Disconnected(T), enumerator
45 Disconnected(T), enumerator
68 Disconnected, enumerator
83 Disconnected, enumerator
156 TrySendError::Disconnected(..) => "Disconnected(..)".fmt(f), in fmt()
165 TrySendError::Disconnected(..) => "sending on a disconnected channel".fmt(f), in fmt()
175 SendError(t) => TrySendError::Disconnected(t), in from()
197 TrySendError::Disconnected(v) => v, in into_inner()
212 TrySendError::Disconnected(_) => true, in is_disconnected()
228 SendTimeoutError::Disconnected(..) => "sending on a disconnected channel".fmt(f), in fmt()
[all …]
|
| D | select.rs | 62 Disconnected, enumerator
74 2 => Selected::Disconnected, in from()
86 Selected::Disconnected => 2, in into()
277 Selected::Disconnected => {} in run_select()
423 Selected::Disconnected => {} in run_ready()
|
| D | waker.rs | 153 if entry.cx.try_select(Selected::Disconnected).is_ok() { in disconnect()
|
| /external/rust/crates/crossbeam-channel/src/flavors/ |
| D | zero.rs | 199 Err(TrySendError::Disconnected(msg)) in try_send()
221 return Err(SendTimeoutError::Disconnected(msg)); in send()
244 Selected::Disconnected => { in send()
247 Err(SendTimeoutError::Disconnected(msg)) in send()
267 unsafe { self.read(token).map_err(|_| TryRecvError::Disconnected) } in try_recv()
269 Err(TryRecvError::Disconnected) in try_recv()
285 return self.read(token).map_err(|_| RecvTimeoutError::Disconnected); in recv()
290 return Err(RecvTimeoutError::Disconnected); in recv()
312 Selected::Disconnected => { in recv()
314 Err(RecvTimeoutError::Disconnected) in recv()
|
| D | array.rs | 338 unsafe { self.write(token, msg).map_err(TrySendError::Disconnected) } in try_send()
353 return res.map_err(SendTimeoutError::Disconnected); in send()
384 Selected::Aborted | Selected::Disconnected => { in send()
398 unsafe { self.read(token).map_err(|_| TryRecvError::Disconnected) } in try_recv()
413 return res.map_err(|_| RecvTimeoutError::Disconnected); in recv()
444 Selected::Aborted | Selected::Disconnected => { in recv()
|
| D | list.rs | 410 SendTimeoutError::Disconnected(msg) => TrySendError::Disconnected(msg), in try_send()
421 .map_err(SendTimeoutError::Disconnected) in send()
430 unsafe { self.read(token).map_err(|_| TryRecvError::Disconnected) } in try_recv()
445 return self.read(token).map_err(|_| RecvTimeoutError::Disconnected); in recv()
477 Selected::Aborted | Selected::Disconnected => { in recv()
|
| D | tick.rs | 129 Err(TryRecvError::Disconnected) => { in try_select()
|
| D | at.rs | 159 Err(TryRecvError::Disconnected) => { in try_select()
|
| /external/rust/crates/crossbeam-channel/tests/ |
| D | ready.rs | 74 Ok(0) => assert_eq!(r1.try_recv(), Err(TryRecvError::Disconnected)), in disconnected()
86 Ok(0) => assert_eq!(r1.try_recv(), Err(TryRecvError::Disconnected)), in disconnected()
99 Ok(0) => assert_eq!(r2.try_recv(), Err(TryRecvError::Disconnected)), in disconnected()
183 Ok(0) => assert_eq!(r.try_recv(), Err(TryRecvError::Disconnected)), in timeout()
197 Ok(0) => assert_eq!(r.try_recv(), Err(TryRecvError::Disconnected)), in default_when_disconnected()
206 Ok(0) => assert_eq!(r.try_recv(), Err(TryRecvError::Disconnected)), in default_when_disconnected()
215 Ok(0) => assert_eq!(s.try_send(0), Err(TrySendError::Disconnected(0))), in default_when_disconnected()
224 Ok(0) => assert_eq!(s.try_send(0), Err(TrySendError::Disconnected(0))), in default_when_disconnected()
398 assert_eq!(r.try_recv(), Err(TryRecvError::Disconnected)); in preflight2()
412 0 => assert_eq!(r.try_recv(), Err(TryRecvError::Disconnected)), in preflight3()
|
| D | list.rs | 79 assert_eq!(r.try_recv(), Err(TryRecvError::Disconnected)); in try_recv()
122 Err(RecvTimeoutError::Disconnected) in recv_timeout()
141 assert_eq!(s.try_send(777), Err(TrySendError::Disconnected(777))); in try_send()
165 Err(SendTimeoutError::Disconnected(777)) in send_timeout()
180 assert_eq!(s.try_send(5), Err(TrySendError::Disconnected(5))); in send_after_disconnect()
183 Err(SendTimeoutError::Disconnected(6)) in send_after_disconnect()
|
| D | mpsc.rs | 60 cc::TrySendError::Disconnected(m) => TrySendError::Disconnected(m), in try_send()
81 cc::TryRecvError::Disconnected => TryRecvError::Disconnected, in try_recv()
92 cc::RecvTimeoutError::Disconnected => RecvTimeoutError::Disconnected, in recv_timeout()
488 assert_eq!(rx.try_recv(), Err(TryRecvError::Disconnected)); in oneshot_single_thread_peek_close()
489 assert_eq!(rx.try_recv(), Err(TryRecvError::Disconnected)); in oneshot_single_thread_peek_close()
682 Err(RecvTimeoutError::Disconnected) => break, in stress_recv_timeout_two_threads()
726 Err(RecvTimeoutError::Disconnected) => break, in stress_recv_timeout_shared()
919 assert_eq!(rx1.try_recv(), Err(TryRecvError::Disconnected)); in try_recv_states()
1112 Err(RecvTimeoutError::Disconnected) => break, in stress_recv_timeout_two_threads()
1136 Err(RecvTimeoutError::Disconnected) => break, in stress_recv_timeout_shared()
[all …]
|
| D | array.rs | 90 assert_eq!(r.try_recv(), Err(TryRecvError::Disconnected)); in try_recv()
133 Err(RecvTimeoutError::Disconnected) in recv_timeout()
155 assert_eq!(s.try_send(4), Err(TrySendError::Disconnected(4))); in try_send()
230 assert_eq!(s.try_send(5), Err(TrySendError::Disconnected(5))); in send_after_disconnect()
233 Err(SendTimeoutError::Disconnected(6)) in send_after_disconnect()
|
| D | zero.rs | 68 assert_eq!(r.try_recv(), Err(TryRecvError::Disconnected)); in try_recv()
111 Err(RecvTimeoutError::Disconnected) in recv_timeout()
132 assert_eq!(s.try_send(9), Err(TrySendError::Disconnected(9))); in try_send()
177 Err(SendTimeoutError::Disconnected(9)) in send_timeout()
|
| /external/rust/crates/futures-channel/src/mpsc/ |
| D | mod.rs | 172 Disconnected, enumerator
204 SendErrorKind::Disconnected => true, in is_disconnected()
434 kind: SendErrorKind::Disconnected, in poll_ready_nb()
556 kind: SendErrorKind::Disconnected, in do_send_b()
654 kind: SendErrorKind::Disconnected, in poll_ready()
729 kind: SendErrorKind::Disconnected, in try_send()
763 kind: SendErrorKind::Disconnected, in poll_ready()
817 kind: SendErrorKind::Disconnected, in poll_ready()
850 kind: SendErrorKind::Disconnected, in do_send_nb()
|
| /external/e2fsprogs/tests/f_bad_disconnected_inode/ |
| D | name | 1 Disconnected inode with bad fields
|
| /external/oboe/docs/notes/ |
| D | README.md | 6 * [Disconnected Streams](disconnect.md) - Responding to Plugging In and Unplugging Headsets
|
| /external/oboe/docs/ |
| D | README.md | 12 - [Disconnected Streams](notes/disconnect.md)
|
| /external/libkmsxx/kms++/inc/kms++/ |
| D | connector.h | 15 Disconnected, enumerator
|
| /external/crosvm/base/src/ |
| D | tube.rs | 29 Disconnected, enumerator
87 return Err(Error::Disconnected); in recv()
|
| /external/oboe/include/oboe/ |
| D | Definitions.h | 72 Disconnected = 13, // AAUDIO_STREAM_STATE_DISCONNECTED, enumerator
|
| /external/oboe/samples/iolib/src/main/cpp/player/ |
| D | SimpleMultiPlayer.cpp | 47 if (streamState == StreamState::Disconnected) { in onAudioReady()
|
| /external/libwebsockets/minimal-examples/secure-streams/minimal-secure-streams-alexa/ |
| D | README.md | 73 ^C[2019/10/16 16:22:14:3067] U: Disconnected from Alexa
|
| /external/oboe/src/common/ |
| D | AudioStream.cpp | 84 } else if (state == StreamState::Disconnected) { in waitForStateTransition()
|
| D | Utilities.cpp | 147 case StreamState::Disconnected: return "Disconnected"; in convertToText()
|
| /external/libkmsxx/kms++/src/ |
| D | connector.cpp | 206 return ConnectorStatus::Disconnected; in connector_status()
|