| /external/rust/crates/crossbeam-channel/src/ |
| D | err.rs | 12 pub struct SendError<T>(pub T); struct
118 impl<T> fmt::Debug for SendError<T> { implementation
124 impl<T> fmt::Display for SendError<T> { implementation
130 impl<T: Send> error::Error for SendError<T> {} implementation
132 impl<T> SendError<T> { implementation
172 impl<T> From<SendError<T>> for TrySendError<T> {
173 fn from(err: SendError<T>) -> TrySendError<T> { in from()
175 SendError(t) => TrySendError::Disconnected(t), in from()
235 impl<T> From<SendError<T>> for SendTimeoutError<T> {
236 fn from(err: SendError<T>) -> SendTimeoutError<T> { in from()
[all …]
|
| D | lib.rs | 369 pub use crate::err::{SendError, SendTimeoutError, TrySendError};
|
| D | select.rs | 13 use crate::err::{RecvError, SendError};
1207 pub fn send<T>(mut self, s: &Sender<T>, msg: T) -> Result<(), SendError<T>> { in send()
1214 res.map_err(SendError) in send()
|
| /external/rust/crates/tokio/src/sync/mpsc/ |
| D | error.rs | 8 pub struct SendError<T>(pub T); struct
10 impl<T> fmt::Display for SendError<T> { implementation
16 impl<T: fmt::Debug> std::error::Error for SendError<T> {} implementation
48 impl<T> From<SendError<T>> for TrySendError<T> {
49 fn from(src: SendError<T>) -> TrySendError<T> { in from()
|
| D | bounded.rs | 4 use crate::sync::mpsc::error::{SendError, TryRecvError, TrySendError};
473 pub async fn send(&self, value: T) -> Result<(), SendError<T>> { in send()
479 Err(_) => Err(SendError(value)), in send()
699 pub fn blocking_send(&self, value: T) -> Result<(), SendError<T>> { in blocking_send()
769 pub async fn reserve(&self) -> Result<Permit<'_, T>, SendError<()>> { in reserve() argument
854 pub async fn reserve_owned(self) -> Result<OwnedPermit<T>, SendError<()>> { in reserve_owned() argument
861 async fn reserve_inner(&self) -> Result<(), SendError<()>> { in reserve_inner() argument
864 Err(_) => Err(SendError(())), in reserve_inner()
|
| D | unbounded.rs | 3 use crate::sync::mpsc::error::{SendError, TryRecvError};
304 pub fn send(&self, message: T) -> Result<(), SendError<T>> { in send()
306 return Err(SendError(message)); in send()
|
| /external/rust/crates/futures-channel/src/mpsc/ |
| D | mod.rs | 152 pub struct SendError { struct
159 err: SendError,
174 impl fmt::Display for SendError { implementation
184 impl std::error::Error for SendError {} implementation
186 impl SendError { impl
239 pub fn into_send_error(self) -> SendError { in into_send_error() argument
406 fn poll_ready_nb(&self) -> Poll<Result<(), SendError>> { in poll_ready_nb() argument
411 Poll::Ready(Err(SendError { kind: SendErrorKind::Disconnected })) in poll_ready_nb()
495 return Err(TrySendError { err: SendError { kind: SendErrorKind::Full }, val: msg }); in try_send()
524 err: SendError { kind: SendErrorKind::Disconnected }, in do_send_b()
[all …]
|
| D | sink_impl.rs | 1 use super::{SendError, Sender, TrySendError, UnboundedSender};
7 type Error = SendError;
34 type Error = SendError;
55 type Error = SendError;
|
| /external/rust/crates/tokio/tests/ |
| D | sync_errors.rs | 13 is_error::<error::SendError<()>>(); in mpsc_error_bound()
29 is_error::<error::SendError<()>>(); in watch_error_bound()
|
| /external/rust/crates/tokio/src/sync/ |
| D | watch.rs | 197 pub struct SendError<T>(pub T); struct
201 impl<T: fmt::Debug> fmt::Display for SendError<T> { implementation
207 impl<T: fmt::Debug> std::error::Error for SendError<T> {} implementation
626 pub fn send(&self, value: T) -> Result<(), error::SendError<T>> { in send()
629 return Err(error::SendError(value)); in send()
|
| D | broadcast.rs | 222 pub struct SendError<T>(pub T); struct
224 impl<T> fmt::Display for SendError<T> { implementation
230 impl<T: fmt::Debug> std::error::Error for SendError<T> {} implementation
538 pub fn send(&self, value: T) -> Result<usize, SendError<T>> { in send()
542 return Err(SendError(value)); in send()
|
| /external/openthread/src/core/net/ |
| D | icmp6.cpp | 90 Error Icmp::SendError(Header::Type aType, Header::Code aCode, const MessageInfo &aMessageInfo, cons… in SendError() function in ot::Ip6::Icmp
96 error = SendError(aType, aCode, aMessageInfo, headers); in SendError()
102 Error Icmp::SendError(Header::Type aType, Header::Code aCode, const MessageInfo &aMessageInfo, cons… in SendError() function in ot::Ip6::Icmp
|
| D | icmp6.hpp | 287 …Error SendError(Header::Type aType, Header::Code aCode, const MessageInfo &aMessageInfo, const Mes…
301 …Error SendError(Header::Type aType, Header::Code aCode, const MessageInfo &aMessageInfo, const Hea…
|
| /external/crosvm/devices/src/virtio/snd/vios_backend/ |
| D | mod.rs | 18 use std::sync::mpsc::SendError;
76 StreamThreadSend(SendError<StreamMsg>),
|
| /external/rust/crates/crossbeam-channel/tests/ |
| D | select_macro.rs | 13 use crossbeam_channel::{Receiver, RecvError, SendError, Sender, TryRecvError};
1227 send(s, 0) -> res => drop::<Result<(), SendError<i32>>>(res), in result_types()
1230 send(s, 0) -> res => drop::<Result<(), SendError<i32>>>(res), in result_types()
1234 send(s, 0) -> res => drop::<Result<(), SendError<i32>>>(res), in result_types()
1239 send(s, 0) -> res => drop::<Result<(), SendError<i32>>>(res), in result_types()
1358 send(s, 8) -> res => assert_eq!(res, Err(SendError(8))), in try_send()
1421 send(s, 9) -> res => assert_eq!(res, Err(SendError(9))), in send_timeout()
1442 send(s, ()) -> res => assert_eq!(res, Err(SendError(()))), in disconnect_wakes_sender()
|
| D | array.rs | 11 use crossbeam_channel::{SendError, SendTimeoutError, TrySendError};
206 assert_eq!(s.send(5), Err(SendError(5))); in send_timeout()
229 assert_eq!(s.send(4), Err(SendError(4))); in send_after_disconnect()
326 assert_eq!(s.send(()), Err(SendError(()))); in disconnect_wakes_sender()
|
| D | list.rs | 11 use crossbeam_channel::{SendError, SendTimeoutError, TrySendError};
163 assert_eq!(s.send(777), Err(SendError(777))); in send()
195 assert_eq!(s.send(4), Err(SendError(4))); in send_after_disconnect()
|
| D | mpsc.rs | 30 use std::sync::mpsc::{SendError, TrySendError};
41 pub fn send(&self, t: T) -> Result<(), SendError<T>> { in send()
42 self.inner.send(t).map_err(|cc::SendError(m)| SendError(m)) in send()
59 pub fn send(&self, t: T) -> Result<(), SendError<T>> { in send()
60 self.inner.send(t).map_err(|cc::SendError(m)| SendError(m)) in send()
966 assert_eq!(tx.send(123), Err(SendError(123))); in issue_32114()
|
| D | zero.rs | 11 use crossbeam_channel::{SendError, SendTimeoutError, TrySendError};
227 assert_eq!(s.send(()), Err(SendError(()))); in disconnect_wakes_sender()
|
| /external/skia/tools/skiaserve/ |
| D | Response.h | 19 int SendError(MHD_Connection* connection, const char* msg);
|
| D | Response.cpp | 55 int SendError(MHD_Connection* connection, const char* msg) { in SendError() function
|
| /external/skia/tools/skiaserve/urlhandlers/ |
| D | ColorModeHandler.cpp | 39 return SendError(connection, "Unable to create requested surface"); in handle()
|
| D | EnableGPUHandler.cpp | 37 return SendError(connection, "Unable to create GPU surface"); in handle()
|
| D | OverdrawHandler.cpp | 37 return SendError(connection, "Unable to set overdraw"); in handle()
|
| /external/rust/crates/futures/tests/ |
| D | sink.rs | 342 let mut tx = tx.with(|item: i32| future::ok::<i32, mpsc::SendError>(item + 10)); in with_propagates_poll_ready()
391 let mut is_positive = tx.clone().with(|item| future::ok::<bool, mpsc::SendError>(item > 0)); in with_implements_clone()
394 tx.clone().with(|item: &str| future::ok::<bool, mpsc::SendError>(item.len() > 5)); in with_implements_clone()
538 impl From<mpsc::SendError> for ErrIntoTest { in err_into()
539 fn from(_: mpsc::SendError) -> Self { in err_into()
|