| /aosp12/frameworks/native/libs/vr/libpdx/ |
| H A D | client_tests.cpp | 93 : client_{SimpleClient::Create( in ClientChannelTest()
151 ASSERT_NE(client_.get(), nullptr); in TEST_F()
172 EXPECT_EQ(0, client_->error()); in TEST_F()
173 client_->Close(-EINVAL); in TEST_F()
180 EXPECT_EQ(12, client_->event_fd()); in TEST_F()
350 client_->DisableAutoReconnect(); in TEST_F()
372 client_->Close(ESHUTDOWN); in TEST_F()
385 client_->Close(ESHUTDOWN); in TEST_F()
388 client_->Close(EIO); in TEST_F()
398 client_->Close(EIO); in TEST_F()
[all …]
|
| H A D | client.cpp | 131 if (state_allocated_ && client_.GetChannel()) in ~Transaction()
136 if (!state_allocated_ && client_.GetChannel()) { in EnsureStateAllocated()
147 *ret = client_.CheckReconnect(); in SendTransaction()
156 auto status = client_.GetChannel()->SendWithInt( in SendTransaction()
171 auto status = client_.CheckReconnect(); in SendTransaction()
182 *ret = client_.GetChannel()->SendWithInt( in SendTransaction()
192 auto status = client_.CheckReconnect(); in SendTransaction()
213 auto status = client_.CheckReconnect(); in SendTransaction()
278 if (client_.NeedToDisconnectChannel(error)) { in CheckDisconnect()
280 if (client_.GetChannel()) in CheckDisconnect()
[all …]
|
| /aosp12/packages/modules/adb/tls/tests/ |
| H A D | tls_connection_test.cpp | 219 ASSERT_NE(nullptr, client_); in SetUp()
226 client_.reset(); in TearDown()
258 std::unique_ptr<TlsConnection> client_; member in adb::tls::AdbWifiTlsConnectionTest
302 EXPECT_TRUE(client_->WriteFully( in TEST_F()
328 EXPECT_FALSE(client_->WriteFully( in TEST_F()
355 EXPECT_TRUE(client_->WriteFully( in TEST_F()
386 EXPECT_TRUE(client_->WriteFully( in TEST_F()
444 client_->EnableClientPostHandshakeCheck(true); in TEST_F()
475 client_->EnableClientPostHandshakeCheck(true); in TEST_F()
490 client_->EnableClientPostHandshakeCheck(true); in TEST_F()
[all …]
|
| /aosp12/system/update_engine/cros/ |
| H A D | update_engine_client.cc | 83 if (!client_) { in OnInit()
154 if (client_->GetStatus(&status)) { in ShowStatus()
178 if (!client_->GetStatus(&status)) { in GetNeedReboot()
201 update_engine::UpdateEngineClient* client_; member in __anone0d56f760110::UpdateWaitHandler
208 if (client_ && client_->GetLastAttemptError(&last_attempt_error)) in HandleStatusUpdate()
308 if (client_->ResetStatus()) { in ProcessFlags()
359 if (!client_->GetCohortHint(&cohort_hint)) { in ProcessFlags()
467 if (!client_->Rollback(FLAGS_powerwash)) { in ProcessFlags()
482 if (!client_->AttemptUpdate( in ProcessFlags()
527 client_->RebootIfNeeded(); in ProcessFlags()
[all …]
|
| /aosp12/system/bt/vendor_libs/test_vendor_lib/test/ |
| H A D | polled_socket_test.cc | 41 client_.SetServerName("localhost"); in SetUp()
42 client_.Initialize(kPort); in SetUp()
50 PolledSocketClient client_; member in test_vendor_lib::net::PolledSocketTest
63 client_.Send(tx_buf); in TEST_F()
65 client_.Send(tx_buf); in TEST_F()
|
| /aosp12/system/logging/logd/ |
| H A D | LogReader.cpp | 51 : LogWriter(client->getUid(), privileged), reader_(reader), client_(client) {} in SocketLogWriter()
60 return client_->sendDatav(iovec, 1 + (entry.len != 0)) == 0; in Write()
64 reader_->release(client_); in Release()
65 client_->decRef(); in Release()
68 void Shutdown() override { shutdown(client_->getSocket(), SHUT_RDWR); } in Shutdown()
70 std::string name() const override { return SocketClientToName(client_); } in name()
74 SocketClient* client_; member in SocketLogWriter
|
| /aosp12/packages/modules/adb/client/openscreen/platform/ |
| H A D | udp_socket.cpp | 161 : client_(client), local_endpoint_(local_endpoint), fd_(std::move(fd)) { in AdbUdpSocket()
162 CHECK(client_); in AdbUdpSocket()
243 client_->OnBound(this); in Bind()
398 client_->OnSendError(this, Error::Code::kSocketClosedFailure); in JoinMulticastGroup()
442 client_->OnSendError(this, ChooseError(errno, Error::Code::kSocketSendFailure)); in JoinMulticastGroup()
562 client_->OnRead(this, Error::Code::kSocketClosedFailure); in JoinMulticastGroup()
568 client_->OnRead(this, ChooseError(errno, Error::Code::kSocketReadFailure)); in JoinMulticastGroup()
590 client_->OnRead(this, result.ok() ? ErrorOr<UdpPacket>(std::move(packet)) in JoinMulticastGroup()
605 client_->OnError(this, Error(error_code, stream.str())); in JoinMulticastGroup()
615 Client* const client_; in JoinMulticastGroup() member in openscreen::__anon6f61fd7c0110::AdbUdpSocket
|
| /aosp12/frameworks/native/libs/vr/libpdx_uds/ |
| H A D | client_channel_tests.cpp | 116 client_ = TestClient::Create(status.take()); in SetUp()
121 client_.reset(); in TearDown()
126 std::shared_ptr<TestClient> client_; member in __anon4bd920b80110::ClientChannelTest
155 threads.emplace_back(worker, client_, data); in TEST_F()
|
| /aosp12/system/update_engine/aosp/ |
| H A D | update_engine_client_android.cc | 60 explicit UECallback(UpdateEngineClientAndroid* client) : client_(client) {} in UECallback()
67 UpdateEngineClientAndroid* client_; member in chromeos_update_engine::internal::UpdateEngineClientAndroid::UECallback
102 client_->ExitWhenIdle( in onPayloadApplicationComplete()
|
| /aosp12/packages/modules/adb/pairing_connection/tests/ |
| H A D | pairing_connection_test.cpp | 173 client_ = CreateClient(client_pswd); in InitPairing()
208 std::unique_ptr<PairingClient> client_; member in adb::pairing::AdbPairingConnectionTest
348 ASSERT_TRUE(client_->Start(ip_addr_, client_waiter.ResultCallback, &client_waiter)); in TEST_F()
387 ASSERT_TRUE(client_->Start(ip_addr_, client_waiter.ResultCallback, &client_waiter)); in TEST_F()
|
| /aosp12/packages/modules/adb/client/pairing/tests/ |
| H A D | pairing_connection_test.cpp | 96 client_ = PairingClient::create(client_pswd, client_info_, cert, key, "127.0.0.1"); in initPairing()
130 std::unique_ptr<PairingClient> client_; member in adbwifi::pairing::AdbWifiPairingConnectionTest
238 ASSERT_TRUE(client_->start(client_callback, nullptr)); in TEST_F()
290 ASSERT_TRUE(client_->start(client_callback, nullptr)); in TEST_F()
|
| /aosp12/system/core/fs_mgr/libsnapshot/ |
| H A D | cow_snapuserd_test.cpp | 147 std::unique_ptr<SnapuserdClient> client_; member in android::snapshot::CowSnapuserdTest
197 ASSERT_TRUE(client_->WaitForDeviceDelete(system_device_ctrl_name_)); in Shutdown()
199 ASSERT_TRUE(client_->DetachSnapuserd()); in Shutdown()
255 client_ = SnapuserdClient::Connect(kSnapuserdSocketTest, 10s); in StartSnapuserdDaemon()
256 ASSERT_NE(client_, nullptr); in StartSnapuserdDaemon()
646 cow_num_sectors_ = client_->InitDmUserCow(system_device_ctrl_name_, cow_system_->path, in InitCowDevice()
708 bool ok = client_->AttachDmUser(system_device_ctrl_name_); in InitDaemon()
|
| /aosp12/frameworks/native/services/vr/hardware_composer/impl/ |
| H A D | vr_hwc.cpp | 869 if (!client_.promote().get()) { in createClient()
876 client_ = client; in createClient()
886 if (!client_.promote().get()) { in createClient_2_3()
893 client_ = client; in createClient_2_3()
|
| H A D | vr_hwc.h | 390 wp<VrComposerClient> client_; variable
|
| /aosp12/frameworks/native/libs/vr/libpdx/private/pdx/ |
| H A D | client.h | 294 Client& client_; variable
|