| Index: net/base/mock_file_stream.cc
|
| diff --git a/net/base/mock_file_stream.cc b/net/base/mock_file_stream.cc
|
| deleted file mode 100644
|
| index a34edb218be9ed54cb8140aa4aa5db9ed9152507..0000000000000000000000000000000000000000
|
| --- a/net/base/mock_file_stream.cc
|
| +++ /dev/null
|
| @@ -1,141 +0,0 @@
|
| -// Copyright (c) 2012 The Chromium Authors. All rights reserved.
|
| -// Use of this source code is governed by a BSD-style license that can be
|
| -// found in the LICENSE file.
|
| -
|
| -#include "net/base/mock_file_stream.h"
|
| -
|
| -#include "base/bind.h"
|
| -#include "base/message_loop/message_loop.h"
|
| -
|
| -namespace net {
|
| -
|
| -namespace testing {
|
| -
|
| -MockFileStream::MockFileStream(
|
| - const scoped_refptr<base::TaskRunner>& task_runner)
|
| - : net::FileStream(task_runner),
|
| - forced_error_(net::OK),
|
| - async_error_(false),
|
| - throttled_(false),
|
| - weak_factory_(this) {
|
| -}
|
| -
|
| -MockFileStream::MockFileStream(
|
| - base::File file,
|
| - const scoped_refptr<base::TaskRunner>& task_runner)
|
| - : net::FileStream(file.Pass(), task_runner),
|
| - forced_error_(net::OK),
|
| - async_error_(false),
|
| - throttled_(false),
|
| - weak_factory_(this) {
|
| -}
|
| -
|
| -MockFileStream::~MockFileStream() {
|
| -}
|
| -
|
| -int MockFileStream::Seek(base::File::Whence whence, int64 offset,
|
| - const Int64CompletionCallback& callback) {
|
| - Int64CompletionCallback wrapped_callback =
|
| - base::Bind(&MockFileStream::DoCallback64,
|
| - weak_factory_.GetWeakPtr(), callback);
|
| - if (forced_error_ == net::OK)
|
| - return FileStream::Seek(whence, offset, wrapped_callback);
|
| - return ErrorCallback64(wrapped_callback);
|
| -}
|
| -
|
| -int MockFileStream::Read(IOBuffer* buf,
|
| - int buf_len,
|
| - const CompletionCallback& callback) {
|
| - CompletionCallback wrapped_callback = base::Bind(&MockFileStream::DoCallback,
|
| - weak_factory_.GetWeakPtr(),
|
| - callback);
|
| - if (forced_error_ == net::OK)
|
| - return FileStream::Read(buf, buf_len, wrapped_callback);
|
| - return ErrorCallback(wrapped_callback);
|
| -}
|
| -
|
| -int MockFileStream::Write(IOBuffer* buf,
|
| - int buf_len,
|
| - const CompletionCallback& callback) {
|
| - CompletionCallback wrapped_callback = base::Bind(&MockFileStream::DoCallback,
|
| - weak_factory_.GetWeakPtr(),
|
| - callback);
|
| - if (forced_error_ == net::OK)
|
| - return FileStream::Write(buf, buf_len, wrapped_callback);
|
| - return ErrorCallback(wrapped_callback);
|
| -}
|
| -
|
| -int MockFileStream::Flush(const CompletionCallback& callback) {
|
| - CompletionCallback wrapped_callback = base::Bind(&MockFileStream::DoCallback,
|
| - weak_factory_.GetWeakPtr(),
|
| - callback);
|
| - if (forced_error_ == net::OK)
|
| - return FileStream::Flush(wrapped_callback);
|
| - return ErrorCallback(wrapped_callback);
|
| -}
|
| -
|
| -void MockFileStream::ThrottleCallbacks() {
|
| - CHECK(!throttled_);
|
| - throttled_ = true;
|
| -}
|
| -
|
| -void MockFileStream::ReleaseCallbacks() {
|
| - CHECK(throttled_);
|
| - throttled_ = false;
|
| -
|
| - if (!throttled_task_.is_null()) {
|
| - base::Closure throttled_task = throttled_task_;
|
| - throttled_task_.Reset();
|
| - base::MessageLoop::current()->PostTask(FROM_HERE, throttled_task);
|
| - }
|
| -}
|
| -
|
| -void MockFileStream::DoCallback(const CompletionCallback& callback,
|
| - int result) {
|
| - if (!throttled_) {
|
| - callback.Run(result);
|
| - return;
|
| - }
|
| - CHECK(throttled_task_.is_null());
|
| - throttled_task_ = base::Bind(callback, result);
|
| -}
|
| -
|
| -void MockFileStream::DoCallback64(const Int64CompletionCallback& callback,
|
| - int64 result) {
|
| - if (!throttled_) {
|
| - callback.Run(result);
|
| - return;
|
| - }
|
| - CHECK(throttled_task_.is_null());
|
| - throttled_task_ = base::Bind(callback, result);
|
| -}
|
| -
|
| -int MockFileStream::ErrorCallback(const CompletionCallback& callback) {
|
| - CHECK_NE(net::OK, forced_error_);
|
| - if (async_error_) {
|
| - base::MessageLoop::current()->PostTask(
|
| - FROM_HERE, base::Bind(callback, forced_error_));
|
| - clear_forced_error();
|
| - return net::ERR_IO_PENDING;
|
| - }
|
| - int ret = forced_error_;
|
| - clear_forced_error();
|
| - return ret;
|
| -}
|
| -
|
| -int64 MockFileStream::ErrorCallback64(const Int64CompletionCallback& callback) {
|
| - CHECK_NE(net::OK, forced_error_);
|
| - if (async_error_) {
|
| - base::MessageLoop::current()->PostTask(
|
| - FROM_HERE, base::Bind(callback, forced_error_));
|
| - clear_forced_error();
|
| - return net::ERR_IO_PENDING;
|
| - }
|
| - int64 ret = forced_error_;
|
| - clear_forced_error();
|
| - return ret;
|
| -}
|
| -
|
| -} // namespace testing
|
| -
|
| -} // namespace net
|
|
|