| /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} : (…
|