| /external/tensorflow/tensorflow/core/common_runtime/ |
| D | executor_test.cc | 148 auto in0 = test::graph::Recv(g.get(), "a", "float", ALICE, 1, BOB); in TEST_F()
149 auto in1 = test::graph::Recv(g.get(), "b", "float", ALICE, 1, BOB); in TEST_F()
162 rendez_->Recv(Key(BOB, kIncarnation, ALICE, "c"), args, &out, &is_dead)); in TEST_F()
176 auto v = test::graph::Recv(g.get(), "a", "float", ALICE, 1, BOB); in TEST_F()
192 rendez_->Recv(Key(BOB, kIncarnation, ALICE, "b"), args, &out, &is_dead)); in TEST_F()
206 auto in = test::graph::Recv(g, "a", "float", ALICE, 1, BOB); in BuildTree()
242 rendez_->Recv(Key(BOB, kIncarnation, ALICE, "b"), args, &out, &is_dead)); in TEST_F()
274 TF_ASSERT_OK(rendez->Recv(Key(ALICE, kIncarnation, BOB, "out"), args, &out, in TEST_F()
285 auto in0 = test::graph::Recv(g.get(), "a", "float", ALICE, 1, BOB); in TEST_F()
297 rendez_->Recv(Key(BOB, kIncarnation, ALICE, "c"), args, &out, &is_dead)); in TEST_F()
[all …]
|
| D | kernel_benchmark_testlib.cc | 168 TF_CHECK_OK(rendez_->Recv(parsed, Rendezvous::Args(), &unused, &is_dead)); in RunWithArgs()
185 TF_CHECK_OK(rendez_->Recv(parsed, Rendezvous::Args(), &unused, &is_dead)); in RunWithArgs()
|
| D | memory_types.cc | 135 static Node* Recv(Graph* g, const string& tensor_name, in Recv() function
189 recv = Recv(g, tensor_name, device_name, (item.dm == HOST_MEMORY), e); in EnsureMemoryTypes()
|
| /external/autotest/client/tests/netperf2/ |
| D | wait_before_data.patch | 118 @@ -5715,7 +5727,7 @@ Send Recv Send Recv usec/Tran
127 @@ -5777,6 +5789,8 @@ Send Recv Send Recv usec/Tran
163 @@ -8767,7 +8785,7 @@ Send Recv Send Recv\n\
172 @@ -10961,7 +10979,7 @@ Send Recv Send Recv\n\
181 @@ -11038,6 +11056,8 @@ Send Recv Send Recv\n\
190 @@ -12021,6 +12041,8 @@ Send Recv Send Recv\n\
|
| /external/tensorflow/tensorflow/core/framework/ |
| D | rendezvous_test.cc | 122 TF_ASSERT_OK(rendez_->Recv(KeyFoo(), args, &val, &is_dead)); in TEST_F()
135 TF_ASSERT_OK(rendez_->Recv(KeyFoo(), args, &val, &is_dead)); in TEST_F()
144 TF_ASSERT_OK(rendez_->Recv(KeyFoo(), args, &t, &is_dead)); in TEST_F()
152 TF_ASSERT_OK(rendez_->Recv(KeyBar(), args, &val, &val_dead)); in TEST_F()
231 TF_ASSERT_OK(rendez_->Recv(key_foo, args, &val, &val_dead)); in TEST_F()
245 Status status = rendez_->Recv(KeyFoo(), args, &val, &val_dead); in TEST_F()
261 Status status = rendez_->Recv(KeyFoo(), args, &val, &val_dead); in TEST_F()
272 errors::IsAborted(rendez_->Recv(KeyFoo(), args, &val, &val_dead))); in TEST_F()
324 TF_CHECK_OK(rendez->Recv(KeyFoo(), args, &val, &is_dead)); in BM_SendRecv()
346 TF_CHECK_OK(rendez->Recv(KeyFoo(), args, &foo, &is_dead)); in BM_PingPong()
[all …]
|
| D | rendezvous.h | 112 Status Recv(const ParsedKey& key, const Args& args, Tensor* val,
114 Status Recv(const ParsedKey& key, const Args& args, Tensor* val,
|
| D | rendezvous.cc | 117 Status Rendezvous::Recv(const ParsedKey& key, const Args& recv_args, in Recv() function in tensorflow::Rendezvous
143 Status Rendezvous::Recv(const ParsedKey& key, const Args& args, Tensor* val, in Recv() function in tensorflow::Rendezvous
146 return Recv(key, args, val, is_dead, no_timeout); in Recv()
|
| /external/flatbuffers/tests/MyGame/Example/ |
| D | MonsterStorage_grpc.go | 53 Recv() (*Monster, error) methodSpec
61 func (x *monsterStorageRetrieveClient) Recv() (*Monster, error) { func
106 Recv() (*Stat, error) methodSpec
118 func (x *monsterStorageGetMinMaxHitPointsClient) Recv() (*Stat, error) { func
178 Recv() (* Monster, error) methodSpec
187 func (x *monsterStorageGetMaxHitPointServer) Recv() (*Monster, error) { func
204 Recv() (* Monster, error) methodSpec
216 func (x *monsterStorageGetMinMaxHitPointsServer) Recv() (*Monster, error) { func
|
| /external/tensorflow/tensorflow/core/kernels/ |
| D | sendrecv_ops_test.cc | 47 test::graph::Recv(g, "T", "float", "/cpu:0", 1, "/cpu:0"); in Send()
51 static Graph* Recv() { in Recv() function
53 test::graph::Recv(g, "T", "float", "/cpu:0", 1, "/cpu:0"); in Recv()
68 test::Benchmark("cpu", Recv(), nullptr, nullptr, new DummyRendezvous) in BM_Recv()
|
| /external/golang-protobuf/protoc-gen-go/testdata/grpc/ |
| D | grpc.pb.go | 232 Recv() (*StreamMsg, error) methodSpec
240 func (x *testDownstreamClient) Recv() (*StreamMsg, error) { func
293 Recv() (*StreamMsg2, error) methodSpec
305 func (x *testBidiClient) Recv() (*StreamMsg2, error) { func
373 Recv() (*StreamMsg, error) methodSpec
385 func (x *testUpstreamServer) Recv() (*StreamMsg, error) { func
399 Recv() (*StreamMsg, error) methodSpec
411 func (x *testBidiServer) Recv() (*StreamMsg, error) { func
|
| /external/tensorflow/tensorflow/core/distributed_runtime/rpc/ |
| D | rpc_rendezvous_mgr_test.cc | 123 EXPECT_TRUE(errors::IsAborted(rendez->Recv(key, args, &val, &val_dead))); in TEST_F()
137 EXPECT_TRUE(errors::IsAborted(rendez->Recv(key, args, &val, &val_dead))); in TEST_F()
155 EXPECT_TRUE(errors::IsAborted(rendez->Recv(key, args, &val, &val_dead))); in TEST_F()
|
| /external/webrtc/webrtc/base/ |
| D | asyncsocket.cc | 67 int AsyncSocketAdapter::Recv(void* pv, size_t cb) { in Recv() function in rtc::AsyncSocketAdapter
68 return socket_->Recv(pv, cb); in Recv()
|
| D | socketadapters.cc | 62 int BufferedReadAdapter::Recv(void *pv, size_t cb) { in Recv() function in rtc::BufferedReadAdapter
83 int res = AsyncSocketAdapter::Recv(pv, cb); in Recv()
116 int len = socket_->Recv(buffer_ + data_len_, buffer_size_ - data_len_); in OnReadEvent()
877 int LoggingSocketAdapter::Recv(void *pv, size_t cb) { in Recv() function in rtc::LoggingSocketAdapter
878 int res = AsyncSocketAdapter::Recv(pv, cb); in Recv()
|
| D | socketadapters.h | 37 int Recv(void* pv, size_t cb) override;
225 int Recv(void* pv, size_t cb) override;
|
| D | virtualsocket_unittest.cc | 466 EXPECT_EQ(-1, b->Recv(buffer, 10)); in CloseTest()
533 result = b->Recv(recv_buffer + recv_pos, 500); in TcpSendTest()
548 result = b->Recv(recv_buffer + recv_pos, kDataSize - recv_pos); in TcpSendTest()
562 result = b->Recv(recv_buffer + recv_pos, kDataSize - recv_pos); in TcpSendTest()
581 result = b->Recv(recv_buffer + recv_pos, kDataSize - recv_pos); in TcpSendTest()
628 EXPECT_EQ(1, b->Recv(buffer, sizeof(buffer))); in TcpSendsPacketsInOrderTest()
648 EXPECT_EQ(1, b->Recv(buffer, sizeof(buffer))); in TcpSendsPacketsInOrderTest()
|
| D | openssladapter.cc | 126 int result = socket->Recv(out, outl); in socket_read()
532 OpenSSLAdapter::Recv(void* pv, size_t cb) { in Recv() function in rtc::OpenSSLAdapter
537 return AsyncSocketAdapter::Recv(pv, cb); in Recv()
589 int ret = Recv(pv, cb); in RecvFrom()
|
| D | macasyncsocket.h | 44 int Recv(void* buffer, size_t length) override;
|
| D | asyncsocket.h | 59 int Recv(void* pv, size_t cb) override;
|
| D | openssladapter.h | 40 int Recv(void* pv, size_t cb) override;
|
| D | socketstream.cc | 63 int result = socket_->Recv(buffer, buffer_len); in Read()
|
| /external/bcc/examples/networking/neighbor_sharing/ |
| D | README.txt | 40 Recv Send Send
49 Recv Send Send
|
| /external/tensorflow/tensorflow/compiler/tf2xla/kernels/ |
| D | sendrecv_ops.cc | 79 ctx->SetOutput(0, xla::Recv(ctx->builder(), shape_, channel)); in Compile()
|
| /external/webrtc/webrtc/p2p/base/ |
| D | pseudotcp_unittest.cc | 278 rcvd = remote_.Recv(block, sizeof(block)); in ReadData()
397 rcvd = receiver_->Recv(block, sizeof(block)); in ReadData()
513 rcvd = remote_.Recv(block, sizeof(block)); in ReadUntilIOPending()
|
| /external/tensorflow/tensorflow/core/kernels/data/ |
| D | single_threaded_executor_test.cc | 315 Node* x = test::graph::Recv(g, "x", "float", ALICE, 1, BOB);
316 Node* y = test::graph::Recv(g, "y", "float", ALICE, 1, BOB);
|
| /external/syzkaller/docs/linux/ |
| D | external_fuzzing_network.md | 43 Proto Recv-Q Send-Q Local Address Foreign Address State PID/Program name
62 Proto Recv-Q Send-Q Local Address Foreign Address State PID/Program name
|