OLD | NEW |
1 // Copyright 2014 The Chromium Authors. All rights reserved. | 1 // Copyright 2014 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/http/http_transaction_test_util.h" | 5 #include "net/http/http_transaction_test_util.h" |
6 | 6 |
7 #include <algorithm> | 7 #include <algorithm> |
8 #include <unordered_map> | 8 #include <unordered_map> |
9 #include <utility> | 9 #include <utility> |
10 | 10 |
(...skipping 145 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
156 : state_(IDLE), error_(OK) { | 156 : state_(IDLE), error_(OK) { |
157 // Disregard the error code. | 157 // Disregard the error code. |
158 factory->CreateTransaction(priority, &trans_); | 158 factory->CreateTransaction(priority, &trans_); |
159 ++quit_counter_; | 159 ++quit_counter_; |
160 } | 160 } |
161 | 161 |
162 TestTransactionConsumer::~TestTransactionConsumer() { | 162 TestTransactionConsumer::~TestTransactionConsumer() { |
163 } | 163 } |
164 | 164 |
165 void TestTransactionConsumer::Start(const HttpRequestInfo* request, | 165 void TestTransactionConsumer::Start(const HttpRequestInfo* request, |
166 const BoundNetLog& net_log) { | 166 const NetLogWithSource& net_log) { |
167 state_ = STARTING; | 167 state_ = STARTING; |
168 int result = trans_->Start( | 168 int result = trans_->Start( |
169 request, base::Bind(&TestTransactionConsumer::OnIOComplete, | 169 request, base::Bind(&TestTransactionConsumer::OnIOComplete, |
170 base::Unretained(this)), net_log); | 170 base::Unretained(this)), net_log); |
171 if (result != ERR_IO_PENDING) | 171 if (result != ERR_IO_PENDING) |
172 DidStart(result); | 172 DidStart(result); |
173 } | 173 } |
174 | 174 |
175 void TestTransactionConsumer::DidStart(int result) { | 175 void TestTransactionConsumer::DidStart(int result) { |
176 if (result != OK) { | 176 if (result != OK) { |
(...skipping 55 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
232 received_bytes_(0), | 232 received_bytes_(0), |
233 sent_bytes_(0), | 233 sent_bytes_(0), |
234 socket_log_id_(NetLog::Source::kInvalidId), | 234 socket_log_id_(NetLog::Source::kInvalidId), |
235 done_reading_called_(false), | 235 done_reading_called_(false), |
236 weak_factory_(this) {} | 236 weak_factory_(this) {} |
237 | 237 |
238 MockNetworkTransaction::~MockNetworkTransaction() {} | 238 MockNetworkTransaction::~MockNetworkTransaction() {} |
239 | 239 |
240 int MockNetworkTransaction::Start(const HttpRequestInfo* request, | 240 int MockNetworkTransaction::Start(const HttpRequestInfo* request, |
241 const CompletionCallback& callback, | 241 const CompletionCallback& callback, |
242 const BoundNetLog& net_log) { | 242 const NetLogWithSource& net_log) { |
243 if (request_) | 243 if (request_) |
244 return ERR_FAILED; | 244 return ERR_FAILED; |
245 | 245 |
246 request_ = request; | 246 request_ = request; |
247 return StartInternal(request, callback, net_log); | 247 return StartInternal(request, callback, net_log); |
248 } | 248 } |
249 | 249 |
250 int MockNetworkTransaction::RestartIgnoringLastError( | 250 int MockNetworkTransaction::RestartIgnoringLastError( |
251 const CompletionCallback& callback) { | 251 const CompletionCallback& callback) { |
252 return ERR_FAILED; | 252 return ERR_FAILED; |
(...skipping 11 matching lines...) Expand all Loading... |
264 const CompletionCallback& callback) { | 264 const CompletionCallback& callback) { |
265 if (!IsReadyToRestartForAuth()) | 265 if (!IsReadyToRestartForAuth()) |
266 return ERR_FAILED; | 266 return ERR_FAILED; |
267 | 267 |
268 HttpRequestInfo auth_request_info = *request_; | 268 HttpRequestInfo auth_request_info = *request_; |
269 auth_request_info.extra_headers.SetHeader("Authorization", "Bar"); | 269 auth_request_info.extra_headers.SetHeader("Authorization", "Bar"); |
270 | 270 |
271 // Let the MockTransactionHandler worry about this: the only way for this | 271 // Let the MockTransactionHandler worry about this: the only way for this |
272 // test to succeed is by using an explicit handler for the transaction so | 272 // test to succeed is by using an explicit handler for the transaction so |
273 // that server behavior can be simulated. | 273 // that server behavior can be simulated. |
274 return StartInternal(&auth_request_info, callback, BoundNetLog()); | 274 return StartInternal(&auth_request_info, callback, NetLogWithSource()); |
275 } | 275 } |
276 | 276 |
277 void MockNetworkTransaction::PopulateNetErrorDetails( | 277 void MockNetworkTransaction::PopulateNetErrorDetails( |
278 NetErrorDetails* /*details*/) const { | 278 NetErrorDetails* /*details*/) const { |
279 NOTIMPLEMENTED(); | 279 NOTIMPLEMENTED(); |
280 } | 280 } |
281 | 281 |
282 bool MockNetworkTransaction::IsReadyToRestartForAuth() { | 282 bool MockNetworkTransaction::IsReadyToRestartForAuth() { |
283 if (!request_) | 283 if (!request_) |
284 return false; | 284 return false; |
(...skipping 108 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
393 } | 393 } |
394 | 394 |
395 // static | 395 // static |
396 const int64_t MockNetworkTransaction::kTotalReceivedBytes = 1000; | 396 const int64_t MockNetworkTransaction::kTotalReceivedBytes = 1000; |
397 | 397 |
398 // static | 398 // static |
399 const int64_t MockNetworkTransaction::kTotalSentBytes = 100; | 399 const int64_t MockNetworkTransaction::kTotalSentBytes = 100; |
400 | 400 |
401 int MockNetworkTransaction::StartInternal(const HttpRequestInfo* request, | 401 int MockNetworkTransaction::StartInternal(const HttpRequestInfo* request, |
402 const CompletionCallback& callback, | 402 const CompletionCallback& callback, |
403 const BoundNetLog& net_log) { | 403 const NetLogWithSource& net_log) { |
404 const MockTransaction* t = FindMockTransaction(request->url); | 404 const MockTransaction* t = FindMockTransaction(request->url); |
405 if (!t) | 405 if (!t) |
406 return ERR_FAILED; | 406 return ERR_FAILED; |
407 | 407 |
408 if (!before_network_start_callback_.is_null()) { | 408 if (!before_network_start_callback_.is_null()) { |
409 bool defer = false; | 409 bool defer = false; |
410 before_network_start_callback_.Run(&defer); | 410 before_network_start_callback_.Run(&defer); |
411 if (defer) | 411 if (defer) |
412 return net::ERR_IO_PENDING; | 412 return net::ERR_IO_PENDING; |
413 } | 413 } |
(...skipping 158 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
572 content.append(buf->data(), rv); | 572 content.append(buf->data(), rv); |
573 else if (rv < 0) | 573 else if (rv < 0) |
574 return rv; | 574 return rv; |
575 } while (rv > 0); | 575 } while (rv > 0); |
576 | 576 |
577 result->swap(content); | 577 result->swap(content); |
578 return OK; | 578 return OK; |
579 } | 579 } |
580 | 580 |
581 } // namespace net | 581 } // namespace net |
OLD | NEW |