| /external/rust/crates/mio/src/sys/unix/ |
| D | pipe.rs | 210 pub struct Sender { struct
214 impl Sender { impl
221 impl event::Source for Sender { implementation
245 impl Write for Sender { implementation
259 impl Write for &Sender { implementation
276 impl From<ChildStdin> for Sender { implementation
277 fn from(stdin: ChildStdin) -> Sender { in from()
283 impl FromRawFd for Sender { implementation
284 unsafe fn from_raw_fd(fd: RawFd) -> Sender { in from_raw_fd()
291 impl AsRawFd for Sender { implementation
[all …]
|
| /external/rust/crates/tokio/src/runtime/tests/ |
| D | loom_oneshot.rs | 19 pub(crate) struct Sender<T> { struct
32 impl<T> Sender<T> { impl
|
| /external/rust/crates/crossbeam-channel/src/ |
| D | counter.rs | 37 pub struct Sender<C> { struct
41 impl<C> Sender<C> { impl
77 impl<C> ops::Deref for Sender<C> { implementation
85 impl<C> PartialEq for Sender<C> { implementation
|
| D | channel.rs | 346 pub struct Sender<T> { struct
347 flavor: SenderFlavor<T>, argument
362 unsafe impl<T: Send> Send for Sender<T> {} implementation
363 unsafe impl<T: Send> Sync for Sender<T> {} implementation
365 impl<T> UnwindSafe for Sender<T> {} implementation
366 impl<T> RefUnwindSafe for Sender<T> {} implementation
368 impl<T> Sender<T> { implementation
643 impl<T> Drop for Sender<T> { implementation
655 impl<T> Clone for Sender<T> { implementation
667 impl<T> fmt::Debug for Sender<T> { implementation
[all …]
|
| /external/rust/crates/async-stream/src/ |
| D | yielder.rs | 9 pub struct Sender<T> { struct
23 pub fn pair<T>() -> (Sender<T>, Receiver<T>) { in pair() argument
36 impl<T: Unpin> Sender<T> { impl
|
| /external/rust/crates/tokio/src/sync/mpsc/ |
| D | bounded.rs | 21 pub struct Sender<T> { struct
27 /// `Permit` values are returned by [`Sender::reserve()`] and [`Sender::try_reserve()`] argument
297 impl<T> Sender<T> { impl
737 impl<T> Clone for Sender<T> { implementation
745 impl<T> fmt::Debug for Sender<T> { implementation
|
| /external/rust/crates/tokio/src/runtime/blocking/ |
| D | shutdown.rs | 12 pub(super) struct Sender { struct
13 tx: Arc<oneshot::Sender<()>>, argument
|
| /external/rust/crates/futures-channel/src/ |
| D | oneshot.rs | 28 pub struct Sender<T> { struct
34 impl<T> Unpin for Sender<T> {} implementation
335 impl<T> Sender<T> { impl
391 impl<T> Drop for Sender<T> { implementation
|
| /external/rust/crates/tokio/src/sync/ |
| D | broadcast.rs | 157 pub struct Sender<T> { struct
158 shared: Arc<Shared<T>>,
468 unsafe impl<T: Send> Send for Sender<T> {} implementation
469 unsafe impl<T: Send> Sync for Sender<T> {} implementation
474 impl<T> Sender<T> { implementation
676 impl<T> Clone for Sender<T> { implementation
685 impl<T> Drop for Sender<T> { implementation
1040 impl<T> fmt::Debug for Sender<T> { implementation
|
| D | watch.rs | 84 pub struct Sender<T> { struct
85 shared: Arc<Shared<T>>,
323 impl<T> Sender<T> { impl
422 impl<T> Drop for Sender<T> { implementation
|
| D | oneshot.rs | 72 pub struct Sender<T> { struct
76 /// Receive a value from the associated [`Sender`]. argument
269 impl<T> Sender<T> { implementation
522 impl<T> Drop for Sender<T> { implementation
|
| /external/webrtc/rtc_base/ |
| D | virtual_socket_unittest.cc | 56 struct Sender : public MessageHandler { struct
57 Sender(Thread* th, AsyncSocket* s, uint32_t rt) in Sender() argument
67 uint32_t NextDelay() { in NextDelay()
72 void OnMessage(Message* pmsg) override { in OnMessage()
92 Thread* thread;
93 std::unique_ptr<AsyncUDPSocket> socket;
94 rtc::PacketOptions options;
95 bool done;
96 uint32_t rate; // bytes per second
97 uint32_t count;
[all …]
|
| /external/llvm-project/clang/test/CodeGenCXX/ |
| D | pr24097.cpp | 6 struct Sender { struct
|
| /external/clang/test/CodeGenCXX/ |
| D | pr24097.cpp | 6 struct Sender { struct
|
| /external/libchrome/ipc/ |
| D | ipc_test_channel_listener.h | 14 class Sender; variable
|
| D | ipc_logging.h | 33 class Sender; variable
|
| /external/rust/crates/tokio/tests/ |
| D | sync_oneshot.rs | 13 impl AssertSend for oneshot::Sender<i32> {} implementation
19 impl<T> SenderExt for oneshot::Sender<T> { implementation
|
| /external/llvm-project/clang/test/CodeGen/ |
| D | available-externally-hidden.cpp | 12 class Sender { class
|
| /external/clang/test/CodeGen/ |
| D | available-externally-hidden.cpp | 12 class Sender { class
|
| /external/libchromeos-rs/src/sync/ |
| D | cv.rs | 620 async fn wait(mu: Arc<Mutex<()>>, cv: Arc<Condvar>, tx: Sender<()>, pool: ThreadPool) { in notify_one_multi_thread_async()
667 async fn increment(mu: Arc<Mutex<usize>>, cv: Arc<Condvar>, done: Sender<()>) { in notify_one_with_cancel()
681 done: Sender<()>, in notify_one_with_cancel()
698 done: Sender<()>, in notify_one_with_cancel()
769 async fn increment(mu: Arc<Mutex<usize>>, cv: Arc<Condvar>, done: Sender<()>) { in notify_all_with_cancel()
783 done: Sender<()>, in notify_all_with_cancel()
925 tx: Sender<()>, in notify_all_multi_thread_async()
|
| /external/crosvm/cros_async/src/sync/ |
| D | cv.rs | 584 async fn wait(mu: Arc<Mutex<()>>, cv: Arc<Condvar>, tx: Sender<()>, pool: ThreadPool) { in notify_one_multi_thread_async()
631 async fn increment(mu: Arc<Mutex<usize>>, cv: Arc<Condvar>, done: Sender<()>) { in notify_one_with_cancel()
645 done: Sender<()>, in notify_one_with_cancel()
662 done: Sender<()>, in notify_one_with_cancel()
733 async fn increment(mu: Arc<Mutex<usize>>, cv: Arc<Condvar>, done: Sender<()>) { in notify_all_with_cancel()
747 done: Sender<()>, in notify_all_with_cancel()
889 tx: Sender<()>, in notify_all_multi_thread_async()
|
| /external/openscreen/cast/streaming/ |
| D | sender_session.h | 32 class Sender; variable
|
| /external/rust/crates/crossbeam-channel/tests/ |
| D | select_macro.rs | 1147 struct Sender<T>(cc::Sender<T>); in deref() struct
1158 impl<T> Deref for Sender<T> { in deref() implementation
|
| D | mpsc.rs | 30 pub struct Sender<T> { struct
31 pub inner: cc::Sender<T>, argument
34 impl<T> Sender<T> { impl
40 impl<T> Clone for Sender<T> { implementation
|
| /external/webrtc/modules/audio_coding/test/ |
| D | EncodeDecodeTest.cc | 49 Sender::Sender() in Sender() function in webrtc::Sender
|