Lines Matching full:cli
103 auto cli = in TEST_F() local
106 ASSERT_FALSE(cli->is_connected()); in TEST_F()
108 EXPECT_CALL(event_listener_, OnConnect(cli.get(), false)) in TEST_F()
133 auto cli = in TEST_F() local
136 EXPECT_CALL(event_listener_, OnConnect(cli.get(), true)) in TEST_F()
143 EXPECT_CALL(event_listener_, OnDisconnect(cli.get())) in TEST_F()
148 cli->SendStr("."); in TEST_F()
149 EXPECT_FALSE(cli->SendStr("should_fail_both_on_win_and_unix")); in TEST_F()
159 auto cli = in TEST_F() local
163 EXPECT_CALL(event_listener_, OnConnect(cli.get(), true)) in TEST_F()
179 ASSERT_TRUE(cli->is_connected()); in TEST_F()
182 EXPECT_CALL(event_listener_, OnDataAvailable(cli.get())) in TEST_F()
184 ASSERT_EQ("srv>cli", s->ReceiveString()); in TEST_F()
191 ASSERT_EQ("cli>srv", s->ReceiveString()); in TEST_F()
194 ASSERT_TRUE(cli->SendStr("cli>srv")); in TEST_F()
195 ASSERT_TRUE(srv_conn->SendStr("srv>cli")); in TEST_F()
201 EXPECT_CALL(event_listener_, OnDisconnect(cli.get())) in TEST_F()
203 cli->Shutdown(true); in TEST_F()
205 ASSERT_EQ(0u, cli->Receive(&msg, sizeof(msg))); in TEST_F()
206 ASSERT_EQ("", cli->ReceiveString()); in TEST_F()
209 ASSERT_FALSE(cli->SendStr("foo")); in TEST_F()
226 auto cli = in TEST_F() local
229 EXPECT_CALL(event_listener_, OnConnect(cli.get(), true)) in TEST_F()
246 ASSERT_TRUE(cli->is_connected()); in TEST_F()
247 cli.reset(); in TEST_F()
259 std::unique_ptr<UnixSocket> cli[kNumClients]; in TEST_F() local
272 cli[i] = in TEST_F()
275 EXPECT_CALL(event_listener_, OnConnect(cli[i].get(), true)) in TEST_F()
282 EXPECT_CALL(event_listener_, OnDataAvailable(cli[i].get())) in TEST_F()
291 ASSERT_TRUE(Mock::VerifyAndClearExpectations(cli[i].get())); in TEST_F()
325 auto cli = in TEST_F() local
330 EXPECT_CALL(tx_events, OnConnect(cli.get(), true)) in TEST_F()
336 tx_task_runner.PostTask([&cli, &buf, all_sent] { in TEST_F()
338 cli->Send(buf.data(), buf.size()); in TEST_F()
375 auto cli = in TEST_F() local
380 EXPECT_CALL(tx_events, OnConnect(cli.get(), true)) in TEST_F()
387 tx_task_runner.PostTask([&cli, &buf, send_done] { in TEST_F()
388 cli->Send(buf.get(), kBufSize); in TEST_F()
412 auto cli = in TEST_F() local
416 EXPECT_CALL(event_listener_, OnConnect(cli.get(), true)) in TEST_F()
422 cli->SendStr("test"); in TEST_F()
444 auto cli = in TEST_F() local
447 EXPECT_CALL(event_listener_, OnConnect(cli.get(), true)) in TEST_F()
459 auto cli = in TEST_F() local
463 EXPECT_CALL(event_listener_, OnConnect(cli.get(), true)) in TEST_F()
478 auto cli = in TEST_F() local
481 EXPECT_CALL(event_listener_, OnConnect(cli.get(), true)) in TEST_F()
484 cli.reset(); in TEST_F()
500 auto cli = in TEST_F() local
503 EXPECT_CALL(event_listener_, OnConnect(cli.get(), true)) in TEST_F()
517 auto cli = in TEST_F() local
521 EXPECT_CALL(event_listener_, OnConnect(cli.get(), true)) in TEST_F()
535 std::unique_ptr<UnixSocket> cli[kNumClients]; in TEST_F() local
549 cli[i] = UnixSocket::Connect(host_and_port, &event_listener_, &task_runner_, in TEST_F()
552 EXPECT_CALL(event_listener_, OnDisconnect(cli[i].get())).Times(AtLeast(0)); in TEST_F()
553 EXPECT_CALL(event_listener_, OnConnect(cli[i].get(), true)); in TEST_F()
554 EXPECT_CALL(event_listener_, OnDataAvailable(cli[i].get())) in TEST_F()
566 ASSERT_TRUE(Mock::VerifyAndClearExpectations(cli[i].get())); in TEST_F()
630 auto cli = in TEST_F() local
633 EXPECT_CALL(event_listener_, OnConnect(cli.get(), true)) in TEST_F()
651 cli.reset(); in TEST_F()
663 static constexpr char cli_str[] = "cli>srv"; in TEST_F()
664 static constexpr char srv_str[] = "srv>cli"; in TEST_F()
670 auto cli = in TEST_F() local
673 EXPECT_CALL(event_listener_, OnConnect(cli.get(), true)); in TEST_F()
687 ASSERT_TRUE(cli->is_connected()); in TEST_F()
693 EXPECT_CALL(event_listener_, OnDataAvailable(cli.get())) in TEST_F()
735 cli->Send(cli_str, sizeof(cli_str), buf_fd, base::ArraySize(buf_fd))); in TEST_F()
742 EXPECT_CALL(event_listener_, OnDisconnect(cli.get())) in TEST_F()
744 cli->Shutdown(true); in TEST_F()
797 auto cli = in TEST_F() local
800 EXPECT_CALL(event_listener_, OnConnect(cli.get(), true)); in TEST_F()
802 EXPECT_CALL(event_listener_, OnDataAvailable(cli.get())) in TEST_F()
1079 auto cli = UnixSocketRaw::CreateMayFail(SockFamily::kUnix, SockType::kStream); in TEST_F() local
1083 ASSERT_EQ(0, connect(cli.fd(), reinterpret_cast<struct sockaddr*>(&addr), in TEST_F()
1085 cli.Shutdown(); in TEST_F()
1101 auto cli = UnixSocketRaw::CreateMayFail(SockFamily::kUnix, SockType::kStream); in TEST_F() local
1108 ASSERT_EQ(0, connect(cli.fd(), reinterpret_cast<struct sockaddr*>(&addr), in TEST_F()