/external/webrtc/webrtc/libjingle/xmpp/ |
xmpppump.h | 36 buzz::XmppClient *client() { return client_; } 54 buzz::XmppClient *client_; member in class:buzz::XmppPump
|
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...] |
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/ |
data_pipe_drainer.h | 37 Client* client_; member in class:mojo::common::DataPipeDrainer
|
/external/perfetto/include/perfetto/ipc/ |
service_proxy.h | 90 base::WeakPtr<Client> client_; member in class:perfetto::ipc::ServiceProxy
|
/external/webrtc/webrtc/examples/peerconnection/client/linux/ |
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
|
/frameworks/native/libs/vr/libbufferhub/include/private/dvr/ |
detached_buffer.h | 36 bool IsConnected() const { return client_.IsValid(); } 45 if (auto* channel = client_.GetChannel()) { 76 BufferHubClient client_; member in class:android::dvr::DetachedBuffer
|
/system/update_engine/client_library/ |
client_binder.h | 94 : client_(client) {} 100 BinderUpdateEngineClient* client_; member in class:update_engine::internal::BinderUpdateEngineClient::StatusUpdateCallback
|
/external/tensorflow/tensorflow/compiler/jit/ |
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/p2p/base/ |
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/webrtc/webrtc/examples/peerconnection/client/ |
conductor.h | 121 PeerConnectionClient* client_; member in class:Conductor
|
/frameworks/native/libs/vr/libpdx/private/pdx/ |
client.h | 294 Client& client_; member in class:android::pdx::Client::final
|
/frameworks/native/libs/vr/libpdx_uds/ |
client_channel_tests.cpp | 116 client_ = TestClient::Create(status.take()); 121 client_.reset(); 126 std::shared_ptr<TestClient> client_; member in class:__anon46443::ClientChannelTest 155 threads.emplace_back(worker, client_, data);
|
/system/update_engine/ |
update_engine_client_android.cc | 61 explicit UECallback(UpdateEngineClientAndroid* client) : client_(client) {} 68 UpdateEngineClientAndroid* client_; member in class:chromeos_update_engine::internal::UpdateEngineClientAndroid::UECallback 100 client_->ExitWhenIdle(
|
update_engine_client.cc | 73 client_ = update_engine::UpdateEngineClient::CreateInstance(); 75 if (!client_) { 110 unique_ptr<update_engine::UpdateEngineClient> client_; member in class:__anon3893::UpdateEngineClient 162 if (client_->GetStatus(&last_checked_time, &progress, ¤t_op, 190 if (!client_->GetStatus(&last_checked_time, &progress, ¤t_op, 206 : exit_on_error_(exit_on_error), client_(client) {} 218 update_engine::UpdateEngineClient* client_; member in class:__anon3893::UpdateWaitHandler 229 if (client_ && client_->GetLastAttemptError(&last_attempt_error)) 316 if (client_->ResetStatus()) [all...] |
/device/google/cuttlefish_common/host/frontend/vnc_server/ |
vnc_client_connection.h | 139 ClientSocket client_; member in class:cvd::vnc::VncClientConnection
|
/external/tensorflow/tensorflow/compiler/xla/tests/ |
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/webrtc/webrtc/base/ |
httprequest.h | 67 HttpRequestData& request() { return client_.request(); } 68 HttpResponseData& response() { return client_.response(); } 82 HttpClient client_; member in class:rtc::HttpRequest
|
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()));
|
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...] |
/frameworks/native/libs/vr/libpdx/ |
client_tests.cpp | 93 : client_{SimpleClient::Create( 97 return static_cast<MockClientChannel*>(client_->GetChannel()); 100 std::unique_ptr<SimpleClient> client_; member in class:__anon46424::ClientChannelTest 110 client_ = SimpleClient::Create(std::move(factory), kTimeout); 114 return static_cast<MockClientChannel*>(client_->GetChannel()); 134 std::unique_ptr<SimpleClient> client_; member in class:__anon46424::ClientChannelFactoryTest 143 ClientTransactionTest() : transaction_{*client_} {} 151 ASSERT_NE(client_.get(), nullptr); 152 EXPECT_TRUE(client_->IsInitialized()); 153 EXPECT_TRUE(client_->IsConnected()) [all...] |
/external/adhd/cras/src/tests/ |
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:__anon14135::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_id)) [all...] |
/external/tensorflow/tensorflow/compiler/xla/client/ |
computation_builder.h | 60 Client* client() const { return client_; } 940 Client* client_; member in class:xla::ComputationBuilder [all...] |
/external/tensorflow/tensorflow/compiler/xla/service/ |
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::__anon38939::HloCostAnalysisTest 148 ComputationBuilder builder(client_, "matrix_multiply"); 170 ComputationBuilder builder(client_, "map") [all...] |
/external/tensorflow/tensorflow/compiler/tf2xla/ |
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_->Execute(*result.computation, {param0_data.get()} [all...] |