Do not spawn a thread in browser/interactive ui tests before spawning sandbox host process

net/test/embedded_test_server/embedded_test_server.h

 // Copyright (c) 2012 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.
 
 #ifndef NET_TEST_EMBEDDED_TEST_SERVER_EMBEDDED_TEST_SERVER_H_
 #define NET_TEST_EMBEDDED_TEST_SERVER_EMBEDDED_TEST_SERVER_H_
 
 #include <map>
 #include <string>
 #include <vector>
@@ skipping 21 matching lines @@
 
 // This class is required to be able to have composition instead of inheritance,
 class HttpListenSocket : public TCPListenSocket {
  public:
   HttpListenSocket(const SocketDescriptor socket_descriptor,
                    StreamListenSocket::Delegate* delegate);
   virtual ~HttpListenSocket();
   virtual void Listen();
 
  private:
+  friend class EmbeddedTestServer;
+
+  // Detaches the current from |thread_checker_|.
+  void DetachFromThread();
 
   base::ThreadChecker thread_checker_;
 };
 
 // Class providing an HTTP server for testing purpose. This is a basic server
 // providing only an essential subset of HTTP/1.1 protocol. Especially,
 // it assumes that the request syntax is correct. It *does not* support
 // a Chunked Transfer Encoding.
 //
-// The common use case is below:
-//
-// base::Thread io_thread_;
-// scoped_ptr<EmbeddedTestServer> test_server_;
+// The common use case for unit tests is below:
 //
 // void SetUp() {
-//   base::Thread::Options thread_options;
-//   thread_options.message_loop_type = base::MessageLoop::TYPE_IO;
-//   ASSERT_TRUE(io_thread_.StartWithOptions(thread_options));
-//
-//   test_server_.reset(
-//       new EmbeddedTestServer(io_thread_.message_loop_proxy()));
+//   test_server_.reset(new EmbeddedTestServer());
 //   ASSERT_TRUE(test_server_.InitializeAndWaitUntilReady());
 //   test_server_->RegisterRequestHandler(
 //       base::Bind(&FooTest::HandleRequest, base::Unretained(this)));
 // }
 //
 // scoped_ptr<HttpResponse> HandleRequest(const HttpRequest& request) {
 //   GURL absolute_url = test_server_->GetURL(request.relative_url);
 //   if (absolute_url.path() != "/test")
 //     return scoped_ptr<HttpResponse>();
 //
 //   scoped_ptr<HttpResponse> http_response(new HttpResponse());
 //   http_response->set_code(test_server::SUCCESS);
 //   http_response->set_content("hello");
 //   http_response->set_content_type("text/plain");
 //   return http_response.Pass();
 // }
 //
+// For a test that spawns another process such as browser_tests, you
+// need to stop the server's thread so that there is no no other
+// threads running while spawning the process. To do so, please follow
+// the following example:
+//
+// void SetUp() {
+//   test_server_.reset(new EmbeddedTestServer());
+//   // EmbeddedTestServer spawns a thread to initialize socket.
+//   // Stop the thread in preparation for fork and exec.
+//   test_server_->StopThread();
+//   ...
+//   InProcessBrowserTest::SetUp();
+// }
+//
+// void SetUpOnMainThread() {
+//   test_server_->RestartThreadAndListen();
+// }
+//
 class EmbeddedTestServer : public StreamListenSocket::Delegate {
  public:
   typedef base::Callback<scoped_ptr<HttpResponse>(
       const HttpRequest& request)> HandleRequestCallback;
 
   // Creates a http test server. InitializeAndWaitUntilReady() must be called
   // to start the server.
   EmbeddedTestServer();
   virtual ~EmbeddedTestServer();
 
@@ skipping 25 matching lines @@
   // For instance, a request to "/foo.html" is served by "foo.html" under
   // |directory|. Files under sub directories are also handled in the same way
   // (i.e. "/foo/bar.html" is served by "foo/bar.html" under |directory|).
   void ServeFilesFromDirectory(const base::FilePath& directory);
 
   // The most general purpose method. Any request processing can be added using
   // this method. Takes ownership of the object. The |callback| is called
   // on UI thread.
   void RegisterRequestHandler(const HandleRequestCallback& callback);
 
+  // Stops IO thread that handles http requests.
+  void StopThread();
+
+  // Restarts IO thread and listen on the socket.
+  void RestartThreadAndListen();
+
  private:
+  void StartThread();
+
   // Initializes and starts the server. If initialization succeeds, Starts()
   // will return true.
   void InitializeOnIOThread();
+  void ListenOnIOThread();
 
   // Shuts down the server.
   void ShutdownOnIOThread();
 
   // Handles a request when it is parsed. It passes the request to registed
   // request handlers and sends a http response.
   void HandleRequest(HttpConnection* connection,
                      scoped_ptr<HttpRequest> request);
 
   // StreamListenSocket::Delegate overrides:
@@ skipping 28 matching lines @@
 
   base::ThreadChecker thread_checker_;
 
   DISALLOW_COPY_AND_ASSIGN(EmbeddedTestServer);
 };
 
 }  // namespace test_servers
 }  // namespace net
 
 #endif  // NET_TEST_EMBEDDED_TEST_SERVER_EMBEDDED_TEST_SERVER_H_