| Index: net/test/embedded_test_server/embedded_test_server.cc
|
| diff --git a/net/test/embedded_test_server/http_server.cc b/net/test/embedded_test_server/embedded_test_server.cc
|
| similarity index 75%
|
| rename from net/test/embedded_test_server/http_server.cc
|
| rename to net/test/embedded_test_server/embedded_test_server.cc
|
| index 165ac1be955911cab96c5c2479d2e4d0dbecba5f..c42ff639f241cfe176416f9954fef2976030ff12 100644
|
| --- a/net/test/embedded_test_server/http_server.cc
|
| +++ b/net/test/embedded_test_server/embedded_test_server.cc
|
| @@ -2,7 +2,7 @@
|
| // Use of this source code is governed by a BSD-style license that can be
|
| // found in the LICENSE file.
|
|
|
| -#include "net/test/embedded_test_server/http_server.h"
|
| +#include "net/test/embedded_test_server/embedded_test_server.h"
|
|
|
| #include "base/bind.h"
|
| #include "base/run_loop.h"
|
| @@ -14,7 +14,7 @@
|
| #include "net/test/embedded_test_server/http_response.h"
|
| #include "net/tools/fetch/http_listen_socket.h"
|
|
|
| -namespace google_apis {
|
| +namespace net {
|
| namespace test_server {
|
|
|
| namespace {
|
| @@ -37,21 +37,21 @@ scoped_ptr<HttpResponse> HandleDefaultRequest(const GURL& url,
|
| } // namespace
|
|
|
| HttpListenSocket::HttpListenSocket(const SocketDescriptor socket_descriptor,
|
| - net::StreamListenSocket::Delegate* delegate)
|
| - : net::TCPListenSocket(socket_descriptor, delegate) {
|
| + StreamListenSocket::Delegate* delegate)
|
| + : TCPListenSocket(socket_descriptor, delegate) {
|
| DCHECK(thread_checker_.CalledOnValidThread());
|
| }
|
|
|
| void HttpListenSocket::Listen() {
|
| DCHECK(thread_checker_.CalledOnValidThread());
|
| - net::TCPListenSocket::Listen();
|
| + TCPListenSocket::Listen();
|
| }
|
|
|
| HttpListenSocket::~HttpListenSocket() {
|
| DCHECK(thread_checker_.CalledOnValidThread());
|
| }
|
|
|
| -HttpServer::HttpServer(
|
| +EmbeddedTestServer::EmbeddedTestServer(
|
| const scoped_refptr<base::SingleThreadTaskRunner>& io_thread)
|
| : io_thread_(io_thread),
|
| port_(-1),
|
| @@ -60,17 +60,18 @@ HttpServer::HttpServer(
|
| DCHECK(thread_checker_.CalledOnValidThread());
|
| }
|
|
|
| -HttpServer::~HttpServer() {
|
| +EmbeddedTestServer::~EmbeddedTestServer() {
|
| DCHECK(thread_checker_.CalledOnValidThread());
|
| }
|
|
|
| -bool HttpServer::InitializeAndWaitUntilReady() {
|
| +bool EmbeddedTestServer::InitializeAndWaitUntilReady() {
|
| DCHECK(thread_checker_.CalledOnValidThread());
|
|
|
| base::RunLoop run_loop;
|
| if (!io_thread_->PostTaskAndReply(
|
| FROM_HERE,
|
| - base::Bind(&HttpServer::InitializeOnIOThread, base::Unretained(this)),
|
| + base::Bind(&EmbeddedTestServer::InitializeOnIOThread,
|
| + base::Unretained(this)),
|
| run_loop.QuitClosure())) {
|
| return false;
|
| }
|
| @@ -79,13 +80,14 @@ bool HttpServer::InitializeAndWaitUntilReady() {
|
| return Started();
|
| }
|
|
|
| -bool HttpServer::ShutdownAndWaitUntilComplete() {
|
| +bool EmbeddedTestServer::ShutdownAndWaitUntilComplete() {
|
| DCHECK(thread_checker_.CalledOnValidThread());
|
|
|
| base::RunLoop run_loop;
|
| if (!io_thread_->PostTaskAndReply(
|
| FROM_HERE,
|
| - base::Bind(&HttpServer::ShutdownOnIOThread, base::Unretained(this)),
|
| + base::Bind(&EmbeddedTestServer::ShutdownOnIOThread,
|
| + base::Unretained(this)),
|
| run_loop.QuitClosure())) {
|
| return false;
|
| }
|
| @@ -94,7 +96,7 @@ bool HttpServer::ShutdownAndWaitUntilComplete() {
|
| return true;
|
| }
|
|
|
| -void HttpServer::InitializeOnIOThread() {
|
| +void EmbeddedTestServer::InitializeOnIOThread() {
|
| DCHECK(io_thread_->BelongsToCurrentThread());
|
| DCHECK(!Started());
|
|
|
| @@ -102,10 +104,10 @@ void HttpServer::InitializeOnIOThread() {
|
| int try_port = kPort;
|
|
|
| while (retries_left > 0) {
|
| - SocketDescriptor socket_descriptor = net::TCPListenSocket::CreateAndBind(
|
| + SocketDescriptor socket_descriptor = TCPListenSocket::CreateAndBind(
|
| kIp,
|
| try_port);
|
| - if (socket_descriptor != net::TCPListenSocket::kInvalidSocket) {
|
| + if (socket_descriptor != TCPListenSocket::kInvalidSocket) {
|
| listen_socket_ = new HttpListenSocket(socket_descriptor, this);
|
| listen_socket_->Listen();
|
| base_url_ = GURL(base::StringPrintf("http://%s:%d", kIp, try_port));
|
| @@ -117,7 +119,7 @@ void HttpServer::InitializeOnIOThread() {
|
| }
|
| }
|
|
|
| -void HttpServer::ShutdownOnIOThread() {
|
| +void EmbeddedTestServer::ShutdownOnIOThread() {
|
| DCHECK(io_thread_->BelongsToCurrentThread());
|
|
|
| listen_socket_ = NULL; // Release the listen socket.
|
| @@ -126,7 +128,7 @@ void HttpServer::ShutdownOnIOThread() {
|
| connections_.clear();
|
| }
|
|
|
| -void HttpServer::HandleRequest(HttpConnection* connection,
|
| +void EmbeddedTestServer::HandleRequest(HttpConnection* connection,
|
| scoped_ptr<HttpRequest> request) {
|
| DCHECK(io_thread_->BelongsToCurrentThread());
|
|
|
| @@ -151,28 +153,29 @@ void HttpServer::HandleRequest(HttpConnection* connection,
|
| delete connection;
|
| }
|
|
|
| -GURL HttpServer::GetURL(const std::string& relative_url) const {
|
| +GURL EmbeddedTestServer::GetURL(const std::string& relative_url) const {
|
| DCHECK(StartsWithASCII(relative_url, "/", true /* case_sensitive */))
|
| << relative_url;
|
| return base_url_.Resolve(relative_url);
|
| }
|
|
|
| -void HttpServer::RegisterRequestHandler(
|
| +void EmbeddedTestServer::RegisterRequestHandler(
|
| const HandleRequestCallback& callback) {
|
| request_handlers_.push_back(callback);
|
| }
|
|
|
| -void HttpServer::DidAccept(net::StreamListenSocket* server,
|
| - net::StreamListenSocket* connection) {
|
| +void EmbeddedTestServer::DidAccept(StreamListenSocket* server,
|
| + StreamListenSocket* connection) {
|
| DCHECK(io_thread_->BelongsToCurrentThread());
|
|
|
| HttpConnection* http_connection = new HttpConnection(
|
| connection,
|
| - base::Bind(&HttpServer::HandleRequest, weak_factory_.GetWeakPtr()));
|
| + base::Bind(&EmbeddedTestServer::HandleRequest,
|
| + weak_factory_.GetWeakPtr()));
|
| connections_[connection] = http_connection;
|
| }
|
|
|
| -void HttpServer::DidRead(net::StreamListenSocket* connection,
|
| +void EmbeddedTestServer::DidRead(StreamListenSocket* connection,
|
| const char* data,
|
| int length) {
|
| DCHECK(io_thread_->BelongsToCurrentThread());
|
| @@ -185,7 +188,7 @@ void HttpServer::DidRead(net::StreamListenSocket* connection,
|
| http_connection->ReceiveData(std::string(data, length));
|
| }
|
|
|
| -void HttpServer::DidClose(net::StreamListenSocket* connection) {
|
| +void EmbeddedTestServer::DidClose(StreamListenSocket* connection) {
|
| DCHECK(io_thread_->BelongsToCurrentThread());
|
|
|
| HttpConnection* http_connection = FindConnection(connection);
|
| @@ -197,11 +200,11 @@ void HttpServer::DidClose(net::StreamListenSocket* connection) {
|
| connections_.erase(connection);
|
| }
|
|
|
| -HttpConnection* HttpServer::FindConnection(
|
| - net::StreamListenSocket* socket) {
|
| +HttpConnection* EmbeddedTestServer::FindConnection(
|
| + StreamListenSocket* socket) {
|
| DCHECK(io_thread_->BelongsToCurrentThread());
|
|
|
| - std::map<net::StreamListenSocket*, HttpConnection*>::iterator it =
|
| + std::map<StreamListenSocket*, HttpConnection*>::iterator it =
|
| connections_.find(socket);
|
| if (it == connections_.end()) {
|
| return NULL;
|
| @@ -210,4 +213,4 @@ HttpConnection* HttpServer::FindConnection(
|
| }
|
|
|
| } // namespace test_server
|
| -} // namespace google_apis
|
| +} // namespace net
|
|
|