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 "chrome/browser/google_apis/test_server/http_server.h" | 5 #include "chrome/browser/google_apis/test_server/http_server.h" |
6 | 6 |
7 #include "base/bind.h" | 7 #include "base/bind.h" |
8 #include "base/file_util.h" | 8 #include "base/file_util.h" |
9 #include "base/stl_util.h" | 9 #include "base/stl_util.h" |
10 #include "base/string_util.h" | 10 #include "base/string_util.h" |
(...skipping 146 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
157 DCHECK(StartsWithASCII(relative_url, "/", true /* case_sensitive */)) | 157 DCHECK(StartsWithASCII(relative_url, "/", true /* case_sensitive */)) |
158 << relative_url; | 158 << relative_url; |
159 return base_url_.Resolve(relative_url); | 159 return base_url_.Resolve(relative_url); |
160 } | 160 } |
161 | 161 |
162 void HttpServer::RegisterRequestHandler( | 162 void HttpServer::RegisterRequestHandler( |
163 const HandleRequestCallback& callback) { | 163 const HandleRequestCallback& callback) { |
164 request_handlers_.push_back(callback); | 164 request_handlers_.push_back(callback); |
165 } | 165 } |
166 | 166 |
167 void HttpServer::RegisterDefaultResponse( | |
168 const std::string& relative_path, | |
169 const HttpResponse& default_response) { | |
170 DCHECK(BrowserThread::CurrentlyOn(BrowserThread::UI)); | |
171 DCHECK(StartsWithASCII(relative_path, "/", true /* case_sensitive */)) | |
172 << relative_path; | |
173 | |
174 const HandleRequestCallback callback = | |
175 base::Bind(&HandleDefaultRequest, | |
176 GetURL(relative_path), | |
177 default_response); | |
178 request_handlers_.push_back(callback); | |
179 } | |
180 | |
181 void HttpServer::RegisterTextResponse( | |
182 const std::string& relative_path, | |
183 const std::string& content, | |
184 const std::string& content_type, | |
185 const ResponseCode response_code) { | |
186 DCHECK(BrowserThread::CurrentlyOn(BrowserThread::UI)); | |
187 DCHECK(StartsWithASCII(relative_path, "/", true /* case_sensitive */)) | |
188 << relative_path; | |
189 | |
190 HttpResponse default_response; | |
191 default_response.set_content(content); | |
192 default_response.set_content_type(content_type); | |
193 default_response.set_code(response_code); | |
194 | |
195 RegisterDefaultResponse(relative_path, default_response); | |
196 } | |
197 | |
198 void HttpServer::RegisterFileResponse( | |
199 const std::string& relative_path, | |
200 const FilePath& file_path, | |
201 const std::string& content_type, | |
202 const ResponseCode response_code) { | |
203 DCHECK(BrowserThread::CurrentlyOn(BrowserThread::UI)); | |
204 DCHECK(StartsWithASCII(relative_path, "/", true /* case_sensitive */)) | |
205 << relative_path; | |
206 | |
207 HttpResponse default_response; | |
208 | |
209 std::string content; | |
210 const bool success = file_util::ReadFileToString( | |
211 file_path, &content); | |
212 default_response.set_content(content); | |
213 DCHECK(success) << "Failed to open the file: " << file_path.value(); | |
214 | |
215 default_response.set_content_type(content_type); | |
216 default_response.set_code(response_code); | |
217 | |
218 RegisterDefaultResponse(relative_path, default_response); | |
219 } | |
220 | |
221 void HttpServer::DidAccept(net::StreamListenSocket* server, | 167 void HttpServer::DidAccept(net::StreamListenSocket* server, |
222 net::StreamListenSocket* connection) { | 168 net::StreamListenSocket* connection) { |
223 DCHECK(BrowserThread::CurrentlyOn(BrowserThread::IO)); | 169 DCHECK(BrowserThread::CurrentlyOn(BrowserThread::IO)); |
224 | 170 |
225 HttpConnection* http_connection = new HttpConnection( | 171 HttpConnection* http_connection = new HttpConnection( |
226 connection, | 172 connection, |
227 base::Bind(&HttpServer::HandleRequest, weak_factory_.GetWeakPtr())); | 173 base::Bind(&HttpServer::HandleRequest, weak_factory_.GetWeakPtr())); |
228 connections_[connection] = http_connection; | 174 connections_[connection] = http_connection; |
229 } | 175 } |
230 | 176 |
(...skipping 29 matching lines...) Expand all Loading... |
260 std::map<net::StreamListenSocket*, HttpConnection*>::iterator it = | 206 std::map<net::StreamListenSocket*, HttpConnection*>::iterator it = |
261 connections_.find(socket); | 207 connections_.find(socket); |
262 if (it == connections_.end()) { | 208 if (it == connections_.end()) { |
263 return NULL; | 209 return NULL; |
264 } | 210 } |
265 return it->second; | 211 return it->second; |
266 } | 212 } |
267 | 213 |
268 } // namespace test_server | 214 } // namespace test_server |
269 } // namespace google_apis | 215 } // namespace google_apis |
OLD | NEW |