Index: net/base/listen_socket_unittest.cc |
diff --git a/net/base/listen_socket_unittest.cc b/net/base/listen_socket_unittest.cc |
index 53fc79ba57e8ce6ed1f8fe9f673e0a062915da3b..75beeec257694ad9890c2238a6ade1372f7aa3a8 100644 |
--- a/net/base/listen_socket_unittest.cc |
+++ b/net/base/listen_socket_unittest.cc |
@@ -19,8 +19,12 @@ static const int kMaxQueueSize = 20; |
static const char kLoopback[] = "127.0.0.1"; |
static const int kDefaultTimeoutMs = 5000; |
-ListenSocket* ListenSocketTester::DoListen() { |
- return ListenSocket::Listen(kLoopback, kTestPort, this); |
+ListenSocketTester::ListenSocketTester() |
+ : thread_(NULL), |
+ loop_(NULL), |
+ server_(NULL), |
+ connection_(NULL), |
+ cv_(&lock_) { |
} |
void ListenSocketTester::SetUp() { |
@@ -121,36 +125,6 @@ void ListenSocketTester::SendFromTester() { |
ReportAction(ListenSocketTestAction(ACTION_SEND)); |
} |
-void ListenSocketTester::DidAccept(ListenSocket *server, |
- ListenSocket *connection) { |
- connection_ = connection; |
- connection_->AddRef(); |
- ReportAction(ListenSocketTestAction(ACTION_ACCEPT)); |
-} |
- |
-void ListenSocketTester::DidRead(ListenSocket *connection, |
- const char* data, |
- int len) { |
- std::string str(data, len); |
- ReportAction(ListenSocketTestAction(ACTION_READ, str)); |
-} |
- |
-void ListenSocketTester::DidClose(ListenSocket *sock) { |
- ReportAction(ListenSocketTestAction(ACTION_CLOSE)); |
-} |
- |
-bool ListenSocketTester::Send(SOCKET sock, const std::string& str) { |
- int len = static_cast<int>(str.length()); |
- int send_len = HANDLE_EINTR(send(sock, str.data(), len, 0)); |
- if (send_len == SOCKET_ERROR) { |
- LOG(ERROR) << "send failed: " << errno; |
- return false; |
- } else if (send_len != len) { |
- return false; |
- } |
- return true; |
-} |
- |
void ListenSocketTester::TestClientSend() { |
ASSERT_TRUE(Send(test_socket_, kHelloWorld)); |
NextAction(); |
@@ -200,6 +174,42 @@ void ListenSocketTester::TestServerSend() { |
ASSERT_STREQ(buf, kHelloWorld); |
} |
+bool ListenSocketTester::Send(SOCKET sock, const std::string& str) { |
+ int len = static_cast<int>(str.length()); |
+ int send_len = HANDLE_EINTR(send(sock, str.data(), len, 0)); |
+ if (send_len == SOCKET_ERROR) { |
+ LOG(ERROR) << "send failed: " << errno; |
+ return false; |
+ } else if (send_len != len) { |
+ return false; |
+ } |
+ return true; |
+} |
+ |
+void ListenSocketTester::DidAccept(ListenSocket *server, |
+ ListenSocket *connection) { |
+ connection_ = connection; |
+ connection_->AddRef(); |
+ ReportAction(ListenSocketTestAction(ACTION_ACCEPT)); |
+} |
+ |
+void ListenSocketTester::DidRead(ListenSocket *connection, |
+ const char* data, |
+ int len) { |
+ std::string str(data, len); |
+ ReportAction(ListenSocketTestAction(ACTION_READ, str)); |
+} |
+ |
+void ListenSocketTester::DidClose(ListenSocket *sock) { |
+ ReportAction(ListenSocketTestAction(ACTION_CLOSE)); |
+} |
+ |
+ListenSocketTester::~ListenSocketTester() {} |
+ |
+ListenSocket* ListenSocketTester::DoListen() { |
+ return ListenSocket::Listen(kLoopback, kTestPort, this); |
+} |
+ |
class ListenSocketTest: public PlatformTest { |
public: |