Revert of Replace StreamListenSocket with StreamSocket in HttpServer.

chrome/test/chromedriver/net/test_http_server.cc

 // Copyright (c) 2013 The Chromium Authors. All rights reserved.
 // Use of this source code is governed by a BSD-style license that can be
 // found in the LICENSE file.
 
 #include "chrome/test/chromedriver/net/test_http_server.h"
 
 #include "base/bind.h"
 #include "base/location.h"
 #include "base/message_loop/message_loop.h"
 #include "base/message_loop/message_loop_proxy.h"
 #include "base/strings/stringprintf.h"
 #include "base/time/time.h"
 #include "net/base/ip_endpoint.h"
 #include "net/base/net_errors.h"
 #include "net/server/http_server_request_info.h"
-#include "net/socket/tcp_server_socket.h"
+#include "net/socket/tcp_listen_socket.h"
 #include "testing/gtest/include/gtest/gtest.h"
 
 TestHttpServer::TestHttpServer()
     : thread_("ServerThread"),
       all_closed_event_(false, true),
       request_action_(kAccept),
       message_action_(kEchoMessage) {
 }
 
 TestHttpServer::~TestHttpServer() {
@@ skipping 58 matching lines @@
   all_closed_event_.Reset();
 
   switch (action) {
     case kAccept:
       server_->AcceptWebSocket(connection_id, info);
       break;
     case kNotFound:
       server_->Send404(connection_id);
       break;
     case kClose:
-      server_->Close(connection_id);
+      // net::HttpServer doesn't allow us to close connection during callback.
+      base::MessageLoop::current()->PostTask(
+          FROM_HERE,
+          base::Bind(&net::HttpServer::Close, server_, connection_id));
       break;
   }
 }
 
 void TestHttpServer::OnWebSocketMessage(int connection_id,
                                         const std::string& data) {
   WebSocketMessageAction action;
   {
     base::AutoLock lock(action_lock_);
     action = message_action_;
   }
   switch (action) {
     case kEchoMessage:
       server_->SendOverWebSocket(connection_id, data);
       break;
     case kCloseOnMessage:
-      server_->Close(connection_id);
+      // net::HttpServer doesn't allow us to close connection during callback.
+      base::MessageLoop::current()->PostTask(
+          FROM_HERE,
+          base::Bind(&net::HttpServer::Close, server_, connection_id));
       break;
   }
 }
 
 void TestHttpServer::OnClose(int connection_id) {
   connections_.erase(connection_id);
   if (connections_.empty())
     all_closed_event_.Signal();
 }
 
 void TestHttpServer::StartOnServerThread(bool* success,
                                          base::WaitableEvent* event) {
-  scoped_ptr<net::ServerSocket> server_socket(
-      new net::TCPServerSocket(NULL, net::NetLog::Source()));
-  server_socket->ListenWithAddressAndPort("127.0.0.1", 0, 1);
-  server_.reset(new net::HttpServer(server_socket.Pass(), this));
+  net::TCPListenSocketFactory factory("127.0.0.1", 0);
+  server_ = new net::HttpServer(factory, this);
 
   net::IPEndPoint address;
   int error = server_->GetLocalAddress(&address);
   EXPECT_EQ(net::OK, error);
   if (error == net::OK) {
     base::AutoLock lock(url_lock_);
     web_socket_url_ = GURL(base::StringPrintf("ws://127.0.0.1:%d",
                                               address.port()));
   } else {
-    server_.reset(NULL);
+    server_ = NULL;
   }
   *success = server_.get();
   event->Signal();
 }
 
 void TestHttpServer::StopOnServerThread(base::WaitableEvent* event) {
-  server_.reset(NULL);
+  if (server_.get())
+    server_ = NULL;
   event->Signal();
 }