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