Lines Matching refs:accepted
228 scoped_ptr<AsyncSocket> accepted(server->Accept(&accept_addr));
229 ASSERT_TRUE(accepted);
231 EXPECT_EQ(accepted->GetRemoteAddress(), accept_addr);
234 EXPECT_EQ(AsyncSocket::CS_CONNECTED, accepted->GetState());
235 EXPECT_EQ(server->GetLocalAddress(), accepted->GetLocalAddress());
236 EXPECT_EQ(client->GetLocalAddress(), accepted->GetRemoteAddress());
243 EXPECT_EQ(client->GetRemoteAddress(), accepted->GetLocalAddress());
277 scoped_ptr<AsyncSocket> accepted(server->Accept(&accept_addr));
278 ASSERT_TRUE(accepted);
280 EXPECT_EQ(accepted->GetRemoteAddress(), accept_addr);
283 EXPECT_EQ(AsyncSocket::CS_CONNECTED, accepted->GetState());
284 EXPECT_EQ(server->GetLocalAddress(), accepted->GetLocalAddress());
285 EXPECT_EQ(client->GetLocalAddress(), accepted->GetRemoteAddress());
292 EXPECT_EQ(client->GetRemoteAddress(), accepted->GetLocalAddress());
407 scoped_ptr<AsyncSocket> accepted(server->Accept(&accept_addr));
408 ASSERT_TRUE(accepted);
412 EXPECT_EQ(AsyncSocket::CS_CONNECTED, accepted->GetState());
413 EXPECT_EQ(server->GetLocalAddress(), accepted->GetLocalAddress());
414 EXPECT_EQ(client->GetLocalAddress(), accepted->GetRemoteAddress());
417 EXPECT_EQ(client->GetRemoteAddress(), accepted->GetLocalAddress());
424 EXPECT_EQ(AsyncSocket::CS_CONNECTED, accepted->GetState());
427 EXPECT_EQ(client->GetRemoteAddress(), accepted->GetLocalAddress());
481 // The connection should still be able to be accepted.
482 scoped_ptr<AsyncSocket> accepted(server->Accept(&accept_addr));
483 ASSERT_TRUE(accepted);
484 sink.Monitor(accepted.get());
485 EXPECT_EQ(AsyncSocket::CS_CONNECTED, accepted->GetState());
487 // The accepted socket should then close (possibly with err, timing-related)
488 EXPECT_EQ_WAIT(AsyncSocket::CS_CLOSED, accepted->GetState(), kTimeout);
489 EXPECT_TRUE(sink.Check(accepted.get(), testing::SSE_CLOSE) ||
490 sink.Check(accepted.get(), testing::SSE_ERROR));
517 scoped_ptr<AsyncSocket> accepted(server->Accept(&accept_addr));
518 ASSERT_TRUE(accepted);
519 sink.Monitor(accepted.get());
524 EXPECT_EQ(client->GetRemoteAddress(), accepted->GetLocalAddress());
525 EXPECT_EQ(accepted->GetRemoteAddress(), client->GetLocalAddress());
528 EXPECT_EQ(1, accepted->Send("a", 1));
529 accepted->Close();
530 EXPECT_EQ(AsyncSocket::CS_CLOSED, accepted->GetState());
548 EXPECT_FALSE(sink.Check(accepted.get(), testing::SSE_CLOSE));
549 EXPECT_TRUE(accepted->GetRemoteAddress().IsNil());
592 scoped_ptr<AsyncSocket> accepted(server->Accept(&accept_addr));
593 ASSERT_TRUE(accepted);
594 sink.Monitor(accepted.get());
599 EXPECT_EQ(client->GetRemoteAddress(), accepted->GetLocalAddress());
600 EXPECT_EQ(accepted->GetRemoteAddress(), client->GetLocalAddress());
603 accepted->Close();
604 EXPECT_EQ(AsyncSocket::CS_CLOSED, accepted->GetState());
641 scoped_ptr<AsyncSocket> accepted(server->Accept(&accept_addr));
642 ASSERT_TRUE(accepted);
643 sink.Monitor(accepted.get());
644 EXPECT_EQ(AsyncSocket::CS_CONNECTED, accepted->GetState());
645 EXPECT_EQ(server->GetLocalAddress(), accepted->GetLocalAddress());
646 EXPECT_EQ(client->GetLocalAddress(), accepted->GetRemoteAddress());
652 EXPECT_EQ(client->GetRemoteAddress(), accepted->GetLocalAddress());
655 EXPECT_FALSE(sink.Check(accepted.get(), testing::SSE_READ));
659 EXPECT_FALSE(sink.Check(accepted.get(), testing::SSE_READ));
667 EXPECT_FALSE(sink.Check(accepted.get(), testing::SSE_READ));
670 EXPECT_TRUE_WAIT((sink.Check(accepted.get(), testing::SSE_READ)), kTimeout);
671 EXPECT_LT(0, accepted->Recv(buf, 1024));
705 scoped_ptr<AsyncSocket> accepted(server->Accept(&accept_addr));
706 ASSERT_TRUE(accepted);
707 sink.Monitor(accepted.get());
712 EXPECT_EQ(client->GetRemoteAddress(), accepted->GetLocalAddress());
713 EXPECT_EQ(accepted->GetRemoteAddress(), client->GetLocalAddress());
725 int sent = accepted->Send(send_buffer.get() + send_pos, tosend);
737 ASSERT_TRUE(accepted->IsBlocking());
775 EXPECT_TRUE_WAIT(sink.Check(accepted.get(), testing::SSE_WRITE),
788 accepted->Close();
815 scoped_ptr<AsyncSocket> accepted(server->Accept(&accept_addr));
816 ASSERT_TRUE(accepted);
817 sink.Monitor(accepted.get());
822 EXPECT_EQ(client->GetRemoteAddress(), accepted->GetLocalAddress());
823 EXPECT_EQ(accepted->GetRemoteAddress(), client->GetLocalAddress());
826 EXPECT_TRUE_WAIT(sink.Check(accepted.get(), testing::SSE_WRITE), kTimeout);
831 while (++sends && accepted->Send(&buf, arraysize(buf)) != -1) {}
832 EXPECT_TRUE(accepted->IsBlocking());
843 EXPECT_TRUE_WAIT(sink.Check(accepted.get(), testing::SSE_WRITE), kTimeout);
849 accepted->Send(&buf, arraysize(buf));
851 if (sink.Check(accepted.get(), testing::SSE_WRITE)) {
858 accepted->Close();
