Home | History | Annotate | Download | only in libpdx

Lines Matching defs:client_

93       : client_{SimpleClient::Create(
97 return static_cast<MockClientChannel*>(client_->GetChannel());
100 std::unique_ptr<SimpleClient> client_;
110 client_ = SimpleClient::Create(std::move(factory), kTimeout);
114 return static_cast<MockClientChannel*>(client_->GetChannel());
134 std::unique_ptr<SimpleClient> client_;
143 ClientTransactionTest() : transaction_{*client_} {}
151 ASSERT_NE(client_.get(), nullptr);
152 EXPECT_TRUE(client_->IsInitialized());
153 EXPECT_TRUE(client_->IsConnected());
171 EXPECT_TRUE(client_->IsConnected());
172 EXPECT_EQ(0, client_->error());
173 client_->Close(-EINVAL);
174 EXPECT_FALSE(client_->IsConnected());
175 EXPECT_EQ(-EINVAL, client_->error());
180 EXPECT_EQ(12, client_->event_fd());
186 EXPECT_TRUE(client_->SendImpulse(123));
190 auto status = client_->SendImpulse(17);
197 EXPECT_TRUE(client_->SendImpulse(1, kTestPtr, 17));
207 EXPECT_TRUE(client_->InvokeRemoteMethod<TestInterface::Add>(4, 5));
219 Status<int> status = client_->InvokeRemoteMethod<TestInterface::Add>(1, 2);
233 Status<int> status = client_->InvokeRemoteMethod<TestInterface::Add>(1, 2);
249 client_->InvokeRemoteMethod<TestInterface::GetFile>();
264 client_->InvokeRemoteMethod<TestInterface::GetFile>("file", 0);
281 client_->InvokeRemoteMethod<TestInterface::PushChannel>();
297 client_->InvokeRemoteMethod<TestInterface::PushChannel>();
315 EXPECT_TRUE(client_->InvokeRemoteMethod<TestInterface::SendFile>(fd));
331 EXPECT_FALSE(client_->InvokeRemoteMethod<TestInterface::SendFile>(fd));
335 ASSERT_NE(client_.get(), nullptr);
336 EXPECT_TRUE(client_->IsInitialized());
337 EXPECT_TRUE(client_->IsConnected());
346 client_ = SimpleClient::Create(std::move(factory), kTimeout);
347 ASSERT_NE(client_.get(), nullptr);
348 EXPECT_TRUE(client_->IsInitialized());
349 EXPECT_FALSE(client_->IsConnected());
350 client_->DisableAutoReconnect();
351 ASSERT_FALSE(client_->SendImpulse(17));
352 EXPECT_FALSE(client_->IsConnected());
353 client_->EnableAutoReconnect(kTimeout);
354 EXPECT_CALL(*client_, OnConnect());
359 ASSERT_TRUE(client_->SendImpulse(17));
360 EXPECT_TRUE(client_->IsConnected());
366 ASSERT_FALSE(client_->SendImpulse(17));
367 EXPECT_FALSE(client_->IsConnected());
368 EXPECT_EQ(-ESHUTDOWN, client_->error());
372 client_->Close(ESHUTDOWN);
373 ASSERT_FALSE(client_->IsConnected());
375 EXPECT_CALL(*client_, OnConnect());
380 ASSERT_TRUE(client_->SendImpulse(17));
381 EXPECT_TRUE(client_->IsConnected());
385 client_->Close(ESHUTDOWN);
387 EXPECT_CALL(*client_, OnConnect()).WillOnce(Invoke([this] {
388 client_->Close(EIO);
390 auto status = client_->SendImpulse(17);
393 EXPECT_FALSE(client_->IsConnected());
394 EXPECT_EQ(-EIO, client_->error());
398 client_->Close(EIO);
399 ASSERT_FALSE(client_->IsConnected());
400 client_->DisableAutoReconnect();
401 auto status = client_->SendImpulse(17);
404 EXPECT_FALSE(client_->IsConnected());
405 client_->EnableAutoReconnect(kTimeout);
406 EXPECT_CALL(*client_, OnConnect());
411 ASSERT_TRUE(client_->SendImpulse(17));
412 EXPECT_TRUE(client_->IsConnected());