OLD | NEW |
1 // Copyright (c) 2006-2008 The Chromium Authors. All rights reserved. | 1 // Copyright (c) 2006-2008 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 <vector> | 5 #include <vector> |
6 | 6 |
7 #include "net/url_request/url_request_test_job.h" | 7 #include "net/url_request/url_request_test_job.h" |
8 | 8 |
9 #include "base/message_loop.h" | 9 #include "base/message_loop.h" |
10 #include "base/string_util.h" | 10 #include "base/string_util.h" |
(...skipping 52 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
63 | 63 |
64 // static getter for error response headers | 64 // static getter for error response headers |
65 std::string URLRequestTestJob::test_error_headers() { | 65 std::string URLRequestTestJob::test_error_headers() { |
66 const char headers[] = | 66 const char headers[] = |
67 "HTTP/1.1 500 BOO HOO\0" | 67 "HTTP/1.1 500 BOO HOO\0" |
68 "\0"; | 68 "\0"; |
69 return std::string(headers, arraysize(headers)); | 69 return std::string(headers, arraysize(headers)); |
70 } | 70 } |
71 | 71 |
72 // static | 72 // static |
73 URLRequestJob* URLRequestTestJob::Factory(net::URLRequest* request, | 73 net::URLRequestJob* URLRequestTestJob::Factory(net::URLRequest* request, |
74 const std::string& scheme) { | 74 const std::string& scheme) { |
75 return new URLRequestTestJob(request); | 75 return new URLRequestTestJob(request); |
76 } | 76 } |
77 | 77 |
78 URLRequestTestJob::URLRequestTestJob(net::URLRequest* request) | 78 URLRequestTestJob::URLRequestTestJob(net::URLRequest* request) |
79 : URLRequestJob(request), | 79 : net::URLRequestJob(request), |
80 auto_advance_(false), | 80 auto_advance_(false), |
81 stage_(WAITING), | 81 stage_(WAITING), |
82 offset_(0), | 82 offset_(0), |
83 async_buf_(NULL), | 83 async_buf_(NULL), |
84 async_buf_size_(0) { | 84 async_buf_size_(0) { |
85 } | 85 } |
86 | 86 |
87 URLRequestTestJob::URLRequestTestJob(net::URLRequest* request, | 87 URLRequestTestJob::URLRequestTestJob(net::URLRequest* request, |
88 bool auto_advance) | 88 bool auto_advance) |
89 : URLRequestJob(request), | 89 : net::URLRequestJob(request), |
90 auto_advance_(auto_advance), | 90 auto_advance_(auto_advance), |
91 stage_(WAITING), | 91 stage_(WAITING), |
92 offset_(0), | 92 offset_(0), |
93 async_buf_(NULL), | 93 async_buf_(NULL), |
94 async_buf_size_(0) { | 94 async_buf_size_(0) { |
95 } | 95 } |
96 | 96 |
97 URLRequestTestJob::URLRequestTestJob(net::URLRequest* request, | 97 URLRequestTestJob::URLRequestTestJob(net::URLRequest* request, |
98 const std::string& response_headers, | 98 const std::string& response_headers, |
99 const std::string& response_data, | 99 const std::string& response_data, |
100 bool auto_advance) | 100 bool auto_advance) |
101 : URLRequestJob(request), | 101 : net::URLRequestJob(request), |
102 auto_advance_(auto_advance), | 102 auto_advance_(auto_advance), |
103 stage_(WAITING), | 103 stage_(WAITING), |
104 response_headers_(new net::HttpResponseHeaders(response_headers)), | 104 response_headers_(new net::HttpResponseHeaders(response_headers)), |
105 response_data_(response_data), | 105 response_data_(response_data), |
106 offset_(0), | 106 offset_(0), |
107 async_buf_(NULL), | 107 async_buf_(NULL), |
108 async_buf_size_(0) { | 108 async_buf_size_(0) { |
109 } | 109 } |
110 | 110 |
111 URLRequestTestJob::~URLRequestTestJob() { | 111 URLRequestTestJob::~URLRequestTestJob() { |
(...skipping 88 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
200 return false; | 200 return false; |
201 | 201 |
202 *location = request_->url().Resolve(value); | 202 *location = request_->url().Resolve(value); |
203 *http_status_code = response_headers_->response_code(); | 203 *http_status_code = response_headers_->response_code(); |
204 return true; | 204 return true; |
205 } | 205 } |
206 | 206 |
207 | 207 |
208 void URLRequestTestJob::Kill() { | 208 void URLRequestTestJob::Kill() { |
209 stage_ = DONE; | 209 stage_ = DONE; |
210 URLRequestJob::Kill(); | 210 net::URLRequestJob::Kill(); |
211 } | 211 } |
212 | 212 |
213 void URLRequestTestJob::ProcessNextOperation() { | 213 void URLRequestTestJob::ProcessNextOperation() { |
214 switch (stage_) { | 214 switch (stage_) { |
215 case WAITING: | 215 case WAITING: |
216 stage_ = DATA_AVAILABLE; | 216 stage_ = DATA_AVAILABLE; |
217 // OK if ReadRawData wasn't called yet. | 217 // OK if ReadRawData wasn't called yet. |
218 if (async_buf_) { | 218 if (async_buf_) { |
219 int bytes_read; | 219 int bytes_read; |
220 if (!ReadRawData(async_buf_, async_buf_size_, &bytes_read)) | 220 if (!ReadRawData(async_buf_, async_buf_size_, &bytes_read)) |
(...skipping 31 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
252 if (pending_jobs.empty()) | 252 if (pending_jobs.empty()) |
253 return false; | 253 return false; |
254 | 254 |
255 scoped_refptr<URLRequestTestJob> next_job(pending_jobs[0]); | 255 scoped_refptr<URLRequestTestJob> next_job(pending_jobs[0]); |
256 pending_jobs.erase(pending_jobs.begin()); | 256 pending_jobs.erase(pending_jobs.begin()); |
257 | 257 |
258 DCHECK(!next_job->auto_advance()); // auto_advance jobs should be in this q | 258 DCHECK(!next_job->auto_advance()); // auto_advance jobs should be in this q |
259 next_job->ProcessNextOperation(); | 259 next_job->ProcessNextOperation(); |
260 return true; | 260 return true; |
261 } | 261 } |
OLD | NEW |