Index: net/test/embedded_test_server/embedded_test_server.h |
diff --git a/net/test/embedded_test_server/embedded_test_server.h b/net/test/embedded_test_server/embedded_test_server.h |
deleted file mode 100644 |
index 586e1f4d02e4c0159ae5bcd92f52a67859362e2f..0000000000000000000000000000000000000000 |
--- a/net/test/embedded_test_server/embedded_test_server.h |
+++ /dev/null |
@@ -1,212 +0,0 @@ |
-// 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> |
- |
-#include "base/basictypes.h" |
-#include "base/callback.h" |
-#include "base/compiler_specific.h" |
-#include "base/memory/ref_counted.h" |
-#include "base/memory/weak_ptr.h" |
-#include "base/threading/thread.h" |
-#include "base/threading/thread_checker.h" |
-#include "net/socket/tcp_listen_socket.h" |
-#include "url/gurl.h" |
- |
-namespace base { |
-class FilePath; |
-} |
- |
-namespace net { |
-namespace test_server { |
- |
-class HttpConnection; |
-class HttpResponse; |
-struct HttpRequest; |
- |
-// 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); |
- ~HttpListenSocket() override; |
- virtual void Listen(); |
- |
- // Listen on the current IO thread. If the IO thread has changed since this |
- // object is constructed, call |ListenOnIOThread| to make sure it listens on |
- // the right thread. Otherwise must call |Listen| instead. |
- void ListenOnIOThread(); |
- |
- 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 for unit tests is below: |
-// |
-// void SetUp() { |
-// 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, it is |
-// suggested to call InitializeAndWaitUntilReady in SetUpOnMainThread after |
-// the process is spawned. If you have to do it before the process spawns, |
-// 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() { |
-// ASSERT_TRUE(embedded_test_server()->InitializeAndWaitUntilReady()); |
-// // EmbeddedTestServer spawns a thread to initialize socket. |
-// // Stop the thread in preparation for fork and exec. |
-// embedded_test_server()->StopThread(); |
-// ... |
-// InProcessBrowserTest::SetUp(); |
-// } |
-// |
-// void SetUpOnMainThread() { |
-// embedded_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(); |
- ~EmbeddedTestServer() override; |
- |
- // Initializes and waits until the server is ready to accept requests. |
- bool InitializeAndWaitUntilReady() WARN_UNUSED_RESULT; |
- |
- // Shuts down the http server and waits until the shutdown is complete. |
- bool ShutdownAndWaitUntilComplete() WARN_UNUSED_RESULT; |
- |
- // Checks if the server is started. |
- bool Started() const { |
- return listen_socket_.get() != NULL; |
- } |
- |
- // Returns the base URL to the server, which looks like |
- // http://127.0.0.1:<port>/, where <port> is the actual port number used by |
- // the server. |
- const GURL& base_url() const { return base_url_; } |
- |
- // Returns a URL to the server based on the given relative URL, which |
- // should start with '/'. For example: GetURL("/path?query=foo") => |
- // http://127.0.0.1:<port>/path?query=foo. |
- GURL GetURL(const std::string& relative_url) const; |
- |
- // Similar to the above method with the difference that it uses the supplied |
- // |hostname| for the URL instead of 127.0.0.1. The hostname should be |
- // resolved to 127.0.0.1. |
- GURL GetURL(const std::string& hostname, |
- const std::string& relative_url) const; |
- |
- // Returns the port number used by the server. |
- uint16 port() const { return port_; } |
- |
- // Registers request handler which serves files from |directory|. |
- // 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: |
- void DidAccept(StreamListenSocket* server, |
- scoped_ptr<StreamListenSocket> connection) override; |
- void DidRead(StreamListenSocket* connection, |
- const char* data, |
- int length) override; |
- void DidClose(StreamListenSocket* connection) override; |
- |
- HttpConnection* FindConnection(StreamListenSocket* socket); |
- |
- // Posts a task to the |io_thread_| and waits for a reply. |
- bool PostTaskToIOThreadAndWait( |
- const base::Closure& closure) WARN_UNUSED_RESULT; |
- |
- scoped_ptr<base::Thread> io_thread_; |
- |
- scoped_ptr<HttpListenSocket> listen_socket_; |
- uint16 port_; |
- GURL base_url_; |
- |
- // Owns the HttpConnection objects. |
- std::map<StreamListenSocket*, HttpConnection*> connections_; |
- |
- // Vector of registered request handlers. |
- std::vector<HandleRequestCallback> request_handlers_; |
- |
- base::ThreadChecker thread_checker_; |
- |
- // Note: This should remain the last member so it'll be destroyed and |
- // invalidate its weak pointers before any other members are destroyed. |
- base::WeakPtrFactory<EmbeddedTestServer> weak_factory_; |
- |
- DISALLOW_COPY_AND_ASSIGN(EmbeddedTestServer); |
-}; |
- |
-} // namespace test_servers |
-} // namespace net |
- |
-#endif // NET_TEST_EMBEDDED_TEST_SERVER_EMBEDDED_TEST_SERVER_H_ |