| 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:
|
|
|