Searched refs:client_ (Results 1 – 6 of 6) sorted by relevance
128 Transaction::Transaction(Client& client) : client_{client} {} in Transaction()131 if (state_allocated_ && client_.GetChannel()) in ~Transaction()132 client_.GetChannel()->FreeTransactionState(state_); in ~Transaction()136 if (!state_allocated_ && client_.GetChannel()) { in EnsureStateAllocated()137 state_ = client_.GetChannel()->AllocateTransactionState(); 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()[all …]
93 : client_{SimpleClient::Create( in ClientChannelTest()97 return static_cast<MockClientChannel*>(client_->GetChannel()); in mock_channel()100 std::unique_ptr<SimpleClient> client_; member in __anon5d1a90d20111::ClientChannelTest110 client_ = SimpleClient::Create(std::move(factory), kTimeout); in ClientChannelFactoryTest()114 return static_cast<MockClientChannel*>(client_->GetChannel()); in mock_channel()134 std::unique_ptr<SimpleClient> client_; member in __anon5d1a90d20111::ClientChannelFactoryTest143 ClientTransactionTest() : transaction_{*client_} {} in ClientTransactionTest()151 ASSERT_NE(client_.get(), nullptr); in TEST_F()152 EXPECT_TRUE(client_->IsInitialized()); in TEST_F()153 EXPECT_TRUE(client_->IsConnected()); in TEST_F()[all …]
116 client_ = TestClient::Create(status.take()); in SetUp()121 client_.reset(); in TearDown()126 std::shared_ptr<TestClient> client_; member in __anon8afdb3350111::ClientChannelTest155 threads.emplace_back(worker, client_, data); in TEST_F()
294 Client& client_; variable
316 wp<VrComposerClient> client_; variable
947 if (!client_.promote().get()) { in createClient()954 client_ = client; in createClient()