Index: chrome/browser/extensions/api/image_writer_private/operation_linux.cc |
diff --git a/chrome/browser/extensions/api/image_writer_private/operation_linux.cc b/chrome/browser/extensions/api/image_writer_private/operation_linux.cc |
deleted file mode 100644 |
index efba6311138f218927e9d7e07f4f51216accf058..0000000000000000000000000000000000000000 |
--- a/chrome/browser/extensions/api/image_writer_private/operation_linux.cc |
+++ /dev/null |
@@ -1,195 +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 "base/file_util.h" |
-#include "base/files/file_enumerator.h" |
-#include "base/threading/worker_pool.h" |
-#include "chrome/browser/extensions/api/image_writer_private/error_messages.h" |
-#include "chrome/browser/extensions/api/image_writer_private/operation.h" |
-#include "chrome/browser/extensions/api/image_writer_private/operation_manager.h" |
-#include "content/public/browser/browser_thread.h" |
-#include "third_party/zlib/google/zip.h" |
- |
-namespace extensions { |
-namespace image_writer { |
- |
-using content::BrowserThread; |
- |
-const int kBurningBlockSize = 8 * 1024; // 8 KiB |
- |
-void Operation::Write(const base::Closure& continuation) { |
- DCHECK(BrowserThread::CurrentlyOn(BrowserThread::FILE)); |
- if (IsCancelled()) { |
- return; |
- } |
- |
- SetStage(image_writer_api::STAGE_WRITE); |
- |
- // TODO (haven): Unmount partitions before writing. http://crbug.com/284834 |
- |
- base::PlatformFileError result; |
- image_file_ = base::CreatePlatformFile( |
- image_path_, |
- base::PLATFORM_FILE_OPEN | base::PLATFORM_FILE_READ, |
- NULL, |
- &result); |
- if (result != base::PLATFORM_FILE_OK) { |
- Error(error::kImageOpenError); |
- return; |
- } |
- |
- device_file_ = base::CreatePlatformFile( |
- device_path_, |
- base::PLATFORM_FILE_OPEN | base::PLATFORM_FILE_WRITE, |
- NULL, |
- &result); |
- if (result != base::PLATFORM_FILE_OK) { |
- Error(error::kDeviceOpenError); |
- base::ClosePlatformFile(image_file_); |
- return; |
- } |
- |
- int64 total_size; |
- base::GetFileSize(image_path_, &total_size); |
- |
- BrowserThread::PostTask( |
- BrowserThread::FILE, |
- FROM_HERE, |
- base::Bind(&Operation::WriteChunk, this, 0, total_size, continuation)); |
-} |
- |
-void Operation::WriteChunk(const int64& bytes_written, |
- const int64& total_size, |
- const base::Closure& continuation) { |
- if (!IsCancelled()) { |
- scoped_ptr<char[]> buffer(new char[kBurningBlockSize]); |
- int64 len = base::ReadPlatformFile( |
- image_file_, bytes_written, buffer.get(), kBurningBlockSize); |
- |
- if (len > 0) { |
- if (base::WritePlatformFile( |
- device_file_, bytes_written, buffer.get(), len) == len) { |
- int percent_curr = |
- kProgressComplete * (bytes_written + len) / total_size; |
- |
- SetProgress(percent_curr); |
- |
- BrowserThread::PostTask(BrowserThread::FILE, |
- FROM_HERE, |
- base::Bind(&Operation::WriteChunk, |
- this, |
- bytes_written + len, |
- total_size, |
- continuation)); |
- return; |
- } else { |
- Error(error::kDeviceWriteError); |
- } |
- } else if (len == 0) { |
- WriteComplete(continuation); |
- } else { // len < 0 |
- Error(error::kImageReadError); |
- } |
- } |
- |
- base::ClosePlatformFile(image_file_); |
- base::ClosePlatformFile(device_file_); |
-} |
- |
-void Operation::WriteComplete(const base::Closure& continuation) { |
- SetProgress(kProgressComplete); |
- BrowserThread::PostTask(BrowserThread::FILE, FROM_HERE, continuation); |
-} |
- |
-void Operation::VerifyWrite(const base::Closure& continuation) { |
- DCHECK(BrowserThread::CurrentlyOn(BrowserThread::FILE)); |
- if (IsCancelled()) { |
- return; |
- } |
- |
- SetStage(image_writer_api::STAGE_VERIFYWRITE); |
- |
- base::PlatformFileError result; |
- |
- image_file_ = base::CreatePlatformFile( |
- image_path_, |
- base::PLATFORM_FILE_OPEN | base::PLATFORM_FILE_READ, |
- NULL, |
- &result); |
- if (result != base::PLATFORM_FILE_OK) { |
- Error(error::kImageOpenError); |
- return; |
- } |
- |
- device_file_ = base::CreatePlatformFile( |
- device_path_, |
- base::PLATFORM_FILE_OPEN | base::PLATFORM_FILE_READ, |
- NULL, |
- &result); |
- if (result != base::PLATFORM_FILE_OK) { |
- Error(error::kDeviceOpenError); |
- base::ClosePlatformFile(image_file_); |
- return; |
- } |
- |
- int64 total_size; |
- base::GetFileSize(image_path_, &total_size); |
- |
- BrowserThread::PostTask( |
- BrowserThread::FILE, |
- FROM_HERE, |
- base::Bind( |
- &Operation::VerifyWriteChunk, this, 0, total_size, continuation)); |
-} |
- |
-void Operation::VerifyWriteChunk(const int64& bytes_processed, |
- const int64& total_size, |
- const base::Closure& continuation) { |
- if (!IsCancelled()) { |
- scoped_ptr<char[]> source_buffer(new char[kBurningBlockSize]); |
- scoped_ptr<char[]> target_buffer(new char[kBurningBlockSize]); |
- |
- int64 image_bytes_read = base::ReadPlatformFile( |
- image_file_, bytes_processed, source_buffer.get(), kBurningBlockSize); |
- |
- if (image_bytes_read > 0) { |
- int64 device_bytes_read = base::ReadPlatformFile( |
- device_file_, bytes_processed, target_buffer.get(), image_bytes_read); |
- if (image_bytes_read == device_bytes_read && |
- memcmp(source_buffer.get(), target_buffer.get(), image_bytes_read) == |
- 0) { |
- int percent_curr = kProgressComplete * |
- (bytes_processed + image_bytes_read) / total_size; |
- |
- SetProgress(percent_curr); |
- |
- BrowserThread::PostTask(BrowserThread::FILE, |
- FROM_HERE, |
- base::Bind(&Operation::VerifyWriteChunk, |
- this, |
- bytes_processed + image_bytes_read, |
- total_size, |
- continuation)); |
- return; |
- } else { |
- Error(error::kVerificationFailed); |
- } |
- } else if (image_bytes_read == 0) { |
- VerifyWriteComplete(continuation); |
- } else { // len < 0 |
- Error(error::kImageReadError); |
- } |
- } |
- |
- base::ClosePlatformFile(image_file_); |
- base::ClosePlatformFile(device_file_); |
-} |
- |
-void Operation::VerifyWriteComplete(const base::Closure& continuation) { |
- SetProgress(kProgressComplete); |
- BrowserThread::PostTask(BrowserThread::FILE, FROM_HERE, continuation); |
-} |
- |
-} // namespace image_writer |
-} // namespace extensions |