| /external/rust/crates/quiche/src/ |
| D | stream.rs | 472 pub recv: RecvBuf, field
499 recv: RecvBuf::new(max_rx_data), in new()
511 self.recv.ready() in is_readable()
541 (true, _) => self.recv.is_fin() && self.send.is_complete(), in is_complete()
549 (false, false) => self.recv.is_fin(), in is_complete()
1251 let mut recv = RecvBuf::new(std::u64::MAX); in empty_read() localVariable
1252 assert_eq!(recv.len, 0); in empty_read()
1256 assert_eq!(recv.pop(&mut buf), Err(Error::Done)); in empty_read()
1261 let mut recv = RecvBuf::new(15); in empty_stream_frame() localVariable
1262 assert_eq!(recv.len, 0); in empty_stream_frame()
[all …]
|
| /external/rust/crates/crossbeam-channel/tests/ |
| D | select_macro.rs | 27 recv(r1) -> v => assert_eq!(v, Ok(1)), in smoke1()
28 recv(r2) -> _ => panic!(), in smoke1()
34 recv(r1) -> _ => panic!(), in smoke1()
35 recv(r2) -> v => assert_eq!(v, Ok(2)), in smoke1()
50 recv(r1) -> _ => panic!(), in smoke2()
51 recv(r2) -> _ => panic!(), in smoke2()
52 recv(r3) -> _ => panic!(), in smoke2()
53 recv(r4) -> _ => panic!(), in smoke2()
54 recv(r5) -> v => assert_eq!(v, Ok(5)), in smoke2()
71 recv(r1) -> v => assert!(v.is_err()), in disconnected()
[all …]
|
| D | select.rs | 23 let oper1 = sel.recv(&r1); in smoke1()
24 let oper2 = sel.recv(&r2); in smoke1()
27 i if i == oper1 => assert_eq!(oper.recv(&r1), Ok(1)), in smoke1()
35 let oper1 = sel.recv(&r1); in smoke1()
36 let oper2 = sel.recv(&r2); in smoke1()
40 i if i == oper2 => assert_eq!(oper.recv(&r2), Ok(2)), in smoke1()
56 let oper1 = sel.recv(&r1); in smoke2()
57 let oper2 = sel.recv(&r2); in smoke2()
58 let oper3 = sel.recv(&r3); in smoke2()
59 let oper4 = sel.recv(&r4); in smoke2()
[all …]
|
| D | ready.rs | 24 sel.recv(&r1); in smoke1()
25 sel.recv(&r2); in smoke1()
32 sel.recv(&r1); in smoke1()
33 sel.recv(&r2); in smoke1()
49 sel.recv(&r1); in smoke2()
50 sel.recv(&r2); in smoke2()
51 sel.recv(&r3); in smoke2()
52 sel.recv(&r4); in smoke2()
53 sel.recv(&r5); in smoke2()
71 sel.recv(&r1); in disconnected()
[all …]
|
| D | tick.rs | 34 recv(r) -> _ => panic!(), in fire()
39 recv(r) -> _ => {} in fire()
40 recv(tick(ms(200))) -> _ => panic!(), in fire()
49 let t1 = r.recv().unwrap(); in intervals()
59 let t3 = r.recv().unwrap(); in intervals()
115 fn recv() { in recv() function
119 let fired = r.recv().unwrap(); in recv()
163 recv(r1) -> _ => {} in recv_two()
164 recv(r2) -> _ => {} in recv_two()
171 recv(r1) -> _ => {} in recv_two()
[all …]
|
| D | golang.rs | 62 fn recv(&self) -> Option<T> { in recv() method
64 r.recv().ok() in recv()
96 self.recv() in next()
286 done.recv(); in main()
287 done.recv(); in main()
288 done.recv(); in main()
289 done.recv(); in main()
309 if ch.recv() != Some(i) { in asynch_fifo()
316 inp.recv(); in chain()
317 if ch.recv() != Some(val) { in chain()
[all …]
|
| D | mpsc.rs | 85 pub fn recv(&self) -> Result<T, RecvError> { in recv() method
86 self.inner.recv().map_err(|_| RecvError) in recv()
143 self.inner.recv().ok() in next()
155 self.inner.recv().ok() in next()
179 recv(($rx).inner) -> res => {
207 assert_eq!(rx.recv().unwrap(), 1); in smoke()
228 assert_eq!(rx.recv().unwrap(), 1); in smoke_shared()
231 assert_eq!(rx.recv().unwrap(), 1); in smoke_shared()
240 assert_eq!(rx.recv().unwrap(), 1); in smoke_threads()
271 rx.recv().unwrap(); in port_gone_concurrent()
[all …]
|
| D | after.rs | 34 recv(r) -> _ => panic!(), in fire()
39 recv(r) -> _ => panic!(), in fire()
40 recv(after(ms(200))) -> _ => {} in fire()
92 fn recv() { in recv() function
96 let fired = r.recv().unwrap(); in recv()
137 recv(r1) -> _ => {} in recv_two()
138 recv(r2) -> _ => {} in recv_two()
143 recv(r1) -> _ => {} in recv_two()
144 recv(r2) -> _ => {} in recv_two()
154 recv(after(ms(50))) -> _ => {} in recv_race()
[all …]
|
| D | array.rs | 26 assert_eq!(r.recv(), Ok(8)); in smoke()
70 r.recv().unwrap(); in len_empty_full()
101 fn recv() { in recv() function
106 assert_eq!(r.recv(), Ok(7)); in recv()
108 assert_eq!(r.recv(), Ok(8)); in recv()
110 assert_eq!(r.recv(), Ok(9)); in recv()
111 assert_eq!(r.recv(), Err(RecvError)); in recv()
161 assert_eq!(r.recv(), Ok(3)); in try_send()
183 assert_eq!(r.recv(), Ok(7)); in send()
184 assert_eq!(r.recv(), Ok(8)); in send()
[all …]
|
| D | zero.rs | 46 scope.spawn(|_| r.recv().unwrap()); in len_empty_full()
79 fn recv() { in recv() function
84 assert_eq!(r.recv(), Ok(7)); in recv()
86 assert_eq!(r.recv(), Ok(8)); in recv()
88 assert_eq!(r.recv(), Ok(9)); in recv()
89 assert_eq!(r.recv(), Err(RecvError)); in recv()
136 assert_eq!(r.recv(), Ok(8)); in try_send()
156 assert_eq!(r.recv(), Ok(7)); in send()
157 assert_eq!(r.recv(), Ok(8)); in send()
158 assert_eq!(r.recv(), Ok(9)); in send()
[all …]
|
| D | list.rs | 26 assert_eq!(r.recv(), Ok(8)); in smoke()
59 r.recv().unwrap(); in len_empty_full()
90 fn recv() { in recv() function
95 assert_eq!(r.recv(), Ok(7)); in recv()
97 assert_eq!(r.recv(), Ok(8)); in recv()
99 assert_eq!(r.recv(), Ok(9)); in recv()
100 assert_eq!(r.recv(), Err(RecvError)); in recv()
197 assert_eq!(r.recv(), Ok(1)); in recv_after_disconnect()
198 assert_eq!(r.recv(), Ok(2)); in recv_after_disconnect()
199 assert_eq!(r.recv(), Ok(3)); in recv_after_disconnect()
[all …]
|
| /external/rust/crates/crossbeam-channel/benches/ |
| D | crossbeam.rs | 24 r.recv().unwrap(); in oneshot()
33 r.recv().unwrap(); in inout()
48 while r1.recv().is_ok() { in par_inout()
51 r.recv().unwrap(); in par_inout()
63 r2.recv().unwrap(); in par_inout()
80 while r1.recv().is_ok() { in spsc()
91 r.recv().unwrap(); in spsc()
93 r2.recv().unwrap(); in spsc()
111 while r1.recv().is_ok() { in spmc()
113 r.recv().unwrap(); in spmc()
[all …]
|
| /external/rust/crates/futures/tests/ |
| D | buffer_unordered.rs | 23 rx2.recv().unwrap(); in works()
38 let o1 = rx3.recv().unwrap(); in works()
39 let o2 = rx3.recv().unwrap(); in works()
40 let o3 = rx3.recv().unwrap(); in works()
41 let o4 = rx3.recv().unwrap(); in works()
45 assert_eq!(rx4.recv(), Ok(1)); in works()
47 assert_eq!(rx4.recv(), Ok(3)); in works()
50 assert_eq!(rx4.recv(), Ok(2)); in works()
52 assert_eq!(rx4.recv(), Ok(4)); in works()
54 let o5 = rx3.recv().unwrap(); in works()
[all …]
|
| D | eventual.rs | 17 assert_eq!(rx.recv(), Ok((1, 2))); in join1()
18 assert!(rx.recv().is_err()); in join1()
31 assert_eq!(rx.recv(), Ok((1, 2))); in join2()
32 assert!(rx.recv().is_err()); in join2()
43 assert_eq!(rx.recv(), Ok(1)); in join3()
44 assert!(rx.recv().is_err()); in join3()
56 assert!(rx.recv().is_ok()); in join4()
58 assert!(rx.recv().is_err()); in join4()
74 assert_eq!(rx.recv(), Ok(((1, 2), 3))); in join5()
75 assert!(rx.recv().is_err()); in join5()
[all …]
|
| D | eager_drop.rs | 15 assert!(rx1.recv().is_err()); in map_ok()
20 rx2.recv().unwrap(); in map_ok()
37 assert!(rx1.recv().is_err()); in map_err()
42 rx2.recv().unwrap(); in map_err()
79 assert!(rx1.recv().is_err()); // tx1 should have been dropped in then_drops_eagerly()
87 rx2.recv().unwrap(); in then_drops_eagerly()
103 assert!(rx1.recv().is_err()); // tx1 should have been dropped in and_then_drops_eagerly()
111 rx2.recv().unwrap(); in and_then_drops_eagerly()
127 assert!(rx1.recv().is_err()); // tx1 should have been dropped in or_else_drops_eagerly()
135 rx2.recv().unwrap(); in or_else_drops_eagerly()
|
| /external/rust/crates/tokio/tests/ |
| D | sync_mpsc.rs | 38 let val = rx.recv().await; in send_recv_with_buffer()
41 let val = rx.recv().await; in send_recv_with_buffer()
44 let val = rx.recv().await; in send_recv_with_buffer()
72 rx.recv().await.unwrap(); in reserve_disarm()
111 assert_eq!(Some(1), rx.recv().await); in async_send_recv_with_buffer()
112 assert_eq!(Some(2), rx.recv().await); in async_send_recv_with_buffer()
113 assert_eq!(None, rx.recv().await); in async_send_recv_with_buffer()
136 assert!(rx.recv().await.is_some()); in start_send_past_cap()
145 assert!(rx.recv().await.is_none()); in start_send_past_cap()
162 assert_eq!(rx.recv().await, Some(1)); in send_recv_unbounded()
[all …]
|
| D | sync_broadcast.rs | 96 let mut recv = task::spawn(rx.recv()); in send_recv_bounded() localVariable
98 assert_pending!(recv.poll()); in send_recv_bounded()
102 assert!(recv.is_woken()); in send_recv_bounded()
103 let val = assert_ready_ok!(recv.poll()); in send_recv_bounded()
112 let mut recv1 = task::spawn(rx1.recv()); in send_two_recv_bounded()
113 let mut recv2 = task::spawn(rx2.recv()); in send_two_recv_bounded()
130 let mut recv1 = task::spawn(rx1.recv()); in send_two_recv_bounded()
131 let mut recv2 = task::spawn(rx2.recv()); in send_two_recv_bounded()
150 let mut recv = Box::pin(rx.recv()); in change_tasks() localVariable
152 let mut task1 = task::spawn(&mut recv); in change_tasks()
[all …]
|
| /external/rust/crates/tokio/src/sync/tests/ |
| D | loom_broadcast.rs | 35 match rx.recv().await { in broadcast_send()
58 let v = assert_ok!(rx1.recv().await); in broadcast_two()
61 let v = assert_ok!(rx1.recv().await); in broadcast_two()
64 match assert_err!(rx1.recv().await) { in broadcast_two()
73 let v = assert_ok!(rx2.recv().await); in broadcast_two()
76 let v = assert_ok!(rx2.recv().await); in broadcast_two()
79 match assert_err!(rx2.recv().await) { in broadcast_two()
106 match rx1.recv().await { in broadcast_wrap()
122 match rx2.recv().await { in broadcast_wrap()
152 let v = assert_ok!(rx1.recv().await); in drop_rx()
[all …]
|
| /external/rust/crates/tokio/src/sync/ |
| D | watch.rs | 448 let (send, mut recv) = crate::sync::watch::channel(0i32); in watch_spurious_wakeup()
457 recv.changed().now_or_never(); in watch_spurious_wakeup()
461 recv.changed().now_or_never(); in watch_spurious_wakeup()
462 recv.changed().now_or_never(); in watch_spurious_wakeup()
463 recv in watch_spurious_wakeup()
468 let mut recv = recv_thread.join().unwrap(); in watch_spurious_wakeup() localVariable
473 recv.changed().now_or_never(); in watch_spurious_wakeup()
482 let (send, mut recv) = crate::sync::watch::channel(0i32); in watch_borrow()
485 assert!(recv.borrow().eq(&0)); in watch_borrow()
495 recv.changed().now_or_never(); in watch_borrow()
[all …]
|
| /external/starlark-go/starlark/ |
| D | library.go | 144 func builtinAttr(recv Value, name string, methods map[string]*Builtin) (Value, error) {
149 return b.BindReceiver(recv), nil
1237 recv := b.Receiver().(*Dict)
1238 k, ok := recv.ht.first()
1242 v, _, err := recv.Delete(k)
1297 recv := b.Receiver().(*List)
1298 if err := recv.checkMutable("append to"); err != nil {
1301 recv.elems = append(recv.elems, object)
1318 recv := b.Receiver().(*List)
1323 if err := recv.checkMutable("extend"); err != nil {
[all …]
|
| /external/webrtc/pc/ |
| D | rtp_media_utils_unittest.cc | 37 bool recv = RtpTransceiverDirectionHasRecv(direction); in TEST_P() local
39 EXPECT_EQ(direction, RtpTransceiverDirectionFromSendRecv(send, recv)); in TEST_P()
47 bool recv = RtpTransceiverDirectionHasRecv(direction); in TEST_P() local
49 EXPECT_EQ(RtpTransceiverDirectionFromSendRecv(recv, send), in TEST_P()
83 bool recv = std::get<1>(GetParam()); in TEST_P() local
86 RtpTransceiverDirectionWithRecvSet(direction, recv); in TEST_P()
90 EXPECT_EQ(recv, RtpTransceiverDirectionHasRecv(result)); in TEST_P()
|
| D | rtp_media_utils.cc | 18 bool recv) { in RtpTransceiverDirectionFromSendRecv() argument
19 if (send && recv) { in RtpTransceiverDirectionFromSendRecv()
21 } else if (send && !recv) { in RtpTransceiverDirectionFromSendRecv()
23 } else if (!send && recv) { in RtpTransceiverDirectionFromSendRecv()
65 bool recv) { in RtpTransceiverDirectionWithRecvSet() argument
67 RtpTransceiverDirectionHasSend(direction), recv); in RtpTransceiverDirectionWithRecvSet()
|
| /external/rust/crates/tokio/tests/support/ |
| D | mpsc_stream.rs | 9 recv: UnboundedReceiver<T>, field
14 Pin::into_inner(self).recv.poll_recv(cx) in poll_next()
21 let stream = UnboundedStream { recv: rx }; in unbounded_channel_stream()
27 recv: Receiver<T>, field
32 Pin::into_inner(self).recv.poll_recv(cx) in poll_next()
39 let stream = BoundedStream { recv: rx }; in channel_stream()
|
| /external/llvm-project/clang/test/Analysis/ |
| D | block-in-critical-section.cpp | 29 void recv() {} in recv() function
47 recv(); // expected-warning {{Call to blocking function 'recv' inside of critical section}} in testBlockInCriticalSectionWithStdMutex()
57 recv(); // expected-warning {{Call to blocking function 'recv' inside of critical section}} in testBlockInCriticalSectionWithPthreadMutex()
65 recv(); // expected-warning {{Call to blocking function 'recv' inside of critical section}} in testBlockInCriticalSectionWithPthreadMutex()
75 recv(); // expected-warning {{Call to blocking function 'recv' inside of critical section}} in testBlockInCriticalSectionC11Locks()
83 recv(); // expected-warning {{Call to blocking function 'recv' inside of critical section}} in testBlockInCriticalSectionC11Locks()
91 recv(); // expected-warning {{Call to blocking function 'recv' inside of critical section}} in testBlockInCriticalSectionC11Locks()
|
| /external/protobuf/ruby/src/main/java/com/google/protobuf/jruby/ |
| D | RubyEnum.java | 51 public static IRubyObject lookup(ThreadContext context, IRubyObject recv, IRubyObject number) { in lookup() argument
52 …RubyEnumDescriptor rubyEnumDescriptorescriptor = (RubyEnumDescriptor) getDescriptor(context, recv); in lookup()
67 public static IRubyObject resolve(ThreadContext context, IRubyObject recv, IRubyObject name) { in resolve() argument
68 …RubyEnumDescriptor rubyEnumDescriptorescriptor = (RubyEnumDescriptor) getDescriptor(context, recv); in resolve()
83 public static IRubyObject getDescriptor(ThreadContext context, IRubyObject recv) { in getDescriptor() argument
84 return ((RubyModule) recv).getInstanceVariable(Utils.DESCRIPTOR_INSTANCE_VAR); in getDescriptor()
|