[chromedriver] Implement reconnection to DevTools.

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.h"
 #include "base/message_loop_proxy.h"
@@ skipping 25 matching lines @@
   base::WaitableEvent event(false, false);
   thread_.message_loop_proxy()->PostTask(
       FROM_HERE,
       base::Bind(&TestHttpServer::StartOnServerThread,
                  base::Unretained(this), &success, &event));
   event.Wait();
   return success;
 }
 
 void TestHttpServer::Stop() {
+  if (!server_)

[kkania, 2013/02/22 01:35:24]

although net::HttpServer is ThreadSafeRefCounted, the scoped_refptr isn't

[chrisgao (Use stgao instead), 2013/02/27 19:29:44]

Good catch.

The check is to avoid calling thread_.message_loop_proxy()->PostTask after the
thread is stopped.
Instead, check whether the thread is still running or not.

+    return;
   base::WaitableEvent event(false, false);
   thread_.message_loop_proxy()->PostTask(
       FROM_HERE,
       base::Bind(&TestHttpServer::StopOnServerThread,
                  base::Unretained(this), &event));
   event.Wait();
+  thread_.Stop();
 }
 
 bool TestHttpServer::WaitForConnectionsToClose() {
   return all_closed_event_.TimedWait(base::TimeDelta::FromSeconds(10));
 }
 
 void TestHttpServer::SetRequestAction(WebSocketRequestAction action) {
   base::AutoLock lock(action_lock_);
   request_action_ = action;
 }
@@ skipping 78 matching lines @@
   }
   *success = server_;
   event->Signal();
 }
 
 void TestHttpServer::StopOnServerThread(base::WaitableEvent* event) {
   if (server_)
     server_ = NULL;
   event->Signal();
 }