| Index: storage/browser/fileapi/file_writer_delegate.cc
|
| diff --git a/webkit/browser/fileapi/file_writer_delegate.cc b/storage/browser/fileapi/file_writer_delegate.cc
|
| similarity index 84%
|
| rename from webkit/browser/fileapi/file_writer_delegate.cc
|
| rename to storage/browser/fileapi/file_writer_delegate.cc
|
| index 83112780cb9a02009c3d9a6421bc63a94e243383..f034ad78df4aba9b727d176dffbc9597fffe32eb 100644
|
| --- a/webkit/browser/fileapi/file_writer_delegate.cc
|
| +++ b/storage/browser/fileapi/file_writer_delegate.cc
|
| @@ -2,7 +2,7 @@
|
| // Use of this source code is governed by a BSD-style license that can be
|
| // found in the LICENSE file.
|
|
|
| -#include "webkit/browser/fileapi/file_writer_delegate.h"
|
| +#include "storage/browser/fileapi/file_writer_delegate.h"
|
|
|
| #include "base/bind.h"
|
| #include "base/callback.h"
|
| @@ -12,11 +12,11 @@
|
| #include "base/sequenced_task_runner.h"
|
| #include "base/threading/thread_restrictions.h"
|
| #include "net/base/net_errors.h"
|
| -#include "webkit/browser/fileapi/file_stream_writer.h"
|
| -#include "webkit/browser/fileapi/file_system_context.h"
|
| -#include "webkit/common/fileapi/file_system_util.h"
|
| +#include "storage/browser/fileapi/file_stream_writer.h"
|
| +#include "storage/browser/fileapi/file_system_context.h"
|
| +#include "storage/common/fileapi/file_system_util.h"
|
|
|
| -namespace fileapi {
|
| +namespace storage {
|
|
|
| static const int kReadBufSize = 32768;
|
|
|
| @@ -50,14 +50,13 @@ void FileWriterDelegate::Cancel() {
|
| request_->Cancel();
|
| }
|
|
|
| - const int status = file_stream_writer_->Cancel(
|
| - base::Bind(&FileWriterDelegate::OnWriteCancelled,
|
| - weak_factory_.GetWeakPtr()));
|
| + const int status = file_stream_writer_->Cancel(base::Bind(
|
| + &FileWriterDelegate::OnWriteCancelled, weak_factory_.GetWeakPtr()));
|
| // Return true to finish immediately if we have no pending writes.
|
| // Otherwise we'll do the final cleanup in the Cancel callback.
|
| if (status != net::ERR_IO_PENDING) {
|
| - write_callback_.Run(base::File::FILE_ERROR_ABORT, 0,
|
| - GetCompletionStatusOnError());
|
| + write_callback_.Run(
|
| + base::File::FILE_ERROR_ABORT, 0, GetCompletionStatusOnError());
|
| }
|
| }
|
|
|
| @@ -114,7 +113,8 @@ void FileWriterDelegate::Read() {
|
| base::MessageLoop::current()->PostTask(
|
| FROM_HERE,
|
| base::Bind(&FileWriterDelegate::OnDataReceived,
|
| - weak_factory_.GetWeakPtr(), bytes_read_));
|
| + weak_factory_.GetWeakPtr(),
|
| + bytes_read_));
|
| } else if (!request_->status().is_io_pending()) {
|
| OnError(base::File::FILE_ERROR_FAILED);
|
| }
|
| @@ -145,7 +145,8 @@ void FileWriterDelegate::Write() {
|
| base::MessageLoop::current()->PostTask(
|
| FROM_HERE,
|
| base::Bind(&FileWriterDelegate::OnDataWritten,
|
| - weak_factory_.GetWeakPtr(), write_response));
|
| + weak_factory_.GetWeakPtr(),
|
| + write_response));
|
| } else if (net::ERR_IO_PENDING != write_response) {
|
| OnError(NetErrorToFileError(write_response));
|
| }
|
| @@ -194,11 +195,11 @@ void FileWriterDelegate::OnProgress(int bytes_written, bool done) {
|
| bytes_written_backlog_ = 0;
|
|
|
| if (done) {
|
| - MaybeFlushForCompletion(base::File::FILE_OK, bytes_written,
|
| - SUCCESS_COMPLETED);
|
| + MaybeFlushForCompletion(
|
| + base::File::FILE_OK, bytes_written, SUCCESS_COMPLETED);
|
| } else {
|
| - write_callback_.Run(base::File::FILE_OK, bytes_written,
|
| - SUCCESS_IO_PENDING);
|
| + write_callback_.Run(
|
| + base::File::FILE_OK, bytes_written, SUCCESS_IO_PENDING);
|
| }
|
| return;
|
| }
|
| @@ -206,8 +207,8 @@ void FileWriterDelegate::OnProgress(int bytes_written, bool done) {
|
| }
|
|
|
| void FileWriterDelegate::OnWriteCancelled(int status) {
|
| - write_callback_.Run(base::File::FILE_ERROR_ABORT, 0,
|
| - GetCompletionStatusOnError());
|
| + write_callback_.Run(
|
| + base::File::FILE_ERROR_ABORT, 0, GetCompletionStatusOnError());
|
| }
|
|
|
| void FileWriterDelegate::MaybeFlushForCompletion(
|
| @@ -220,9 +221,12 @@ void FileWriterDelegate::MaybeFlushForCompletion(
|
| }
|
| DCHECK_EQ(FLUSH_ON_COMPLETION, flush_policy_);
|
|
|
| - int flush_error = file_stream_writer_->Flush(
|
| - base::Bind(&FileWriterDelegate::OnFlushed, weak_factory_.GetWeakPtr(),
|
| - error, bytes_written, progress_status));
|
| + int flush_error =
|
| + file_stream_writer_->Flush(base::Bind(&FileWriterDelegate::OnFlushed,
|
| + weak_factory_.GetWeakPtr(),
|
| + error,
|
| + bytes_written,
|
| + progress_status));
|
| if (flush_error != net::ERR_IO_PENDING)
|
| OnFlushed(error, bytes_written, progress_status, flush_error);
|
| }
|
| @@ -240,4 +244,4 @@ void FileWriterDelegate::OnFlushed(base::File::Error error,
|
| write_callback_.Run(error, bytes_written, progress_status);
|
| }
|
|
|
| -} // namespace fileapi
|
| +} // namespace storage
|
|
|