/external/rust/crates/tokio/tests/ |
D | sync_broadcast.rs | 112 let mut recv1 = task::spawn(rx1.recv()); in send_two_recv_bounded() localVariable 115 assert_pending!(recv1.poll()); in send_two_recv_bounded() 120 assert!(recv1.is_woken()); in send_two_recv_bounded() 123 let val1 = assert_ready_ok!(recv1.poll()); in send_two_recv_bounded() 128 drop((recv1, recv2)); in send_two_recv_bounded() 130 let mut recv1 = task::spawn(rx1.recv()); in send_two_recv_bounded() localVariable 133 assert_pending!(recv1.poll()); in send_two_recv_bounded() 137 assert!(recv1.is_woken()); in send_two_recv_bounded() 140 let val1 = assert_ready_ok!(recv1.poll()); in send_two_recv_bounded() 172 let mut recv1 = task::spawn(rx1.recv()); in send_slow_rx() localVariable [all …]
|
/external/tensorflow/tensorflow/core/common_runtime/ |
D | constant_folding_test.cc | 411 auto recv1 = ops::_Recv(s.WithOpName("recv1"), DT_FLOAT, "recv1", "sender", in TEST_F() local 413 auto c1 = ops::Const<int>(s.WithControlDependencies(recv1), 2); in TEST_F() 428 Node* recv1 = index.at("recv1"); in TEST_F() local 439 EXPECT_TRUE(e->src() == recv1 || e->src() == recv2) << e->src()->name(); in TEST_F() 450 Output recv1 = ops::_Recv(s.WithOpName("recv1"), DT_FLOAT, "recv1", in TEST_F() local 452 auto shape_n = ops::ShapeN(s.WithOpName("shape_n"), {recv0, recv1}); in TEST_F() 454 auto size = ops::Size(s.WithOpName("size"), recv1); in TEST_F() 471 Node* recv1 = orig_index.at("recv1"); in TEST_F() local 480 map[recv1->name()].push_back(ps1); in TEST_F() 509 EXPECT_TRUE(e->src() == recv0 || e->src() == recv1 || e->src() == recv2) in TEST_F() [all …]
|
/external/tensorflow/tensorflow/compiler/jit/ |
D | encapsulate_subgraphs_pass_test.cc | 1052 Node* recv1 = RecvAtHost( in TEST() local 1055 Node* e = Binary(ops::NodeOut(recv1, 0), ops::NodeOut(recv1, 1), in TEST() 1146 Node* recv1 = RecvAtHost( in TEST() local 1149 Node* e = Binary(ops::NodeOut(recv1, 0), ops::NodeOut(recv1, 1), in TEST() 1152 .WithControlInputs({recv1}) in TEST() 1180 .WithControlInputs({recv1, send1, recv2, send2}), in TEST() 1314 Node* recv1 = RecvAtHost( in TEST() local 1317 Node* e = Binary(ops::NodeOut(recv1, 0), ops::NodeOut(recv1, 1), in TEST() 1320 .WithControlInputs({recv1}) in TEST() 1328 b2.opts().WithName("F1_sequencer").WithControlInputs({recv1, send1}), in TEST() [all …]
|
/external/webrtc/media/sctp/ |
D | sctp_transport_unittest.cc | 245 SctpFakeDataReceiver recv1; in TEST_F() local 248 CreateTransport(&fake_dtls1, &recv1)); in TEST_F() 268 EXPECT_TRUE_WAIT(ReceivedData(&recv1, 1, "meow"), kDefaultTimeout); in TEST_F() 306 EXPECT_TRUE_WAIT(ReceivedData(&recv1, 1, "meow? rawr!"), kDefaultTimeout); in TEST_F() 316 SctpFakeDataReceiver recv1; in TEST_F() local 321 CreateTransport(&black_hole, &recv1)); in TEST_F() 345 EXPECT_TRUE_WAIT(ReceivedData(&recv1, 1, "bar"), kDefaultTimeout); in TEST_F() 378 SctpFakeDataReceiver recv1; in TEST_F() local 381 CreateTransport(&fake_dtls1, &recv1)); in TEST_F() 403 EXPECT_TRUE_WAIT(ReceivedData(&recv1, 1, "bar"), kDefaultTimeout); in TEST_F()
|
/external/rust/crates/crossbeam-channel/tests/ |
D | golang.rs | 783 fn recv1(c: Chan<i32>) { in recv1() function 830 send1(recv1); in main() 831 send2(recv1); in main() 832 send3(recv1); in main() 923 let recv1 = Arc::new(Mutex::new(false)); in test_chan() localVariable 924 go!(c, recv1, { in test_chan() 926 *recv1.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 | 363 auto recv1 = in TEST_F() local 365 auto id1 = Identity(scope_b_.WithOpName("A1/_5"), recv1); in TEST_F()
|
/external/tensorflow/tensorflow/core/grappler/costs/ |
D | virtual_scheduler_test.cc | 482 NodeDef recv1; in TEST_F() local 486 NodeSetUp("Recv1", kRecv, kCPU0, 2003, &recv1); in TEST_F() 501 manager.AddNode(&recv1); in TEST_F()
|
/external/tensorflow/tensorflow/compiler/mlir/xla/tests/ |
D | legalize-tf-communication.mlir | 244 …%1 = "tf._XlaHostComputeMlir"(%0) {recv_key = "recv1", send_key = "send1", tpu_core = 0 : i64} : (…
|