| /external/rust/crates/tokio/tests/ |
| D | sync_broadcast.rs | 113 let mut recv2 = task::spawn(rx2.recv()); in send_two_recv_bounded() localVariable
116 assert_pending!(recv2.poll()); in send_two_recv_bounded()
121 assert!(recv2.is_woken()); in send_two_recv_bounded()
124 let val2 = assert_ready_ok!(recv2.poll()); in send_two_recv_bounded()
128 drop((recv1, recv2)); in send_two_recv_bounded()
131 let mut recv2 = task::spawn(rx2.recv()); in send_two_recv_bounded() localVariable
138 assert!(!recv2.is_woken()); in send_two_recv_bounded()
141 let val2 = assert_ready_ok!(recv2.poll()); in send_two_recv_bounded()
169 let mut recv2 = task::spawn(rx2.recv()); in send_slow_rx() localVariable
175 assert_pending!(recv2.poll()); in send_slow_rx()
[all …]
|
| /external/webrtc/media/sctp/ |
| D | sctp_transport_unittest.cc | 246 SctpFakeDataReceiver recv2; in TEST_F() local
250 CreateTransport(&fake_dtls2, &recv2)); in TEST_F()
317 SctpFakeDataReceiver recv2; in TEST_F() local
323 CreateTransport(&fake_dtls2, &recv2)); in TEST_F()
344 EXPECT_TRUE_WAIT(ReceivedData(&recv2, 1, "foo"), kDefaultTimeout); in TEST_F()
379 SctpFakeDataReceiver recv2; in TEST_F() local
383 CreateTransport(&fake_dtls2, &recv2)); in TEST_F()
402 EXPECT_TRUE_WAIT(ReceivedData(&recv2, 1, "foo"), kDefaultTimeout); in TEST_F()
|
| /external/tensorflow/tensorflow/compiler/jit/ |
| D | encapsulate_subgraphs_pass_test.cc | 1060 Node* recv2 = RecvAtHost( in TEST() local
1063 Node* g = Binary(e, ops::NodeOut(recv2, 0), in TEST()
1068 Node* h = Binary(ops::NodeOut(recv2, 1), e, in TEST()
1160 Node* recv2 = RecvAtHost( in TEST() local
1163 Node* g = Binary(e, ops::NodeOut(recv2, 0), in TEST()
1166 .WithControlInputs({recv2, e}) in TEST()
1169 Node* h = Binary(ops::NodeOut(recv2, 1), e, in TEST()
1180 .WithControlInputs({recv1, send1, recv2, send2}), in TEST()
1338 Node* recv2 = RecvAtHost( in TEST() local
1341 Node* h = Binary(recv2, ops::NodeOut(recv2, 1), in TEST()
[all …]
|
| /external/tensorflow/tensorflow/core/common_runtime/ |
| D | constant_folding_test.cc | 414 auto recv2 = ops::_Recv(s.WithOpName("recv2"), DT_FLOAT, "recv2", "sender", in TEST_F() local
416 auto c2 = ops::Const<int>(s.WithControlDependencies(recv2), 3); in TEST_F()
429 Node* recv2 = index.at("recv2"); in TEST_F() local
439 EXPECT_TRUE(e->src() == recv1 || e->src() == recv2) << e->src()->name(); in TEST_F()
455 auto recv2 = ops::_Recv(s.WithOpName("recv2"), DT_FLOAT, "recv2", "sender", in TEST_F() local
457 auto c = ops::Const<int>(s.WithControlDependencies(recv2), 3); in TEST_F()
489 Node* recv2 = index.at("recv2"); in TEST_F() local
509 EXPECT_TRUE(e->src() == recv0 || e->src() == recv1 || e->src() == recv2) in TEST_F()
|
| /external/rust/crates/crossbeam-channel/tests/ |
| D | golang.rs | 787 fn recv2(c: Chan<i32>) { in recv2() function
833 send1(recv2); in main()
834 send2(recv2); in main()
835 send3(recv2); in main()
929 let recv2 = Arc::new(Mutex::new(false)); in test_chan() localVariable
930 go!(c, recv2, { in test_chan()
932 *recv2.lock().unwrap() = true; in test_chan()
937 if *recv1.lock().unwrap() || *recv2.lock().unwrap() { in test_chan()
|
| /external/tensorflow/tensorflow/core/graph/ |
| D | graph_partition_test.cc | 366 auto recv2 = in TEST_F() local
369 Combine(scope_b_.WithOpName("B2"), recv2, b1); in TEST_F()
|
| /external/tensorflow/tensorflow/core/grappler/costs/ |
| D | virtual_scheduler_test.cc | 483 NodeDef recv2; in TEST_F() local
487 NodeSetUp("Recv2", kRecv, kCPU1, 2004, &recv2); in TEST_F()
502 manager.AddNode(&recv2); in TEST_F()
|