/external/webrtc/webrtc/libjingle/xmpp/ |
H A D | xmpppump.h | 36 buzz::XmppClient *client() { return client_; } 54 buzz::XmppClient *client_; member in class:buzz::XmppPump
|
H A D | pubsubstateclient.h | 97 client_(client), 102 client_->SignalItems.connect( 104 client_->SignalPublishResult.connect( 106 client_->SignalPublishError.connect( 108 client_->SignalRetractResult.connect( 110 client_->SignalRetractError.connect( 122 client_->RetractItem(itemid, task_id_out); 126 client_->PublishItem(itemid, state_elem, task_id_out); 150 client_->GetPublisherNickFromPubSubItem(item.elem); 160 PubSubClient* client() { return client_; } 256 PubSubClient* client_; member in class:buzz::PubSubStateClient [all...] |
H A D | xmppclient.cc | 32 client_(client), 48 XmppClient* const client_; member in class:buzz::XmppClient::Private 366 client_->SignalLogInput(bytes, static_cast<int>(bytes_read)); 380 client_->EnsureClosed(); 383 client_->SignalStateChange((XmppEngine::State)state); 385 client_->Wake(); 390 client_->SignalLogOutput(bytes, static_cast<int>(len));
|
/external/libmojo/mojo/common/ |
H A D | data_pipe_drainer.h | 37 Client* client_; member in class:mojo::common::DataPipeDrainer
|
/external/perfetto/include/perfetto/ipc/ |
H A D | service_proxy.h | 90 base::WeakPtr<Client> client_; member in class:perfetto::ipc::ServiceProxy
|
/external/webrtc/webrtc/examples/peerconnection/client/linux/ |
H A D | main.cc | 24 : thread_(thread), wnd_(wnd), conductor_(NULL), client_(NULL) {} 27 void set_client(PeerConnectionClient* client) { client_ = client; } 41 client_ != NULL && !client_->is_connected()) { 52 PeerConnectionClient* client_; member in class:CustomSocketServer
|
/external/webrtc/webrtc/p2p/base/ |
H A D | stunserver_unittest.cc | 36 client_.reset(new rtc::TestClient( 47 client_->SendTo(buf, len, server_addr); 50 return(client_->CheckNoPacket()); 55 client_->NextPacket(rtc::TestClient::kTimeoutMs); 69 rtc::scoped_ptr<rtc::TestClient> client_; member in class:StunServerTest
|
/external/tensorflow/tensorflow/compiler/jit/ |
H A D | xla_compilation_cache.h | 72 xla::LocalClient* client() const { return client_; } 84 xla::LocalClient* const client_; member in class:tensorflow::XlaCompilationCache::xla
|
/external/webrtc/webrtc/examples/peerconnection/client/ |
H A D | conductor.h | 121 PeerConnectionClient* client_; member in class:Conductor
|
/external/webrtc/webrtc/base/ |
H A D | httprequest.h | 67 HttpRequestData& request() { return client_.request(); } 68 HttpResponseData& response() { return client_.response(); } 82 HttpClient client_; member in class:rtc::HttpRequest
|
H A D | ssladapter_unittest.cc | 278 client_(new SSLAdapterTestDummyClient(ssl_mode_)), 289 ASSERT_EQ(rtc::AsyncSocket::CS_CLOSED, client_->GetState()); 291 rv = client_->Connect(server_->GetHostname(), server_->GetAddress()); 295 ASSERT_EQ(rtc::AsyncSocket::CS_CONNECTING, client_->GetState()); 299 server_->AcceptConnection(client_->GetAddress()); 305 EXPECT_EQ_WAIT(rtc::AsyncSocket::CS_CONNECTED, client_->GetState(), 312 EXPECT_EQ_WAIT(rtc::AsyncSocket::CS_CLOSED, client_->GetState(), 322 rv = client_->Send(message); 332 EXPECT_EQ_WAIT(message, client_->GetReceivedData(), kTimeout); 343 rtc::scoped_ptr<SSLAdapterTestDummyClient> client_; member in class:SSLAdapterTestBase [all...] |
H A D | nat_unittest.cc | 346 client_->SignalConnectEvent.connect(this, &NatTcpTest::OnConnectEvent); 360 rtc::scoped_ptr<AsyncSocket> client_; member in class:NatTcpTest 370 client_.reset(natsf_->CreateAsyncSocket(SOCK_STREAM)); 371 EXPECT_GE(0, client_->Bind(int_addr_)); 372 EXPECT_GE(0, client_->Connect(server_->GetLocalAddress())); 377 EXPECT_EQ(client_->GetRemoteAddress(), server_->GetLocalAddress()); 380 rtc::scoped_ptr<rtc::TestClient> in(CreateTCPTestClient(client_.release()));
|
/external/tensorflow/tensorflow/compiler/xla/client/ |
H A D | computation_builder.h | 60 Client* client() const { return client_; } 940 Client* client_; member in class:xla::ComputationBuilder
|
/external/tensorflow/tensorflow/compiler/xla/service/ |
H A D | hlo_cost_analysis_test.cc | 56 : client_(ClientLibrary::LocalClientOrDie()), 61 static_cast<LocalClient*>(client_)->platform()))), 65 ComputationBuilder builder(client_, "add_and_exp"); 76 ComputationBuilder builder(client_, "add"); 87 ComputationBuilder builder(client_, "sigmoid"); 98 ComputationBuilder builder(client_, "max"); 109 ComputationBuilder builder(client_, "gt"); 135 Client* client_; member in class:xla::__anon25618::HloCostAnalysisTest 148 ComputationBuilder builder(client_, "matrix_multiply"); 170 ComputationBuilder builder(client_, "ma [all...] |
/external/tensorflow/tensorflow/compiler/xla/tests/ |
H A D | client_library_test_base.h | 383 Client* client_; member in class:xla::ClientLibraryTestBase 556 client_->TransferToServer(*literal).ConsumeValueOrDie(); 571 client_->TransferToServer(*literal).ConsumeValueOrDie(); 586 client_->TransferToServer(*literal).ConsumeValueOrDie(); 601 client_->TransferToServer(*literal).ConsumeValueOrDie();
|
/external/adhd/cras/src/tests/ |
H A D | cras_client_unittest.cc | 71 memset(&client_, 0, sizeof(client_)); 72 client_.server_fd_state = CRAS_SOCKET_STATE_CONNECTED; 95 struct cras_client client_; member in class:__anon758::CrasClientTestSuite 282 &client_, stream_ptr, &stream_id, NO_DEVICE)); 288 &client_, stream_ptr, &stream_id, NO_DEVICE)); 289 EXPECT_EQ(&client_, stream_ptr->client); 294 EXPECT_EQ(stream_ptr, stream_from_id(&client_, stream_id)); 298 EXPECT_EQ(0, client_thread_rm_stream(&client_, stream_id)); 305 EXPECT_EQ(NULL, stream_from_id(&client_, stream_i [all...] |
/external/tensorflow/tensorflow/compiler/tf2xla/ |
H A D | xla_compiler_test.cc | 48 client_ = xla::ClientLibrary::LocalClientOrDie(); 59 options.client = client_; 69 xla::Client* client_; member in class:tensorflow::XlaCompilerTest 177 TF_ASSERT_OK(client_->Execute(*result.computation, {}).status()); 213 client_->TransferToServer(*param0_literal).ConsumeValueOrDie(); 215 client_->TransferToServer(*param1_literal).ConsumeValueOrDie(); 218 client_ 222 client_->Transfer(*actual).ConsumeValueOrDie(); 311 client_->TransferToServer(*param0_literal).ConsumeValueOrDie(); 314 client_ [all...] |
/external/v4l2_codec2/vda/ |
H A D | v4l2_slice_video_decode_accelerator.h | 337 base::WeakPtr<VideoDecodeAccelerator::Client> client_; member in class:media::V4L2SliceVideoDecodeAccelerator
|
H A D | v4l2_video_decode_accelerator.h | 378 base::WeakPtr<Client> client_; member in class:media::V4L2VideoDecodeAccelerator
|
/external/libmojo/mojo/public/cpp/bindings/lib/ |
H A D | multiplex_router.cc | 40 client_(nullptr), 83 InterfaceEndpointClient* client() const { return client_; } 88 DCHECK(!client_); 93 client_ = client; 100 DCHECK(client_); 105 client_ = nullptr; 171 DCHECK(!client_); 251 // The task runner on which |client_|'s methods can be called. 254 InterfaceEndpointClient* client_; member in class:mojo::internal::MultiplexRouter::InterfaceEndpoint
|
/external/boringssl/src/ssl/ |
H A D | ssl_test.cc | 1610 return ConnectClientAndServer(&client_, &server_, client_ctx_.get(), 1620 bssl::UniquePtr<SSL> client_, server_; member in class:bssl::__anon1019::SSLVersionTest 1638 ASSERT_LE(SSL_read(client_.get(), &byte, 1), 0); 1641 uint64_t client_read_seq = SSL_get_read_sequence(client_.get()); 1642 uint64_t client_write_seq = SSL_get_write_sequence(client_.get()); 1663 EXPECT_EQ(SSL_write(client_.get(), &byte, 1), 1); 1668 EXPECT_EQ(client_write_seq + 1, SSL_get_write_sequence(client_.get())); 1681 ASSERT_EQ(SSL_shutdown(client_.get()), 0); 1692 ASSERT_EQ(SSL_read(client_.get(), &byte, 1), 1); 1697 EXPECT_EQ(SSL_shutdown(client_ [all...] |