• Home
  • Raw
  • Download

Lines Matching refs:AsyncSocket

57   Sender(Thread* th, AsyncSocket* s, uint32_t rt)  in Sender()
103 Receiver(Thread* th, AsyncSocket* s, uint32_t bw) in Receiver()
198 AsyncSocket* socket = in TestDefaultRoute()
207 AsyncSocket* socket2 = in TestDefaultRoute()
229 AsyncSocket* socket = in BasicTest()
238 AsyncSocket* socket2 = in BasicTest()
280 std::unique_ptr<AsyncSocket> client = absl::WrapUnique( in ConnectTest()
283 EXPECT_EQ(client->GetState(), AsyncSocket::CS_CLOSED); in ConnectTest()
287 std::unique_ptr<AsyncSocket> server = absl::WrapUnique( in ConnectTest()
294 EXPECT_EQ(server->GetState(), AsyncSocket::CS_CONNECTING); in ConnectTest()
308 EXPECT_EQ(client->GetState(), AsyncSocket::CS_CONNECTING); in ConnectTest()
315 EXPECT_EQ(client->GetState(), AsyncSocket::CS_CONNECTING); in ConnectTest()
327 EXPECT_EQ(accepted->GetState(), AsyncSocket::CS_CONNECTED); in ConnectTest()
334 EXPECT_EQ(client->GetState(), AsyncSocket::CS_CONNECTED); in ConnectTest()
349 std::unique_ptr<AsyncSocket> client = absl::WrapUnique( in ConnectToNonListenerTest()
354 std::unique_ptr<AsyncSocket> server = absl::WrapUnique( in ConnectToNonListenerTest()
370 EXPECT_EQ(client->GetState(), AsyncSocket::CS_CLOSED); in ConnectToNonListenerTest()
383 std::unique_ptr<AsyncSocket> client( in CloseDuringConnectTest()
386 std::unique_ptr<AsyncSocket> server( in CloseDuringConnectTest()
404 EXPECT_EQ(client->GetState(), AsyncSocket::CS_CLOSED); in CloseDuringConnectTest()
426 EXPECT_EQ(client->GetState(), AsyncSocket::CS_CLOSED); in CloseDuringConnectTest()
444 std::unique_ptr<AsyncSocket> accepted(server->Accept(&accept_addr)); in CloseDuringConnectTest()
449 EXPECT_EQ(accepted->GetState(), AsyncSocket::CS_CONNECTED); in CloseDuringConnectTest()
452 EXPECT_EQ(client->GetState(), AsyncSocket::CS_CONNECTING); in CloseDuringConnectTest()
458 EXPECT_EQ(accepted->GetState(), AsyncSocket::CS_CLOSED); in CloseDuringConnectTest()
468 std::unique_ptr<AsyncSocket> a = absl::WrapUnique( in CloseTest()
474 std::unique_ptr<AsyncSocket> b = absl::WrapUnique( in CloseTest()
486 EXPECT_EQ(a->GetState(), AsyncSocket::CS_CONNECTED); in CloseTest()
490 EXPECT_EQ(b->GetState(), AsyncSocket::CS_CONNECTED); in CloseTest()
504 EXPECT_EQ(a->GetState(), AsyncSocket::CS_CLOSED); in CloseTest()
509 EXPECT_EQ(b->GetState(), AsyncSocket::CS_CLOSED); in CloseTest()
518 std::unique_ptr<AsyncSocket> a = absl::WrapUnique( in TcpSendTest()
524 std::unique_ptr<AsyncSocket> b = absl::WrapUnique( in TcpSendTest()
640 std::unique_ptr<AsyncSocket> a = absl::WrapUnique( in TcpSendsPacketsInOrderTest()
642 std::unique_ptr<AsyncSocket> b = absl::WrapUnique( in TcpSendsPacketsInOrderTest()
694 AsyncSocket* send_socket = in BandwidthTest()
696 AsyncSocket* recv_socket = in BandwidthTest()
739 AsyncSocket* send_socket = in DelayTest()
741 AsyncSocket* recv_socket = in DelayTest()
791 std::unique_ptr<AsyncSocket> client = absl::WrapUnique( in CrossFamilyConnectionTest()
794 EXPECT_EQ(client->GetState(), AsyncSocket::CS_CLOSED); in CrossFamilyConnectionTest()
800 std::unique_ptr<AsyncSocket> server = absl::WrapUnique( in CrossFamilyConnectionTest()
825 EXPECT_EQ(client->GetState(), AsyncSocket::CS_CLOSED); in CrossFamilyConnectionTest()
837 AsyncSocket* socket = ss_.CreateAsyncSocket(AF_INET, SOCK_DGRAM); in CrossFamilyDatagramTest()
843 AsyncSocket* socket2 = ss_.CreateAsyncSocket(AF_INET, SOCK_DGRAM); in CrossFamilyDatagramTest()
1045 AsyncSocket* socket1 = in TEST_F()
1047 std::unique_ptr<AsyncSocket> socket2 = absl::WrapUnique( in TEST_F()
1070 std::unique_ptr<AsyncSocket> socket1 = absl::WrapUnique( in TEST_F()
1072 std::unique_ptr<AsyncSocket> socket2 = absl::WrapUnique( in TEST_F()