Chromium Code Reviews
chromiumcodereview-hr@appspot.gserviceaccount.com (chromiumcodereview-hr) | Please choose your nickname with Settings | Help | Chromium Project | Gerrit Changes | Sign out
(701)

Unified Diff: webkit/browser/fileapi/local_file_stream_writer.cc

Issue 539143002: Migrate webkit/browser/ to storage/browser/ (Closed) Base URL: https://chromium.googlesource.com/chromium/src.git@master
Patch Set: Created 6 years, 3 months ago
Use n/p to move between diff chunks; N/P to move between comments. Draft comments are only viewable by you.
Jump to:
View side-by-side diff with in-line comments
Download patch
Index: webkit/browser/fileapi/local_file_stream_writer.cc
diff --git a/webkit/browser/fileapi/local_file_stream_writer.cc b/webkit/browser/fileapi/local_file_stream_writer.cc
deleted file mode 100644
index 6f58ffa5ba0772b9b9b98eaafe30c14d53f5d114..0000000000000000000000000000000000000000
--- a/webkit/browser/fileapi/local_file_stream_writer.cc
+++ /dev/null
@@ -1,257 +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 "webkit/browser/fileapi/local_file_stream_writer.h"
-
-#include "base/callback.h"
-#include "base/message_loop/message_loop.h"
-#include "net/base/file_stream.h"
-#include "net/base/io_buffer.h"
-#include "net/base/net_errors.h"
-
-namespace storage {
-
-namespace {
-
-const int kOpenFlagsForWrite = base::File::FLAG_OPEN |
- base::File::FLAG_WRITE |
- base::File::FLAG_ASYNC;
-const int kCreateFlagsForWrite = base::File::FLAG_CREATE |
- base::File::FLAG_WRITE |
- base::File::FLAG_ASYNC;
-
-} // namespace
-
-FileStreamWriter* FileStreamWriter::CreateForLocalFile(
- base::TaskRunner* task_runner,
- const base::FilePath& file_path,
- int64 initial_offset,
- OpenOrCreate open_or_create) {
- return new LocalFileStreamWriter(
- task_runner, file_path, initial_offset, open_or_create);
-}
-
-LocalFileStreamWriter::~LocalFileStreamWriter() {
- // Invalidate weak pointers so that we won't receive any callbacks from
- // in-flight stream operations, which might be triggered during the file close
- // in the FileStream destructor.
- weak_factory_.InvalidateWeakPtrs();
-
- // FileStream's destructor closes the file safely, since we opened the file
- // by its Open() method.
-}
-
-int LocalFileStreamWriter::Write(net::IOBuffer* buf, int buf_len,
- const net::CompletionCallback& callback) {
- DCHECK(!has_pending_operation_);
- DCHECK(cancel_callback_.is_null());
-
- has_pending_operation_ = true;
- if (stream_impl_) {
- int result = InitiateWrite(buf, buf_len, callback);
- if (result != net::ERR_IO_PENDING)
- has_pending_operation_ = false;
- return result;
- }
- return InitiateOpen(callback,
- base::Bind(&LocalFileStreamWriter::ReadyToWrite,
- weak_factory_.GetWeakPtr(),
- make_scoped_refptr(buf), buf_len, callback));
-}
-
-int LocalFileStreamWriter::Cancel(const net::CompletionCallback& callback) {
- if (!has_pending_operation_)
- return net::ERR_UNEXPECTED;
-
- DCHECK(!callback.is_null());
- cancel_callback_ = callback;
- return net::ERR_IO_PENDING;
-}
-
-int LocalFileStreamWriter::Flush(const net::CompletionCallback& callback) {
- DCHECK(!has_pending_operation_);
- DCHECK(cancel_callback_.is_null());
-
- // Write() is not called yet, so there's nothing to flush.
- if (!stream_impl_)
- return net::OK;
-
- has_pending_operation_ = true;
- int result = InitiateFlush(callback);
- if (result != net::ERR_IO_PENDING)
- has_pending_operation_ = false;
- return result;
-}
-
-LocalFileStreamWriter::LocalFileStreamWriter(base::TaskRunner* task_runner,
- const base::FilePath& file_path,
- int64 initial_offset,
- OpenOrCreate open_or_create)
- : file_path_(file_path),
- open_or_create_(open_or_create),
- initial_offset_(initial_offset),
- task_runner_(task_runner),
- has_pending_operation_(false),
- weak_factory_(this) {}
-
-int LocalFileStreamWriter::InitiateOpen(
- const net::CompletionCallback& error_callback,
- const base::Closure& main_operation) {
- DCHECK(has_pending_operation_);
- DCHECK(!stream_impl_.get());
-
- stream_impl_.reset(new net::FileStream(task_runner_));
-
- int open_flags = 0;
- switch (open_or_create_) {
- case OPEN_EXISTING_FILE:
- open_flags = kOpenFlagsForWrite;
- break;
- case CREATE_NEW_FILE:
- open_flags = kCreateFlagsForWrite;
- break;
- }
-
- return stream_impl_->Open(file_path_,
- open_flags,
- base::Bind(&LocalFileStreamWriter::DidOpen,
- weak_factory_.GetWeakPtr(),
- error_callback,
- main_operation));
-}
-
-void LocalFileStreamWriter::DidOpen(
- const net::CompletionCallback& error_callback,
- const base::Closure& main_operation,
- int result) {
- DCHECK(has_pending_operation_);
- DCHECK(stream_impl_.get());
-
- if (CancelIfRequested())
- return;
-
- if (result != net::OK) {
- has_pending_operation_ = false;
- stream_impl_.reset(NULL);
- error_callback.Run(result);
- return;
- }
-
- InitiateSeek(error_callback, main_operation);
-}
-
-void LocalFileStreamWriter::InitiateSeek(
- const net::CompletionCallback& error_callback,
- const base::Closure& main_operation) {
- DCHECK(has_pending_operation_);
- DCHECK(stream_impl_.get());
-
- if (initial_offset_ == 0) {
- // No need to seek.
- main_operation.Run();
- return;
- }
-
- int result = stream_impl_->Seek(base::File::FROM_BEGIN, initial_offset_,
- base::Bind(&LocalFileStreamWriter::DidSeek,
- weak_factory_.GetWeakPtr(),
- error_callback,
- main_operation));
- if (result != net::ERR_IO_PENDING) {
- has_pending_operation_ = false;
- error_callback.Run(result);
- }
-}
-
-void LocalFileStreamWriter::DidSeek(
- const net::CompletionCallback& error_callback,
- const base::Closure& main_operation,
- int64 result) {
- DCHECK(has_pending_operation_);
-
- if (CancelIfRequested())
- return;
-
- if (result != initial_offset_) {
- // TODO(kinaba) add a more specific error code.
- result = net::ERR_FAILED;
- }
-
- if (result < 0) {
- has_pending_operation_ = false;
- error_callback.Run(static_cast<int>(result));
- return;
- }
-
- main_operation.Run();
-}
-
-void LocalFileStreamWriter::ReadyToWrite(
- net::IOBuffer* buf, int buf_len,
- const net::CompletionCallback& callback) {
- DCHECK(has_pending_operation_);
-
- int result = InitiateWrite(buf, buf_len, callback);
- if (result != net::ERR_IO_PENDING) {
- has_pending_operation_ = false;
- callback.Run(result);
- }
-}
-
-int LocalFileStreamWriter::InitiateWrite(
- net::IOBuffer* buf, int buf_len,
- const net::CompletionCallback& callback) {
- DCHECK(has_pending_operation_);
- DCHECK(stream_impl_.get());
-
- return stream_impl_->Write(buf, buf_len,
- base::Bind(&LocalFileStreamWriter::DidWrite,
- weak_factory_.GetWeakPtr(),
- callback));
-}
-
-void LocalFileStreamWriter::DidWrite(const net::CompletionCallback& callback,
- int result) {
- DCHECK(has_pending_operation_);
-
- if (CancelIfRequested())
- return;
- has_pending_operation_ = false;
- callback.Run(result);
-}
-
-int LocalFileStreamWriter::InitiateFlush(
- const net::CompletionCallback& callback) {
- DCHECK(has_pending_operation_);
- DCHECK(stream_impl_.get());
-
- return stream_impl_->Flush(base::Bind(&LocalFileStreamWriter::DidFlush,
- weak_factory_.GetWeakPtr(),
- callback));
-}
-
-void LocalFileStreamWriter::DidFlush(const net::CompletionCallback& callback,
- int result) {
- DCHECK(has_pending_operation_);
-
- if (CancelIfRequested())
- return;
- has_pending_operation_ = false;
- callback.Run(result);
-}
-
-bool LocalFileStreamWriter::CancelIfRequested() {
- DCHECK(has_pending_operation_);
-
- if (cancel_callback_.is_null())
- return false;
-
- net::CompletionCallback pending_cancel = cancel_callback_;
- has_pending_operation_ = false;
- cancel_callback_.Reset();
- pending_cancel.Run(net::OK);
- return true;
-}
-
-} // namespace storage

Powered by Google App Engine
This is Rietveld 408576698