Lines Matching refs:client
236 std::unique_ptr<AsyncSocket> client( in ConnectInternal() local
238 sink.Monitor(client.get()); in ConnectInternal()
239 EXPECT_EQ(AsyncSocket::CS_CLOSED, client->GetState()); in ConnectInternal()
240 EXPECT_TRUE(IsUnspecOrEmptyIP(client->GetLocalAddress().ipaddr())); in ConnectInternal()
256 EXPECT_EQ(0, client->Connect(server->GetLocalAddress())); in ConnectInternal()
257 EXPECT_FALSE(client->GetLocalAddress().IsNil()); in ConnectInternal()
258 EXPECT_NE(server->GetLocalAddress(), client->GetLocalAddress()); in ConnectInternal()
261 EXPECT_EQ(AsyncSocket::CS_CONNECTING, client->GetState()); in ConnectInternal()
262 EXPECT_FALSE(sink.Check(client.get(), SSE_OPEN)); in ConnectInternal()
263 EXPECT_FALSE(sink.Check(client.get(), SSE_CLOSE)); in ConnectInternal()
275 EXPECT_EQ(client->GetLocalAddress(), accepted->GetRemoteAddress()); in ConnectInternal()
278 EXPECT_EQ_WAIT(AsyncSocket::CS_CONNECTED, client->GetState(), kTimeout); in ConnectInternal()
279 EXPECT_TRUE(sink.Check(client.get(), SSE_OPEN)); in ConnectInternal()
280 EXPECT_FALSE(sink.Check(client.get(), SSE_CLOSE)); in ConnectInternal()
281 EXPECT_EQ(client->GetRemoteAddress(), server->GetLocalAddress()); in ConnectInternal()
282 EXPECT_EQ(client->GetRemoteAddress(), accepted->GetLocalAddress()); in ConnectInternal()
291 std::unique_ptr<AsyncSocket> client( in ConnectWithDnsLookupInternal() local
293 sink.Monitor(client.get()); in ConnectWithDnsLookupInternal()
305 EXPECT_EQ(0, client->Connect(dns_addr)); in ConnectWithDnsLookupInternal()
310 EXPECT_EQ(AsyncSocket::CS_CONNECTING, client->GetState()); in ConnectWithDnsLookupInternal()
311 EXPECT_FALSE(sink.Check(client.get(), SSE_OPEN)); in ConnectWithDnsLookupInternal()
312 EXPECT_FALSE(sink.Check(client.get(), SSE_CLOSE)); in ConnectWithDnsLookupInternal()
324 EXPECT_EQ(client->GetLocalAddress(), accepted->GetRemoteAddress()); in ConnectWithDnsLookupInternal()
327 EXPECT_EQ_WAIT(AsyncSocket::CS_CONNECTED, client->GetState(), kTimeout); in ConnectWithDnsLookupInternal()
328 EXPECT_TRUE(sink.Check(client.get(), SSE_OPEN)); in ConnectWithDnsLookupInternal()
329 EXPECT_FALSE(sink.Check(client.get(), SSE_CLOSE)); in ConnectWithDnsLookupInternal()
330 EXPECT_EQ(client->GetRemoteAddress(), server->GetLocalAddress()); in ConnectWithDnsLookupInternal()
331 EXPECT_EQ(client->GetRemoteAddress(), accepted->GetLocalAddress()); in ConnectWithDnsLookupInternal()
339 std::unique_ptr<AsyncSocket> client( in ConnectFailInternal() local
341 sink.Monitor(client.get()); in ConnectFailInternal()
353 EXPECT_EQ(0, client->Connect(bogus_addr)); in ConnectFailInternal()
356 EXPECT_EQ_WAIT(AsyncSocket::CS_CLOSED, client->GetState(), kTimeout); in ConnectFailInternal()
357 EXPECT_FALSE(sink.Check(client.get(), SSE_OPEN)); in ConnectFailInternal()
358 EXPECT_TRUE(sink.Check(client.get(), SSE_ERROR)); in ConnectFailInternal()
359 EXPECT_TRUE(client->GetRemoteAddress().IsNil()); in ConnectFailInternal()
372 std::unique_ptr<AsyncSocket> client( in ConnectWithDnsLookupFailInternal() local
374 sink.Monitor(client.get()); in ConnectWithDnsLookupFailInternal()
386 EXPECT_EQ(0, client->Connect(bogus_dns_addr)); in ConnectWithDnsLookupFailInternal()
390 WAIT_(client->GetState() == AsyncSocket::CS_CLOSED, kTimeout, in ConnectWithDnsLookupFailInternal()
398 EXPECT_EQ_WAIT(AsyncSocket::CS_CLOSED, client->GetState(), kTimeout); in ConnectWithDnsLookupFailInternal()
399 EXPECT_FALSE(sink.Check(client.get(), SSE_OPEN)); in ConnectWithDnsLookupFailInternal()
400 EXPECT_TRUE(sink.Check(client.get(), SSE_ERROR)); in ConnectWithDnsLookupFailInternal()
401 EXPECT_TRUE(client->GetRemoteAddress().IsNil()); in ConnectWithDnsLookupFailInternal()
416 std::unique_ptr<AsyncSocket> client( in ConnectWithClosedSocketInternal() local
418 EXPECT_EQ(0, client->Close()); in ConnectWithClosedSocketInternal()
419 EXPECT_EQ(AsyncSocket::CS_CLOSED, client->GetState()); in ConnectWithClosedSocketInternal()
422 EXPECT_EQ(0, client->Connect(SocketAddress(server->GetLocalAddress()))); in ConnectWithClosedSocketInternal()
423 EXPECT_EQ(AsyncSocket::CS_CONNECTING, client->GetState()); in ConnectWithClosedSocketInternal()
435 std::unique_ptr<AsyncSocket> client( in ConnectWhileNotClosedInternal() local
437 EXPECT_EQ(0, client->Connect(SocketAddress(server->GetLocalAddress()))); in ConnectWhileNotClosedInternal()
438 EXPECT_EQ(AsyncSocket::CS_CONNECTING, client->GetState()); in ConnectWhileNotClosedInternal()
441 client->Connect(SocketAddress(server->GetLocalAddress()))); in ConnectWhileNotClosedInternal()
453 EXPECT_EQ(client->GetLocalAddress(), accepted->GetRemoteAddress()); in ConnectWhileNotClosedInternal()
454 EXPECT_EQ_WAIT(AsyncSocket::CS_CONNECTED, client->GetState(), kTimeout); in ConnectWhileNotClosedInternal()
455 EXPECT_EQ(client->GetRemoteAddress(), server->GetLocalAddress()); in ConnectWhileNotClosedInternal()
456 EXPECT_EQ(client->GetRemoteAddress(), accepted->GetLocalAddress()); in ConnectWhileNotClosedInternal()
460 EXPECT_EQ(SOCKET_ERROR, client->Connect(SocketAddress( in ConnectWhileNotClosedInternal()
463 EXPECT_EQ(AsyncSocket::CS_CONNECTED, client->GetState()); in ConnectWhileNotClosedInternal()
464 EXPECT_EQ(client->GetRemoteAddress(), server->GetLocalAddress()); in ConnectWhileNotClosedInternal()
465 EXPECT_EQ(client->GetRemoteAddress(), accepted->GetLocalAddress()); in ConnectWhileNotClosedInternal()
472 std::unique_ptr<AsyncSocket> client( in ServerCloseDuringConnectInternal() local
474 sink.Monitor(client.get()); in ServerCloseDuringConnectInternal()
484 EXPECT_EQ(0, client->Connect(server->GetLocalAddress())); in ServerCloseDuringConnectInternal()
491 EXPECT_EQ_WAIT(AsyncSocket::CS_CLOSED, client->GetState(), kTimeout); in ServerCloseDuringConnectInternal()
492 EXPECT_TRUE(sink.Check(client.get(), SSE_ERROR)); in ServerCloseDuringConnectInternal()
493 client->Close(); in ServerCloseDuringConnectInternal()
501 std::unique_ptr<AsyncSocket> client( in ClientCloseDuringConnectInternal() local
503 sink.Monitor(client.get()); in ClientCloseDuringConnectInternal()
513 EXPECT_EQ(0, client->Connect(server->GetLocalAddress())); in ClientCloseDuringConnectInternal()
517 client->Close(); in ClientCloseDuringConnectInternal()
531 EXPECT_FALSE(sink.Check(client.get(), SSE_CLOSE)); in ClientCloseDuringConnectInternal()
539 std::unique_ptr<AsyncSocket> client( in ServerCloseInternal() local
541 sink.Monitor(client.get()); in ServerCloseInternal()
551 EXPECT_EQ(0, client->Connect(server->GetLocalAddress())); in ServerCloseInternal()
560 EXPECT_EQ_WAIT(AsyncSocket::CS_CONNECTED, client->GetState(), kTimeout); in ServerCloseInternal()
561 EXPECT_TRUE(sink.Check(client.get(), SSE_OPEN)); in ServerCloseInternal()
562 EXPECT_EQ(client->GetRemoteAddress(), accepted->GetLocalAddress()); in ServerCloseInternal()
563 EXPECT_EQ(accepted->GetRemoteAddress(), client->GetLocalAddress()); in ServerCloseInternal()
571 EXPECT_TRUE_WAIT(sink.Check(client.get(), SSE_READ), kTimeout); in ServerCloseInternal()
572 EXPECT_FALSE(sink.Check(client.get(), SSE_CLOSE)); in ServerCloseInternal()
573 EXPECT_EQ(AsyncSocket::CS_CONNECTED, client->GetState()); in ServerCloseInternal()
577 EXPECT_EQ(1, client->Recv(buffer, sizeof(buffer), nullptr)); in ServerCloseInternal()
581 EXPECT_EQ_WAIT(AsyncSocket::CS_CLOSED, client->GetState(), kTimeout); in ServerCloseInternal()
582 EXPECT_TRUE(sink.Check(client.get(), SSE_CLOSE)); in ServerCloseInternal()
583 EXPECT_FALSE(client->GetRemoteAddress().IsAnyIP()); in ServerCloseInternal()
591 EXPECT_FALSE(sink.Check(client.get(), SSE_CLOSE)); in ServerCloseInternal()
594 client->Close(); in ServerCloseInternal()
595 EXPECT_FALSE(sink.Check(client.get(), SSE_CLOSE)); in ServerCloseInternal()
596 EXPECT_TRUE(client->GetRemoteAddress().IsNil()); in ServerCloseInternal()
613 std::unique_ptr<AsyncSocket> client( in CloseInClosedCallbackInternal() local
615 sink.Monitor(client.get()); in CloseInClosedCallbackInternal()
616 client->SignalCloseEvent.connect(&closer, &SocketCloser::OnClose); in CloseInClosedCallbackInternal()
626 EXPECT_EQ(0, client->Connect(server->GetLocalAddress())); in CloseInClosedCallbackInternal()
635 EXPECT_EQ_WAIT(AsyncSocket::CS_CONNECTED, client->GetState(), kTimeout); in CloseInClosedCallbackInternal()
636 EXPECT_TRUE(sink.Check(client.get(), SSE_OPEN)); in CloseInClosedCallbackInternal()
637 EXPECT_EQ(client->GetRemoteAddress(), accepted->GetLocalAddress()); in CloseInClosedCallbackInternal()
638 EXPECT_EQ(accepted->GetRemoteAddress(), client->GetLocalAddress()); in CloseInClosedCallbackInternal()
645 EXPECT_FALSE(sink.Check(client.get(), SSE_CLOSE)); in CloseInClosedCallbackInternal()
646 EXPECT_EQ(AsyncSocket::CS_CONNECTED, client->GetState()); in CloseInClosedCallbackInternal()
649 EXPECT_EQ_WAIT(AsyncSocket::CS_CLOSED, client->GetState(), kTimeout); in CloseInClosedCallbackInternal()
650 EXPECT_TRUE(sink.Check(client.get(), SSE_CLOSE)); in CloseInClosedCallbackInternal()
651 EXPECT_TRUE(Socket::CS_CLOSED == client->GetState()); in CloseInClosedCallbackInternal()
664 std::unique_ptr<AsyncSocket> client( in SocketServerWaitInternal() local
668 sink.Monitor(client.get()); in SocketServerWaitInternal()
673 EXPECT_EQ(0, client->Connect(server->GetLocalAddress())); in SocketServerWaitInternal()
681 EXPECT_EQ(client->GetLocalAddress(), accepted->GetRemoteAddress()); in SocketServerWaitInternal()
683 EXPECT_EQ_WAIT(AsyncSocket::CS_CONNECTED, client->GetState(), kTimeout); in SocketServerWaitInternal()
684 EXPECT_TRUE(sink.Check(client.get(), SSE_OPEN)); in SocketServerWaitInternal()
685 EXPECT_FALSE(sink.Check(client.get(), SSE_CLOSE)); in SocketServerWaitInternal()
686 EXPECT_EQ(client->GetRemoteAddress(), server->GetLocalAddress()); in SocketServerWaitInternal()
687 EXPECT_EQ(client->GetRemoteAddress(), accepted->GetLocalAddress()); in SocketServerWaitInternal()
693 EXPECT_EQ(1024, client->Send(buf, 1024)); in SocketServerWaitInternal()
700 TypedMessageData<AsyncSocket*> data(client.get()); in SocketServerWaitInternal()
842 std::unique_ptr<AsyncSocket> client( in SingleFlowControlCallbackInternal() local
844 sink.Monitor(client.get()); in SingleFlowControlCallbackInternal()
854 EXPECT_EQ(0, client->Connect(server->GetLocalAddress())); in SingleFlowControlCallbackInternal()
863 EXPECT_EQ_WAIT(AsyncSocket::CS_CONNECTED, client->GetState(), kTimeout); in SingleFlowControlCallbackInternal()
864 EXPECT_TRUE(sink.Check(client.get(), SSE_OPEN)); in SingleFlowControlCallbackInternal()
865 EXPECT_EQ(client->GetRemoteAddress(), accepted->GetLocalAddress()); in SingleFlowControlCallbackInternal()
866 EXPECT_EQ(accepted->GetRemoteAddress(), client->GetLocalAddress()); in SingleFlowControlCallbackInternal()
879 EXPECT_TRUE_WAIT(sink.Check(client.get(), SSE_READ), kTimeout); in SingleFlowControlCallbackInternal()
883 client->Recv(buf, arraysize(buf), nullptr); in SingleFlowControlCallbackInternal()
903 client->Close(); in SingleFlowControlCallbackInternal()
962 std::unique_ptr<TestClient> client( in UdpReadyToSend() local
974 client->SetOption(rtc::Socket::OPT_SNDBUF, send_buffer_size); in UdpReadyToSend()
981 int ret = client->SendTo(test_packet.get(), test_packet_size, test_addr); in UdpReadyToSend()
984 error = client->GetError(); in UdpReadyToSend()
993 EXPECT_FALSE(client->ready_to_send()); in UdpReadyToSend()
994 EXPECT_TRUE_WAIT(client->ready_to_send(), kTimeout); in UdpReadyToSend()