| Index: chrome/browser/chromeos/drive/file_system/truncate_operation.cc
|
| diff --git a/chrome/browser/chromeos/drive/file_system/truncate_operation.cc b/chrome/browser/chromeos/drive/file_system/truncate_operation.cc
|
| deleted file mode 100644
|
| index ff1307e460ab57c31f0fde02f4bcaf8fbb19f662..0000000000000000000000000000000000000000
|
| --- a/chrome/browser/chromeos/drive/file_system/truncate_operation.cc
|
| +++ /dev/null
|
| @@ -1,145 +0,0 @@
|
| -// Copyright 2013 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 "chrome/browser/chromeos/drive/file_system/truncate_operation.h"
|
| -
|
| -#include "base/bind.h"
|
| -#include "base/callback_helpers.h"
|
| -#include "base/files/file.h"
|
| -#include "base/files/file_path.h"
|
| -#include "base/logging.h"
|
| -#include "base/sequenced_task_runner.h"
|
| -#include "base/task_runner_util.h"
|
| -#include "base/thread_task_runner_handle.h"
|
| -#include "chrome/browser/chromeos/drive/drive.pb.h"
|
| -#include "chrome/browser/chromeos/drive/file_cache.h"
|
| -#include "chrome/browser/chromeos/drive/file_errors.h"
|
| -#include "chrome/browser/chromeos/drive/file_system/download_operation.h"
|
| -#include "chrome/browser/chromeos/drive/file_system/operation_delegate.h"
|
| -#include "chrome/browser/chromeos/drive/job_scheduler.h"
|
| -
|
| -namespace drive {
|
| -namespace file_system {
|
| -namespace {
|
| -
|
| -// Truncates the local file at |local_cache_path| to the |length| bytes,
|
| -// then marks the resource is dirty on |cache|.
|
| -FileError TruncateOnBlockingPool(internal::ResourceMetadata* metadata,
|
| - internal::FileCache* cache,
|
| - const std::string& local_id,
|
| - const base::FilePath& local_cache_path,
|
| - int64 length) {
|
| - DCHECK(metadata);
|
| - DCHECK(cache);
|
| -
|
| - scoped_ptr<base::ScopedClosureRunner> file_closer;
|
| - FileError error = cache->OpenForWrite(local_id, &file_closer);
|
| - if (error != FILE_ERROR_OK)
|
| - return error;
|
| -
|
| - base::File file(local_cache_path,
|
| - base::File::FLAG_OPEN | base::File::FLAG_WRITE);
|
| - if (!file.IsValid())
|
| - return FILE_ERROR_FAILED;
|
| -
|
| - if (!file.SetLength(length))
|
| - return FILE_ERROR_FAILED;
|
| -
|
| - return FILE_ERROR_OK;
|
| -}
|
| -
|
| -} // namespace
|
| -
|
| -TruncateOperation::TruncateOperation(
|
| - base::SequencedTaskRunner* blocking_task_runner,
|
| - OperationDelegate* delegate,
|
| - JobScheduler* scheduler,
|
| - internal::ResourceMetadata* metadata,
|
| - internal::FileCache* cache,
|
| - const base::FilePath& temporary_file_directory)
|
| - : blocking_task_runner_(blocking_task_runner),
|
| - delegate_(delegate),
|
| - metadata_(metadata),
|
| - cache_(cache),
|
| - download_operation_(new DownloadOperation(blocking_task_runner,
|
| - delegate,
|
| - scheduler,
|
| - metadata,
|
| - cache,
|
| - temporary_file_directory)),
|
| - weak_ptr_factory_(this) {
|
| -}
|
| -
|
| -TruncateOperation::~TruncateOperation() {
|
| -}
|
| -
|
| -void TruncateOperation::Truncate(const base::FilePath& file_path,
|
| - int64 length,
|
| - const FileOperationCallback& callback) {
|
| - DCHECK(thread_checker_.CalledOnValidThread());
|
| - DCHECK(!callback.is_null());
|
| -
|
| - if (length < 0) {
|
| - base::ThreadTaskRunnerHandle::Get()->PostTask(
|
| - FROM_HERE,
|
| - base::Bind(callback, FILE_ERROR_INVALID_OPERATION));
|
| - return;
|
| - }
|
| -
|
| - // TODO(kinaba): http://crbug.com/132780.
|
| - // Optimize the cases for small |length|, at least for |length| == 0.
|
| - download_operation_->EnsureFileDownloadedByPath(
|
| - file_path,
|
| - ClientContext(USER_INITIATED),
|
| - GetFileContentInitializedCallback(),
|
| - google_apis::GetContentCallback(),
|
| - base::Bind(&TruncateOperation::TruncateAfterEnsureFileDownloadedByPath,
|
| - weak_ptr_factory_.GetWeakPtr(), length, callback));
|
| -}
|
| -
|
| -void TruncateOperation::TruncateAfterEnsureFileDownloadedByPath(
|
| - int64 length,
|
| - const FileOperationCallback& callback,
|
| - FileError error,
|
| - const base::FilePath& local_file_path,
|
| - scoped_ptr<ResourceEntry> entry) {
|
| - DCHECK(thread_checker_.CalledOnValidThread());
|
| - DCHECK(!callback.is_null());
|
| -
|
| - if (error != FILE_ERROR_OK) {
|
| - callback.Run(error);
|
| - return;
|
| - }
|
| - DCHECK(entry);
|
| - DCHECK(entry->has_file_specific_info());
|
| -
|
| - if (entry->file_specific_info().is_hosted_document()) {
|
| - callback.Run(FILE_ERROR_INVALID_OPERATION);
|
| - return;
|
| - }
|
| -
|
| - base::PostTaskAndReplyWithResult(
|
| - blocking_task_runner_.get(),
|
| - FROM_HERE,
|
| - base::Bind(&TruncateOnBlockingPool,
|
| - metadata_, cache_, entry->local_id(), local_file_path, length),
|
| - base::Bind(
|
| - &TruncateOperation::TruncateAfterTruncateOnBlockingPool,
|
| - weak_ptr_factory_.GetWeakPtr(), entry->local_id(), callback));
|
| -}
|
| -
|
| -void TruncateOperation::TruncateAfterTruncateOnBlockingPool(
|
| - const std::string& local_id,
|
| - const FileOperationCallback& callback,
|
| - FileError error) {
|
| - DCHECK(thread_checker_.CalledOnValidThread());
|
| - DCHECK(!callback.is_null());
|
| -
|
| - delegate_->OnEntryUpdatedByOperation(ClientContext(USER_INITIATED), local_id);
|
| -
|
| - callback.Run(error);
|
| -}
|
| -
|
| -} // namespace file_system
|
| -} // namespace drive
|
|
|