Chromium Code Reviews| OLD | NEW |
|---|---|
| 1 // Copyright (c) 2012 The Chromium Authors. All rights reserved. | 1 // Copyright (c) 2012 The Chromium Authors. All rights reserved. |
| 2 // Use of this source code is governed by a BSD-style license that can be | 2 // Use of this source code is governed by a BSD-style license that can be |
| 3 // found in the LICENSE file. | 3 // found in the LICENSE file. |
| 4 | 4 |
| 5 #include "net/test/embedded_test_server/embedded_test_server.h" | 5 #include "net/test/embedded_test_server/embedded_test_server.h" |
| 6 | 6 |
| 7 #include "base/bind.h" | 7 #include "base/bind.h" |
| 8 #include "base/files/file_path.h" | |
| 9 #include "base/file_util.h" | |
| 10 #include "base/path_service.h" | |
| 8 #include "base/run_loop.h" | 11 #include "base/run_loop.h" |
| 9 #include "base/stl_util.h" | 12 #include "base/stl_util.h" |
| 10 #include "base/string_util.h" | 13 #include "base/string_util.h" |
| 11 #include "base/stringprintf.h" | 14 #include "base/stringprintf.h" |
| 15 #include "base/threading/thread_restrictions.h" | |
| 12 #include "net/test/embedded_test_server/http_connection.h" | 16 #include "net/test/embedded_test_server/http_connection.h" |
| 13 #include "net/test/embedded_test_server/http_request.h" | 17 #include "net/test/embedded_test_server/http_request.h" |
| 14 #include "net/test/embedded_test_server/http_response.h" | 18 #include "net/test/embedded_test_server/http_response.h" |
| 15 #include "net/tools/fetch/http_listen_socket.h" | 19 #include "net/tools/fetch/http_listen_socket.h" |
| 16 | 20 |
| 17 namespace net { | 21 namespace net { |
| 18 namespace test_server { | 22 namespace test_server { |
| 19 | 23 |
| 20 namespace { | 24 namespace { |
| 21 | 25 |
| 22 const int kPort = 8040; | 26 const int kPort = 8040; |
| 23 const char kIp[] = "127.0.0.1"; | 27 const char kIp[] = "127.0.0.1"; |
| 24 const int kRetries = 10; | 28 const int kRetries = 10; |
| 25 | 29 |
| 26 // Callback to handle requests with default predefined response for requests | 30 // Callback to handle requests with default predefined response for requests |
| 27 // matching the address |url|. | 31 // matching the address |url|. |
| 28 scoped_ptr<HttpResponse> HandleDefaultRequest(const GURL& url, | 32 scoped_ptr<HttpResponse> HandleDefaultRequest(const GURL& url, |
| 29 const HttpResponse& response, | 33 const HttpResponse& response, |
| 30 const HttpRequest& request) { | 34 const HttpRequest& request) { |
| 31 const GURL request_url = url.Resolve(request.relative_url); | 35 const GURL request_url = url.Resolve(request.relative_url); |
| 32 if (url.path() != request_url.path()) | 36 if (url.path() != request_url.path()) |
| 33 return scoped_ptr<HttpResponse>(NULL); | 37 return scoped_ptr<HttpResponse>(NULL); |
| 34 return scoped_ptr<HttpResponse>(new HttpResponse(response)); | 38 return scoped_ptr<HttpResponse>(new HttpResponse(response)); |
| 35 } | 39 } |
| 36 | 40 |
| 41 scoped_ptr<HttpResponse> HandleFileRequest(const base::FilePath& file_path, | |
|
satorux1
2013/05/16 04:57:59
function comment is missing.
satorux1
2013/05/16 04:57:59
file_path -> directory_path ?
| |
| 42 const HttpRequest& request) { | |
| 43 // This is a test-only server. Ignore I/O thread restrictions. | |
| 44 base::ThreadRestrictions::ScopedAllowIO allow_io; | |
| 45 | |
| 46 std::string file_contents; | |
|
satorux1
2013/05/16 04:57:59
Maybe:
// Trim the first byte ('/').
| |
| 47 if (!file_util::ReadFileToString( | |
| 48 file_path.AppendASCII(request.relative_url.substr(1)), | |
| 49 &file_contents)) { | |
| 50 return scoped_ptr<HttpResponse>(NULL); | |
| 51 } | |
| 52 | |
| 53 scoped_ptr<HttpResponse> http_response(new HttpResponse); | |
| 54 http_response->set_code(net::test_server::SUCCESS); | |
| 55 http_response->set_content(file_contents); | |
| 56 return http_response.Pass(); | |
| 57 } | |
| 58 | |
| 37 } // namespace | 59 } // namespace |
| 38 | 60 |
| 39 HttpListenSocket::HttpListenSocket(const SocketDescriptor socket_descriptor, | 61 HttpListenSocket::HttpListenSocket(const SocketDescriptor socket_descriptor, |
| 40 StreamListenSocket::Delegate* delegate) | 62 StreamListenSocket::Delegate* delegate) |
| 41 : TCPListenSocket(socket_descriptor, delegate) { | 63 : TCPListenSocket(socket_descriptor, delegate) { |
| 42 DCHECK(thread_checker_.CalledOnValidThread()); | 64 DCHECK(thread_checker_.CalledOnValidThread()); |
| 43 } | 65 } |
| 44 | 66 |
| 45 void HttpListenSocket::Listen() { | 67 void HttpListenSocket::Listen() { |
| 46 DCHECK(thread_checker_.CalledOnValidThread()); | 68 DCHECK(thread_checker_.CalledOnValidThread()); |
| 47 TCPListenSocket::Listen(); | 69 TCPListenSocket::Listen(); |
| 48 } | 70 } |
| 49 | 71 |
| 50 HttpListenSocket::~HttpListenSocket() { | 72 HttpListenSocket::~HttpListenSocket() { |
| 51 DCHECK(thread_checker_.CalledOnValidThread()); | 73 DCHECK(thread_checker_.CalledOnValidThread()); |
| 52 } | 74 } |
| 53 | 75 |
| 54 EmbeddedTestServer::EmbeddedTestServer( | 76 EmbeddedTestServer::EmbeddedTestServer( |
| 55 const scoped_refptr<base::SingleThreadTaskRunner>& io_thread) | 77 const scoped_refptr<base::SingleThreadTaskRunner>& io_thread) |
| 56 : io_thread_(io_thread), | 78 : io_thread_(io_thread), |
| 57 port_(-1), | 79 port_(-1), |
| 58 weak_factory_(this) { | 80 weak_factory_(this) { |
| 59 DCHECK(io_thread_); | 81 DCHECK(io_thread_); |
| 60 DCHECK(thread_checker_.CalledOnValidThread()); | 82 DCHECK(thread_checker_.CalledOnValidThread()); |
| 61 } | 83 } |
| 62 | 84 |
| 63 EmbeddedTestServer::~EmbeddedTestServer() { | 85 EmbeddedTestServer::~EmbeddedTestServer() { |
| 64 DCHECK(thread_checker_.CalledOnValidThread()); | 86 DCHECK(thread_checker_.CalledOnValidThread()); |
| 87 | |
| 88 if (Started() && !ShutdownAndWaitUntilComplete()) { | |
| 89 LOG(ERROR) << "EmbeddedTestServer failed to shut down."; | |
| 90 } | |
| 65 } | 91 } |
| 66 | 92 |
| 67 bool EmbeddedTestServer::InitializeAndWaitUntilReady() { | 93 bool EmbeddedTestServer::InitializeAndWaitUntilReady() { |
| 68 DCHECK(thread_checker_.CalledOnValidThread()); | 94 DCHECK(thread_checker_.CalledOnValidThread()); |
| 69 | 95 |
| 70 base::RunLoop run_loop; | 96 base::RunLoop run_loop; |
| 71 if (!io_thread_->PostTaskAndReply( | 97 if (!io_thread_->PostTaskAndReply( |
| 72 FROM_HERE, | 98 FROM_HERE, |
| 73 base::Bind(&EmbeddedTestServer::InitializeOnIOThread, | 99 base::Bind(&EmbeddedTestServer::InitializeOnIOThread, |
| 74 base::Unretained(this)), | 100 base::Unretained(this)), |
| (...skipping 77 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... | |
| 152 connections_.erase(connection->socket_.get()); | 178 connections_.erase(connection->socket_.get()); |
| 153 delete connection; | 179 delete connection; |
| 154 } | 180 } |
| 155 | 181 |
| 156 GURL EmbeddedTestServer::GetURL(const std::string& relative_url) const { | 182 GURL EmbeddedTestServer::GetURL(const std::string& relative_url) const { |
| 157 DCHECK(StartsWithASCII(relative_url, "/", true /* case_sensitive */)) | 183 DCHECK(StartsWithASCII(relative_url, "/", true /* case_sensitive */)) |
| 158 << relative_url; | 184 << relative_url; |
| 159 return base_url_.Resolve(relative_url); | 185 return base_url_.Resolve(relative_url); |
| 160 } | 186 } |
| 161 | 187 |
| 188 bool EmbeddedTestServer::ServeFilesFromDirectory( | |
| 189 int root_key, const base::FilePath& directory) { | |
| 190 base::FilePath root_path; | |
| 191 if (!PathService::Get(root_key, &root_path)) | |
| 192 return false; | |
| 193 RegisterRequestHandler(base::Bind(&HandleFileRequest, | |
| 194 root_path.Append(directory))); | |
| 195 return true; | |
| 196 } | |
| 197 | |
| 162 void EmbeddedTestServer::RegisterRequestHandler( | 198 void EmbeddedTestServer::RegisterRequestHandler( |
| 163 const HandleRequestCallback& callback) { | 199 const HandleRequestCallback& callback) { |
| 164 request_handlers_.push_back(callback); | 200 request_handlers_.push_back(callback); |
| 165 } | 201 } |
| 166 | 202 |
| 167 void EmbeddedTestServer::DidAccept(StreamListenSocket* server, | 203 void EmbeddedTestServer::DidAccept(StreamListenSocket* server, |
| 168 StreamListenSocket* connection) { | 204 StreamListenSocket* connection) { |
| 169 DCHECK(io_thread_->BelongsToCurrentThread()); | 205 DCHECK(io_thread_->BelongsToCurrentThread()); |
| 170 | 206 |
| 171 HttpConnection* http_connection = new HttpConnection( | 207 HttpConnection* http_connection = new HttpConnection( |
| (...skipping 35 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... | |
| 207 std::map<StreamListenSocket*, HttpConnection*>::iterator it = | 243 std::map<StreamListenSocket*, HttpConnection*>::iterator it = |
| 208 connections_.find(socket); | 244 connections_.find(socket); |
| 209 if (it == connections_.end()) { | 245 if (it == connections_.end()) { |
| 210 return NULL; | 246 return NULL; |
| 211 } | 247 } |
| 212 return it->second; | 248 return it->second; |
| 213 } | 249 } |
| 214 | 250 |
| 215 } // namespace test_server | 251 } // namespace test_server |
| 216 } // namespace net | 252 } // namespace net |
| OLD | NEW |