| /external/tensorflow/tensorflow/core/common_runtime/ |
| D | executor_test.cc | 160 auto in0 = test::graph::Recv(g.get(), "a", "float", ALICE, 1, BOB); in TEST_F()
161 auto in1 = test::graph::Recv(g.get(), "b", "float", ALICE, 1, BOB); in TEST_F()
174 rendez_->Recv(Key(BOB, kIncarnation, ALICE, "c"), args, &out, &is_dead)); in TEST_F()
188 auto v = test::graph::Recv(g.get(), "a", "float", ALICE, 1, BOB); in TEST_F()
204 rendez_->Recv(Key(BOB, kIncarnation, ALICE, "b"), args, &out, &is_dead)); in TEST_F()
218 auto in = test::graph::Recv(g, "a", "float", ALICE, 1, BOB); in BuildTree()
254 rendez_->Recv(Key(BOB, kIncarnation, ALICE, "b"), args, &out, &is_dead)); in TEST_F()
286 TF_ASSERT_OK(rendez->Recv(Key(ALICE, kIncarnation, BOB, "out"), args, &out, in TEST_F()
297 auto in0 = test::graph::Recv(g.get(), "a", "float", ALICE, 1, BOB); in TEST_F()
309 rendez_->Recv(Key(BOB, kIncarnation, ALICE, "c"), args, &out, &is_dead)); in TEST_F()
[all …]
|
| D | kernel_benchmark_testlib.cc | 189 TF_CHECK_OK(rendez_->Recv(parsed, Rendezvous::Args(), &unused, &is_dead)); in RunWithRendezvousArgs()
207 TF_CHECK_OK(rendez_->Recv(parsed, Rendezvous::Args(), &unused, &is_dead)); in RunWithRendezvousArgs()
241 TF_CHECK_OK(rendez_->Recv(parsed, Rendezvous::Args(), &unused, &is_dead)); in RunWithRendezvousArgs()
258 TF_CHECK_OK(rendez_->Recv(parsed, Rendezvous::Args(), &unused, &is_dead)); in RunWithRendezvousArgs()
|
| D | memory_types.cc | 137 static Node* Recv(Graph* g, const string& tensor_name, in Recv() function
193 recv = Recv(g, tensor_name, device_name, (item.dm == HOST_MEMORY), e); in EnsureMemoryTypes()
|
| /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()
66 test::Benchmark("cpu", Recv(), nullptr, nullptr, new DummyRendezvous, "", in BM_Recv()
|
| /external/tensorflow/tensorflow/core/framework/ |
| D | rendezvous_test.cc | 124 TF_ASSERT_OK(rendez_->Recv(KeyFoo(), args, &val, &is_dead)); in TEST_F()
137 TF_ASSERT_OK(rendez_->Recv(KeyFoo(), args, &val, &is_dead)); in TEST_F()
146 TF_ASSERT_OK(rendez_->Recv(KeyFoo(), args, &t, &is_dead)); in TEST_F()
154 TF_ASSERT_OK(rendez_->Recv(KeyBar(), args, &val, &val_dead)); in TEST_F()
165 auto s = rendez_->Recv(KeyFoo(), args, &val, &is_dead); in TEST_F()
184 auto s = rendez_->Recv(KeyFoo(), args, &val, &is_dead); in TEST_F()
206 TF_ASSERT_OK(rendez_->Recv(KeyFoo(), args, &val, &is_dead)); in TEST_F()
353 TF_ASSERT_OK(rendez_->Recv(key_foo, args, &val, &val_dead)); in TEST_F()
367 Status status = rendez_->Recv(KeyFoo(), args, &val, &val_dead); in TEST_F()
383 Status status = rendez_->Recv(KeyFoo(), args, &val, &val_dead); in TEST_F()
[all …]
|
| D | rendezvous.cc | 119 Status RendezvousInterface::Recv(const ParsedKey& key, const Args& recv_args, in Recv() function in tensorflow::RendezvousInterface
145 Status RendezvousInterface::Recv(const ParsedKey& key, const Args& args, in Recv() function in tensorflow::RendezvousInterface
148 return Recv(key, args, val, is_dead, no_timeout); in Recv()
|
| D | rendezvous.h | 108 Status Recv(const ParsedKey& key, const Args& args, Tensor* val,
110 Status Recv(const ParsedKey& key, const Args& args, Tensor* val,
|
| /external/rust/crates/tokio/src/sync/ |
| D | broadcast.rs | 369 struct Recv<'a, T> { struct
377 unsafe impl<'a, T: Send> Send for Recv<'a, T> {} argument
378 unsafe impl<'a, T: Send> Sync for Recv<'a, T> {} implementation
878 let fut = Recv::new(self); in recv()
951 impl<'a, T> Recv<'a, T> { impl
952 fn new(receiver: &'a mut Receiver<T>) -> Recv<'a, T> { in new()
953 Recv { in new()
977 impl<'a, T> Future for Recv<'a, T> implementation
997 impl<'a, T> Drop for Recv<'a, T> { implementation
|
| /external/golang-protobuf/protoc-gen-go/testdata/grpc/ |
| D | grpc.pb.go | 236 Recv() (*StreamMsg, error) methodSpec
244 func (x *testDownstreamClient) Recv() (*StreamMsg, error) { func
297 Recv() (*StreamMsg2, error) methodSpec
309 func (x *testBidiClient) Recv() (*StreamMsg2, error) { func
394 Recv() (*StreamMsg, error) methodSpec
406 func (x *testUpstreamServer) Recv() (*StreamMsg, error) { func
420 Recv() (*StreamMsg, error) methodSpec
432 func (x *testBidiServer) Recv() (*StreamMsg, error) { func
|
| /external/llvm-project/lldb/unittests/debugserver/ |
| D | RNBSocketTest.cpp | 42 std::string Recv(&buffer[0], read_size); in ServerCallbackv4() local
43 if (Recv != hello) in ServerCallbackv4()
138 std::string Recv(&buffer[0], read_size); in TestSocketConnect() local
139 if (Recv != hello) { in TestSocketConnect()
|
| /external/tensorflow/tensorflow/core/distributed_runtime/rpc/ |
| D | rpc_rendezvous_mgr_test.cc | 176 EXPECT_TRUE(errors::IsAborted(rendez->Recv(key, args, &val, &val_dead))); in TEST_F()
190 EXPECT_TRUE(errors::IsAborted(rendez->Recv(key, args, &val, &val_dead))); in TEST_F()
213 EXPECT_TRUE(errors::IsCancelled(rendez->Recv(key, args, &val, &val_dead))); in TEST_F()
238 TF_ASSERT_OK(rendez->Recv(key, args, &val, &val_dead)); in TEST_F()
304 TF_ASSERT_OK(rendez->Recv(key, args, &val, &val_dead)); in TEST_F()
|
| /external/webrtc/rtc_base/ |
| D | async_socket.cc | 67 int AsyncSocketAdapter::Recv(void* pv, size_t cb, int64_t* timestamp) { in Recv() function in rtc::AsyncSocketAdapter
68 return socket_->Recv(pv, cb, timestamp); in Recv()
|
| D | openssl_adapter.cc | 86 int result = socket->Recv(out, outl, nullptr); in socket_read()
584 int OpenSSLAdapter::Recv(void* pv, size_t cb, int64_t* timestamp) { in Recv() function in rtc::OpenSSLAdapter
587 return AsyncSocketAdapter::Recv(pv, cb, timestamp); in Recv()
638 int ret = Recv(pv, cb, timestamp); in RecvFrom()
|
| D | virtual_socket_unittest.cc | 501 EXPECT_EQ(-1, b->Recv(buffer, 10, nullptr)); in CloseTest()
570 result = b->Recv(recv_buffer + recv_pos, 500, nullptr); in TcpSendTest()
585 result = b->Recv(recv_buffer + recv_pos, kDataSize - recv_pos, nullptr); in TcpSendTest()
599 result = b->Recv(recv_buffer + recv_pos, kDataSize - recv_pos, nullptr); in TcpSendTest()
618 result = b->Recv(recv_buffer + recv_pos, kDataSize - recv_pos, nullptr); in TcpSendTest()
665 EXPECT_EQ(1, b->Recv(buffer, sizeof(buffer), nullptr)); in TcpSendsPacketsInOrderTest()
685 EXPECT_EQ(1, b->Recv(buffer, sizeof(buffer), nullptr)); in TcpSendsPacketsInOrderTest()
|
| D | socket_adapters.cc | 50 int BufferedReadAdapter::Recv(void* pv, size_t cb, int64_t* timestamp) { in Recv() function in rtc::BufferedReadAdapter
71 int res = AsyncSocketAdapter::Recv(pv, cb, timestamp); in Recv()
105 socket_->Recv(buffer_ + data_len_, buffer_size_ - data_len_, nullptr); in OnReadEvent()
|
| D | async_socket.h | 61 int Recv(void* pv, size_t cb, int64_t* timestamp) override;
|
| D | socket.h | 96 virtual int Recv(void* pv, size_t cb, int64_t* timestamp) = 0;
|
| /external/bcc/examples/networking/neighbor_sharing/ |
| D | README.txt | 40 Recv Send Send
49 Recv Send Send
|
| /external/tensorflow/tensorflow/core/ops/compat/ops_history_v1/ |
| D | Recv.pbtxt | 2 name: "Recv"
|
| /external/tensorflow/tensorflow/core/ops/compat/ops_history_v2/ |
| D | Recv.pbtxt | 2 name: "Recv"
|
| /external/crosvm/base/src/ |
| D | tube.rs | 27 Recv(io::Error), enumerator
84 self.socket.recv_as_vec_with_fds().map_err(Error::Recv)?; in recv()
|
| /external/tensorflow/tensorflow/compiler/tf2xla/kernels/ |
| D | sendrecv_ops.cc | 79 ctx->SetOutput(0, xla::Recv(ctx->builder(), shape_, channel)); in Compile()
|
| /external/tensorflow/tensorflow/core/api_def/base_api/ |
| D | api_def_Recv.pbtxt | 2 graph_op_name: "Recv"
|
| /external/webrtc/test/network/ |
| D | fake_network_socket_server.cc | 53 int Recv(void* pv, size_t cb, int64_t* timestamp) override;
177 int FakeNetworkSocket::Recv(void* pv, size_t cb, int64_t* timestamp) { in Recv() function in webrtc::test::FakeNetworkSocket
|