| 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/http/http_transaction_unittest.h" | 5 #include "net/http/http_transaction_unittest.h" |
| 6 | 6 |
| 7 #include <algorithm> | 7 #include <algorithm> |
| 8 | 8 |
| 9 #include "base/bind.h" | 9 #include "base/bind.h" |
| 10 #include "base/message_loop.h" | 10 #include "base/message_loop.h" |
| (...skipping 203 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 214 default: | 214 default: |
| 215 NOTREACHED(); | 215 NOTREACHED(); |
| 216 } | 216 } |
| 217 } | 217 } |
| 218 | 218 |
| 219 MockNetworkTransaction::MockNetworkTransaction( | 219 MockNetworkTransaction::MockNetworkTransaction( |
| 220 net::RequestPriority priority, | 220 net::RequestPriority priority, |
| 221 MockNetworkLayer* factory) | 221 MockNetworkLayer* factory) |
| 222 : ALLOW_THIS_IN_INITIALIZER_LIST(weak_factory_(this)), | 222 : ALLOW_THIS_IN_INITIALIZER_LIST(weak_factory_(this)), |
| 223 data_cursor_(0), | 223 data_cursor_(0), |
| 224 priority_(priority), |
| 224 transaction_factory_(factory->AsWeakPtr()) { | 225 transaction_factory_(factory->AsWeakPtr()) { |
| 225 } | 226 } |
| 226 | 227 |
| 227 MockNetworkTransaction::~MockNetworkTransaction() {} | 228 MockNetworkTransaction::~MockNetworkTransaction() {} |
| 228 | 229 |
| 229 int MockNetworkTransaction::Start(const net::HttpRequestInfo* request, | 230 int MockNetworkTransaction::Start(const net::HttpRequestInfo* request, |
| 230 const net::CompletionCallback& callback, | 231 const net::CompletionCallback& callback, |
| 231 const net::BoundNetLog& net_log) { | 232 const net::BoundNetLog& net_log) { |
| 232 const MockTransaction* t = FindMockTransaction(request->url); | 233 const MockTransaction* t = FindMockTransaction(request->url); |
| 233 if (!t) | 234 if (!t) |
| (...skipping 87 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 321 | 322 |
| 322 net::UploadProgress MockNetworkTransaction::GetUploadProgress() const { | 323 net::UploadProgress MockNetworkTransaction::GetUploadProgress() const { |
| 323 return net::UploadProgress(); | 324 return net::UploadProgress(); |
| 324 } | 325 } |
| 325 | 326 |
| 326 bool MockNetworkTransaction::GetLoadTimingInfo( | 327 bool MockNetworkTransaction::GetLoadTimingInfo( |
| 327 net::LoadTimingInfo* load_timing_info) const { | 328 net::LoadTimingInfo* load_timing_info) const { |
| 328 return false; | 329 return false; |
| 329 } | 330 } |
| 330 | 331 |
| 332 void MockNetworkTransaction::SetPriority(net::RequestPriority priority) { |
| 333 priority_ = priority; |
| 334 } |
| 335 |
| 331 void MockNetworkTransaction::CallbackLater( | 336 void MockNetworkTransaction::CallbackLater( |
| 332 const net::CompletionCallback& callback, int result) { | 337 const net::CompletionCallback& callback, int result) { |
| 333 MessageLoop::current()->PostTask( | 338 MessageLoop::current()->PostTask( |
| 334 FROM_HERE, base::Bind(&MockNetworkTransaction::RunCallback, | 339 FROM_HERE, base::Bind(&MockNetworkTransaction::RunCallback, |
| 335 weak_factory_.GetWeakPtr(), callback, result)); | 340 weak_factory_.GetWeakPtr(), callback, result)); |
| 336 } | 341 } |
| 337 | 342 |
| 338 void MockNetworkTransaction::RunCallback( | 343 void MockNetworkTransaction::RunCallback( |
| 339 const net::CompletionCallback& callback, int result) { | 344 const net::CompletionCallback& callback, int result) { |
| 340 callback.Run(result); | 345 callback.Run(result); |
| 341 } | 346 } |
| 342 | 347 |
| 343 MockNetworkLayer::MockNetworkLayer() | 348 MockNetworkLayer::MockNetworkLayer() |
| 344 : transaction_count_(0), done_reading_called_(false) {} | 349 : transaction_count_(0), |
| 350 done_reading_called_(false), |
| 351 last_transaction_(NULL) {} |
| 345 | 352 |
| 346 MockNetworkLayer::~MockNetworkLayer() {} | 353 MockNetworkLayer::~MockNetworkLayer() {} |
| 347 | 354 |
| 348 void MockNetworkLayer::TransactionDoneReading() { | 355 void MockNetworkLayer::TransactionDoneReading() { |
| 349 done_reading_called_ = true; | 356 done_reading_called_ = true; |
| 350 } | 357 } |
| 351 | 358 |
| 352 int MockNetworkLayer::CreateTransaction( | 359 int MockNetworkLayer::CreateTransaction( |
| 353 net::RequestPriority priority, | 360 net::RequestPriority priority, |
| 354 scoped_ptr<net::HttpTransaction>* trans, | 361 scoped_ptr<net::HttpTransaction>* trans, |
| 355 net::HttpTransactionDelegate* delegate) { | 362 net::HttpTransactionDelegate* delegate) { |
| 356 transaction_count_++; | 363 transaction_count_++; |
| 357 trans->reset(new MockNetworkTransaction(priority, this)); | 364 last_transaction_ = new MockNetworkTransaction(priority, this); |
| 365 trans->reset(last_transaction_); |
| 358 return net::OK; | 366 return net::OK; |
| 359 } | 367 } |
| 360 | 368 |
| 361 net::HttpCache* MockNetworkLayer::GetCache() { | 369 net::HttpCache* MockNetworkLayer::GetCache() { |
| 362 return NULL; | 370 return NULL; |
| 363 } | 371 } |
| 364 | 372 |
| 365 net::HttpNetworkSession* MockNetworkLayer::GetSession() { | 373 net::HttpNetworkSession* MockNetworkLayer::GetSession() { |
| 366 return NULL; | 374 return NULL; |
| 367 } | 375 } |
| (...skipping 15 matching lines...) Expand all Loading... |
| 383 | 391 |
| 384 if (rv > 0) | 392 if (rv > 0) |
| 385 content.append(buf->data(), rv); | 393 content.append(buf->data(), rv); |
| 386 else if (rv < 0) | 394 else if (rv < 0) |
| 387 return rv; | 395 return rv; |
| 388 } while (rv > 0); | 396 } while (rv > 0); |
| 389 | 397 |
| 390 result->swap(content); | 398 result->swap(content); |
| 391 return net::OK; | 399 return net::OK; |
| 392 } | 400 } |
| OLD | NEW |