| /external/tensorflow/tensorflow/contrib/ignite/kernels/dataset/ |
| D | ignite_dataset_iterator.cc | 46 client_ = std::unique_ptr<Client>(p_client); in IgniteDatasetIterator()
48 client_ = std::unique_ptr<Client>( in IgniteDatasetIterator()
132 if (!client_->IsConnected()) { in EstablishConnection()
133 TF_RETURN_IF_ERROR(client_->Connect()); in EstablishConnection()
137 Status disconnect_status = client_->Disconnect(); in EstablishConnection()
151 TF_RETURN_IF_ERROR(client_->WriteInt(kCloseConnectionReqLength)); in CloseConnection()
152 TF_RETURN_IF_ERROR(client_->WriteShort(kCloseConnectionOpcode)); in CloseConnection()
153 TF_RETURN_IF_ERROR(client_->WriteLong(0)); // Request ID in CloseConnection()
154 TF_RETURN_IF_ERROR(client_->WriteLong(cursor_id_)); // Resource ID in CloseConnection()
157 TF_RETURN_IF_ERROR(client_->ReadInt(&res_len)); in CloseConnection()
[all …]
|
| /external/tensorflow/tensorflow/compiler/xla/tests/ |
| D | deconstruct_tuple_test.cc | 48 client_->Execute(computation, arguments, &execution_options_) in ExecuteAndCheckTransfer()
50 TF_CHECK_OK(client_->Transfer(*global_data).status()); in ExecuteAndCheckTransfer()
62 auto result_status = client_->DeconstructTuple(*global_data); in TEST_F()
68 TF_ASSERT_OK_AND_ASSIGN(literal, client_->Transfer(*handles[0])); in TEST_F()
70 TF_ASSERT_OK_AND_ASSIGN(literal, client_->Transfer(*handles[1])); in TEST_F()
81 auto result_status1 = client_->DeconstructTuple(*global_data); in TEST_F()
83 auto result_status2 = client_->DeconstructTuple(*global_data); in TEST_F()
90 TF_ASSERT_OK_AND_ASSIGN(literal, client_->Transfer(*handles1[0])); in TEST_F()
92 TF_ASSERT_OK_AND_ASSIGN(literal, client_->Transfer(*handles1[1])); in TEST_F()
98 TF_ASSERT_OK_AND_ASSIGN(literal, client_->Transfer(*handles2[0])); in TEST_F()
[all …]
|
| D | deallocation_test.cc | 42 client_->Execute(computation, arguments, &execution_options_) in ExecuteAndCheckTransfer()
44 TF_CHECK_OK(client_->Transfer(*global_data).status()); in ExecuteAndCheckTransfer()
57 ASSERT_IS_OK(client_->Transfer(*global_data).status()); in TEST_F()
59 ASSERT_IS_OK(client_->Unregister(*global_data)); in TEST_F()
61 auto transfer_status = client_->Transfer(*global_data); in TEST_F()
72 ASSERT_IS_OK(client_->Unregister(*global_data)); in TEST_F()
74 auto transfer_status = client_->Transfer(*global_data); in TEST_F()
85 ASSERT_IS_OK(client_->Unregister(*global_data)); in TEST_F()
87 auto transfer_status = client_->Transfer(*global_data); in TEST_F()
99 ASSERT_IS_OK(client_->Unregister(*global_data)); in XLA_TEST_F()
[all …]
|
| D | replay_test.cc | 51 XlaComputation replayed = client_->LoadSnapshot(*module).ConsumeValueOrDie(); in TEST_F()
55 client_->GetComputationShape(computation).ConsumeValueOrDie(); in TEST_F()
57 client_->GetComputationShape(replayed).ConsumeValueOrDie(); in TEST_F()
63 client_ in TEST_F()
84 XlaComputation replayed = client_->LoadSnapshot(*module).ConsumeValueOrDie(); in XLA_TEST_F()
88 client_->GetComputationShape(computation).ConsumeValueOrDie(); in XLA_TEST_F()
90 client_->GetComputationShape(replayed).ConsumeValueOrDie(); in XLA_TEST_F()
96 client_->TransferToServer(LiteralUtil::CreateR0<int32>(2)) in XLA_TEST_F()
99 client_->TransferToServer(LiteralUtil::CreateR0<int32>(3)) in XLA_TEST_F()
102 client_ in XLA_TEST_F()
[all …]
|
| D | check_execution_arity_test.cc | 46 client_->TransferToServer(param_literal).ConsumeValueOrDie(); in TEST_F()
48 client_->TransferToServer(param_literal).ConsumeValueOrDie(); in TEST_F()
56 auto result_two_args = client_->Execute( in TEST_F()
61 client_->Execute(computation, {param0_data.get()}, &execution_options_); in TEST_F()
69 client_->Execute(computation, {}, &execution_options_); in TEST_F()
89 auto f32_data = client_->TransferToServer(f32_literal).ConsumeValueOrDie(); in XLA_TEST_F()
92 client_->TransferToServer(f32_4_literal).ConsumeValueOrDie(); in XLA_TEST_F()
94 auto u8_4_data = client_->TransferToServer(u8_4_literal).ConsumeValueOrDie(); in XLA_TEST_F()
97 auto status = client_->Execute( in XLA_TEST_F()
102 status = client_->Execute(computation, {f32_4_data.get(), f32_4_data.get()}, in XLA_TEST_F()
[all …]
|
| D | map_test.cc | 174 client_->TransferToServer(param0_literal).ConsumeValueOrDie(); in TEST_F()
188 client_->TransferToServer(param0_literal).ConsumeValueOrDie(); in XLA_TEST_F()
203 client_->TransferToServer(param0_literal).ConsumeValueOrDie(); in TEST_F()
217 client_->TransferToServer(param0_literal).ConsumeValueOrDie(); in TEST_F()
230 client_->TransferToServer(param0_literal).ConsumeValueOrDie(); in TEST_F()
244 client_->TransferToServer(param0_literal).ConsumeValueOrDie(); in TEST_F()
260 client_->TransferToServer(param0_literal).ConsumeValueOrDie(); in XLA_TEST_F()
277 client_->TransferToServer(param0_literal).ConsumeValueOrDie(); in TEST_F()
293 client_->TransferToServer(param0_literal).ConsumeValueOrDie(); in TEST_F()
348 client_->TransferToServer(param0_literal).ConsumeValueOrDie(); in TEST_F()
[all …]
|
| D | params_test.cc | 47 client_->TransferToServer(param0_literal).ConsumeValueOrDie(); in XLA_TEST_F()
59 client_->TransferToServer(param0_literal).ConsumeValueOrDie(); in XLA_TEST_F()
71 client_->TransferToServer(param0_literal).ConsumeValueOrDie(); in XLA_TEST_F()
84 client_->TransferToServer(param0_literal).ConsumeValueOrDie(); in XLA_TEST_F()
98 client_->TransferToServer(param0_literal).ConsumeValueOrDie(); in XLA_TEST_F()
111 client_->TransferToServer(param0_literal).ConsumeValueOrDie(); in XLA_TEST_F()
126 client_->TransferToServer(literal0).ConsumeValueOrDie(); in XLA_TEST_F()
131 client_->TransferToServer(literal1).ConsumeValueOrDie(); in XLA_TEST_F()
157 client_->TransferToServer(literal).ConsumeValueOrDie(); in XLA_TEST_F()
171 client_->TransferToServer(literal0).ConsumeValueOrDie(); in XLA_TEST_F()
[all …]
|
| D | compilation_cache_test.cc | 46 client_ in ExecuteComputationR0F32()
62 auto data_handle = client_ in ExecuteComputationR2F32()
66 Literal result = client_->Transfer(*data_handle).ConsumeValueOrDie(); in ExecuteComputationR2F32()
90 client_->TransferToServer(LiteralUtil::CreateR0<float>(42.0f)) in XLA_TEST_F()
93 client_->TransferToServer(LiteralUtil::CreateR0<float>(123.0f)) in XLA_TEST_F()
96 client_->TransferToServer(LiteralUtil::CreateR0<float>(456.0f)) in XLA_TEST_F()
147 client_->TransferToServer(rowmaj_array).ConsumeValueOrDie(); in XLA_TEST_F()
152 client_->TransferToServer(colmaj_array).ConsumeValueOrDie(); in XLA_TEST_F()
|
| D | client_test.cc | 57 client_->Execute(computation, {}, &execution_options)); in XLA_TEST_F()
63 auto computed, client_->Transfer(*data, &expected_literal.shape())); in XLA_TEST_F()
93 client_->ExecuteAndTransfer(computation, {}, &execution_options)); in XLA_TEST_F()
120 client_->TransferToServer( in XLA_TEST_F()
133 client_->GetDeviceHandles(1)); in XLA_TEST_F()
142 client_->ExecuteParallel(computation_instances)); in XLA_TEST_F()
147 client_->Transfer(*results[0], &expected_result.shape())); in XLA_TEST_F()
|
| D | convolution_test.cc | 259 client_->TransferToServer(LiteralUtil::CreateR3FromArray3D(input)) in XLA_TEST_F()
262 client_->TransferToServer(LiteralUtil::CreateR3FromArray3D(filter)) in XLA_TEST_F()
294 client_->TransferToServer(LiteralUtil::CreateR3FromArray3D(input)) in RunTest()
297 client_->TransferToServer(LiteralUtil::CreateR3FromArray3D(filter)) in RunTest()
329 client_->TransferToServer(LiteralUtil::CreateR3FromArray3D(input)) in XLA_TEST_F()
332 client_->TransferToServer(LiteralUtil::CreateR3FromArray3D(filter)) in XLA_TEST_F()
360 client_->TransferToServer(LiteralUtil::CreateR3FromArray3D(input)) in XLA_TEST_F()
363 client_->TransferToServer(LiteralUtil::CreateR3FromArray3D(filter)) in XLA_TEST_F()
396 client_->TransferToServer(LiteralUtil::CreateR3FromArray3D(input)) in RunTest()
399 client_->TransferToServer(LiteralUtil::CreateR3FromArray3D(filter)) in RunTest()
[all …]
|
| /external/webrtc/webrtc/base/ |
| D | httprequest.cc | 56 client_(user_agent.c_str(), NULL), in HttpRequest()
71 SslSocketFactory factory(ss, client_.agent()); in Send()
79 client_.set_pool(&pool); in Send()
85 client_.set_proxy(proxy_); in Send()
87 client_.set_redirect_action(HttpClient::REDIRECT_ALWAYS); in Send()
90 client_.set_server(server); in Send()
92 LOG(LS_INFO) << "HttpRequest start: " << host_ + client_.request().path; in Send()
95 monitor.Connect(&client_); in Send()
96 client_.start(); in Send()
100 client_.reset(); in Send()
[all …]
|
| D | ssladapter_unittest.cc | 278 client_(new SSLAdapterTestDummyClient(ssl_mode_)), in SSLAdapterTestBase()
289 ASSERT_EQ(rtc::AsyncSocket::CS_CLOSED, client_->GetState()); in TestHandshake()
291 rv = client_->Connect(server_->GetHostname(), server_->GetAddress()); in TestHandshake()
295 ASSERT_EQ(rtc::AsyncSocket::CS_CONNECTING, client_->GetState()); in TestHandshake()
299 server_->AcceptConnection(client_->GetAddress()); in TestHandshake()
305 EXPECT_EQ_WAIT(rtc::AsyncSocket::CS_CONNECTED, client_->GetState(), in TestHandshake()
312 EXPECT_EQ_WAIT(rtc::AsyncSocket::CS_CLOSED, client_->GetState(), in TestHandshake()
322 rv = client_->Send(message); in TestTransfer()
332 EXPECT_EQ_WAIT(message, client_->GetReceivedData(), kTimeout); in TestTransfer()
343 rtc::scoped_ptr<SSLAdapterTestDummyClient> client_; member in SSLAdapterTestBase
|
| /external/tensorflow/tensorflow/compiler/xla/service/cpu/tests/ |
| D | cpu_infeed_test.cc | 48 ASSERT_IS_OK(client_->TransferToInfeed(literal)); in TestInfeedRoundTrip()
154 result = client_->Execute(computation, {}, &execution_options_) in TEST_F()
160 client_->TransferToInfeed(LiteralUtil::CreateR1<float>({1, 2, 3}))); in TEST_F()
162 client_->TransferToInfeed(LiteralUtil::CreateR1<float>({4, 5, 6}))); in TEST_F()
164 client_->TransferToInfeed(LiteralUtil::CreateR1<float>({7, 8, 9}))); in TEST_F()
166 client_->TransferToInfeed(LiteralUtil::CreateR1<float>({10, 11, 12}))); in TEST_F()
168 client_->TransferToInfeed(LiteralUtil::CreateR1<float>({13, 14, 15}))); in TEST_F()
171 auto result_literal = client_->Transfer(*result).ConsumeValueOrDie(); in TEST_F()
252 ASSERT_IS_OK(client_->TransferToInfeed( in TEST_F()
255 ASSERT_IS_OK(client_->TransferToInfeed( in TEST_F()
[all …]
|
| /external/deqp-deps/SPIRV-Tools/test/ |
| D | binary_parse_test.cpp | 214 spvBinaryParse(ScopedContext().context, &client_, in Parse()
220 MockParseClient client_; member in spvtools::__anonf6d6ed8b0111::BinaryParseTest
227 client_, \
238 EXPECT_CALL(client_, Instruction(_)).Times(0); // No instruction callback. in TEST_F()
247 EXPECT_CALL(client_, Instruction(_)).Times(0); // No instruction callback. in TEST_F()
250 spvBinaryParse(ScopedContext().context, &client_, words.data(), in TEST_F()
258 EXPECT_CALL(client_, Instruction(_)).Times(0); // No instruction callback. in TEST_F()
261 spvBinaryParse(ScopedContext().context, &client_, words.data(), in TEST_F()
275 EXPECT_CALL(client_, Instruction(_)).Times(0); // No instruction callback. in TEST_F()
277 spvBinaryParse(ctx.CContext(), &client_, words.data(), words.size(), in TEST_F()
[all …]
|
| /external/swiftshader/third_party/SPIRV-Tools/test/ |
| D | binary_parse_test.cpp | 216 spvBinaryParse(ScopedContext().context, &client_, in Parse()
222 MockParseClient client_; member in spvtools::__anon9bba21450111::BinaryParseTest
229 client_, \
240 EXPECT_CALL(client_, Instruction(_)).Times(0); // No instruction callback. in TEST_F()
249 EXPECT_CALL(client_, Instruction(_)).Times(0); // No instruction callback. in TEST_F()
252 spvBinaryParse(ScopedContext().context, &client_, words.data(), in TEST_F()
260 EXPECT_CALL(client_, Instruction(_)).Times(0); // No instruction callback. in TEST_F()
263 spvBinaryParse(ScopedContext().context, &client_, words.data(), in TEST_F()
277 EXPECT_CALL(client_, Instruction(_)).Times(0); // No instruction callback. in TEST_F()
279 spvBinaryParse(ctx.CContext(), &client_, words.data(), words.size(), in TEST_F()
[all …]
|
| /external/tensorflow/tensorflow/contrib/ignite/kernels/igfs/ |
| D | igfs_client.cc | 24 client_(ExtendedTCPClient(host, port, true)) { in IGFSClient()
25 client_.Connect(); in IGFSClient()
28 IGFSClient::~IGFSClient() { client_.Disconnect(); } in ~IGFSClient()
32 TF_RETURN_IF_ERROR(request.Write(&client_)); in SendRequestGetResponse()
33 client_.reset(); in SendRequestGetResponse()
36 TF_RETURN_IF_ERROR(response->Read(&client_)); in SendRequestGetResponse()
37 client_.reset(); in SendRequestGetResponse()
|
| D | igfs_writable_file.cc | 25 client_(std::move(client)) {} in IGFSWritableFile()
31 Status status = client_->Close(&close_response, resource_id_); in ~IGFSWritableFile()
37 return client_->WriteBlock(resource_id_, (uint8_t *)data.data(), data.size()); in Append()
45 return client_->Close(&close_response, resource_to_be_closed); in Close()
52 TF_RETURN_IF_ERROR(client_->Close(&close_response, resource_id_)); in Sync()
55 TF_RETURN_IF_ERROR(client_->OpenAppend(&open_append_resp, file_name_)); in Sync()
|
| /external/webrtc/webrtc/examples/peerconnection/client/ |
| D | conductor.cc | 58 client_(client), in Conductor()
60 client_->RegisterObserver(this); in Conductor()
73 client_->SignOut(); in Close()
203 main_wnd_->SwitchToPeerList(client_->peers()); in OnSignedIn()
219 main_wnd_->SwitchToPeerList(client_->peers()); in OnPeerConnected()
230 main_wnd_->SwitchToPeerList(client_->peers()); in OnPeerDisconnected()
244 client_->SignOut(); in OnMessageFromPeer()
271 client_->SignOut(); in OnMessageFromPeer()
342 if (client_->is_connected()) in StartLogin()
345 client_->Connect(server, port, GetPeerName()); in StartLogin()
[all …]
|
| /external/tensorflow/tensorflow/compiler/tf2xla/ |
| D | xla_expression_test.cc | 38 client_ = xla::ClientLibrary::LocalClientOrDie(); in SetUp()
51 xla::Client* client_; member in tensorflow::__anon72ef178f0111::XlaExpressionTest
88 client_->ComputeConstant(computation)); in TEST_F()
111 EXPECT_FALSE(XlaExpression().ResolveConstant(client_).ok()); in TEST_F()
112 EXPECT_FALSE(XlaExpression::Invalid().ResolveConstant(client_).ok()); in TEST_F()
114 XlaExpression::Resource(resource_.get()).ResolveConstant(client_).ok()); in TEST_F()
118 XlaExpression::XlaOp(op_, DT_INT32).ResolveConstant(client_)); in TEST_F()
124 .ResolveConstant(client_)); in TEST_F()
129 XlaExpression::Constant(constant_).ResolveConstant(client_)); in TEST_F()
|
| /external/webrtc/webrtc/libjingle/xmpp/ |
| D | xmpppump.cc | 20 client_ = new buzz::XmppClient(this); // NOTE: deleted by TaskRunner in XmppPump()
28 client_->SignalStateChange.connect(this, &XmppPump::OnStateChange); in DoLogin()
29 client_->Connect(xcs, "", socket, auth); in DoLogin()
30 client_->Start(); in DoLogin()
36 client_->Disconnect(); in DoDisconnect()
62 return client_->SendStanza(stanza); in SendStanza()
|
| D | pubsubstateclient.h | 97 client_(client), in PubSubStateClient()
102 client_->SignalItems.connect( in PubSubStateClient()
104 client_->SignalPublishResult.connect( in PubSubStateClient()
106 client_->SignalPublishError.connect( in PubSubStateClient()
108 client_->SignalRetractResult.connect( in PubSubStateClient()
110 client_->SignalRetractError.connect( in PubSubStateClient()
122 client_->RetractItem(itemid, task_id_out); in Publish()
126 client_->PublishItem(itemid, state_elem, task_id_out); in Publish()
150 client_->GetPublisherNickFromPubSubItem(item.elem); in ParseStateItem()
160 PubSubClient* client() { return client_; } in client()
[all …]
|
| /external/tensorflow/tensorflow/contrib/bigtable/kernels/ |
| D | bigtable_lib.h | 40 client_(std::move(client)) {} in BigtableClientResource()
43 return client_; in get_client()
54 std::shared_ptr<google::cloud::bigtable::DataClient> client_; variable
60 : client_(client), in BigtableTableResource()
64 client_->Ref(); in BigtableTableResource()
67 ~BigtableTableResource() override { client_->Unref(); } in ~BigtableTableResource()
73 "BigtableTableResource(client: ", client_->DebugString(), in DebugString()
78 BigtableClientResource* client_; // Ownes one ref.
|
| /external/boringssl/src/ssl/ |
| D | ssl_test.cc | 1635 return ConnectClientAndServer(&client_, &server_, client_ctx_.get(), in Connect()
1647 bssl::UniquePtr<SSL> client_, server_; member in __anond8fd7f190111::SSLVersionTest
1665 ASSERT_LE(SSL_read(client_.get(), &byte, 1), 0); in TEST_P()
1668 uint64_t client_read_seq = SSL_get_read_sequence(client_.get()); in TEST_P()
1669 uint64_t client_write_seq = SSL_get_write_sequence(client_.get()); in TEST_P()
1690 EXPECT_EQ(SSL_write(client_.get(), &byte, 1), 1); in TEST_P()
1695 EXPECT_EQ(client_write_seq + 1, SSL_get_write_sequence(client_.get())); in TEST_P()
1708 ASSERT_EQ(SSL_shutdown(client_.get()), 0); in TEST_P()
1719 ASSERT_EQ(SSL_read(client_.get(), &byte, 1), 1); in TEST_P()
1724 EXPECT_EQ(SSL_shutdown(client_.get()), 1); in TEST_P()
[all …]
|
| /external/webrtc/webrtc/examples/peerconnection/client/linux/ |
| D | main.cc | 24 : thread_(thread), wnd_(wnd), conductor_(NULL), client_(NULL) {} in CustomSocketServer()
27 void set_client(PeerConnectionClient* client) { client_ = client; } in set_client()
41 client_ != NULL && !client_->is_connected()) { in Wait()
52 PeerConnectionClient* client_; member in CustomSocketServer
|
| /external/tensorflow/tensorflow/contrib/ignite/kernels/client/ |
| D | ignite_ssl_wrapper.cc | 35 client_(client), in SslWrapper()
91 TF_RETURN_IF_ERROR(client_->Connect()); in Connect()
93 SSL_set_fd(ssl_, client_->GetSocketDescriptor()); in Connect()
108 return client_->Disconnect(); in Disconnect()
111 bool SslWrapper::IsConnected() { return client_->IsConnected(); } in IsConnected()
113 int SslWrapper::GetSocketDescriptor() { return client_->GetSocketDescriptor(); } in GetSocketDescriptor()
|