Index: ui/file_manager/zip_archiver/unpacker/cpp/compressor_io_javascript_stream.cc |
diff --git a/ui/file_manager/zip_archiver/unpacker/cpp/compressor_io_javascript_stream.cc b/ui/file_manager/zip_archiver/unpacker/cpp/compressor_io_javascript_stream.cc |
deleted file mode 100644 |
index 5fdb081f15e4df94925111e85d987a8302f11d7c..0000000000000000000000000000000000000000 |
--- a/ui/file_manager/zip_archiver/unpacker/cpp/compressor_io_javascript_stream.cc |
+++ /dev/null |
@@ -1,84 +0,0 @@ |
-// Copyright 2017 The Chromium OS 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 "compressor_io_javascript_stream.h" |
- |
-#include <limits> |
-#include <thread> |
- |
-#include "archive.h" |
-#include "ppapi/cpp/logging.h" |
- |
-CompressorIOJavaScriptStream::CompressorIOJavaScriptStream( |
- JavaScriptCompressorRequestorInterface* requestor) |
- : requestor_(requestor) { |
- pthread_mutex_init(&shared_state_lock_, NULL); |
- pthread_cond_init(&available_data_cond_, NULL); |
- pthread_cond_init(&data_written_cond_, NULL); |
- |
- pthread_mutex_lock(&shared_state_lock_); |
- available_data_ = false; |
- pthread_mutex_unlock(&shared_state_lock_); |
-} |
- |
-CompressorIOJavaScriptStream::~CompressorIOJavaScriptStream() { |
- pthread_cond_destroy(&data_written_cond_); |
- pthread_cond_destroy(&available_data_cond_); |
- pthread_mutex_destroy(&shared_state_lock_); |
-}; |
- |
-int64_t CompressorIOJavaScriptStream::Write(int64_t byte_to_write, |
- const pp::VarArrayBuffer& buffer) { |
- pthread_mutex_lock(&shared_state_lock_); |
- requestor_->WriteChunkRequest(byte_to_write, buffer); |
- |
- pthread_cond_wait(&data_written_cond_, &shared_state_lock_); |
- |
- int64_t written_bytes = written_bytes_; |
- pthread_mutex_unlock(&shared_state_lock_); |
- |
- return written_bytes; |
-} |
- |
-void CompressorIOJavaScriptStream::WriteChunkDone(int64_t written_bytes) { |
- pthread_mutex_lock(&shared_state_lock_); |
- written_bytes_ = written_bytes; |
- pthread_cond_signal(&data_written_cond_); |
- pthread_mutex_unlock(&shared_state_lock_); |
-} |
- |
-int64_t CompressorIOJavaScriptStream::Read(int64_t bytes_to_read, |
- char* destination_buffer) { |
- pthread_mutex_lock(&shared_state_lock_); |
- |
- destination_buffer_ = destination_buffer; |
- requestor_->ReadFileChunkRequest(bytes_to_read); |
- |
- while (!available_data_) { |
- pthread_cond_wait(&available_data_cond_, &shared_state_lock_); |
- } |
- |
- int64_t read_bytes = read_bytes_; |
- available_data_ = false; |
- pthread_mutex_unlock(&shared_state_lock_); |
- return read_bytes; |
-} |
- |
-void CompressorIOJavaScriptStream::ReadFileChunkDone(int64_t read_bytes, |
- pp::VarArrayBuffer* array_buffer) { |
- pthread_mutex_lock(&shared_state_lock_); |
- |
- // JavaScript sets a negative value in read_bytes if an error occurred while |
- // reading a chunk. |
- if (read_bytes >= 0) { |
- char* array_buffer_data = static_cast<char*>(array_buffer->Map()); |
- memcpy(destination_buffer_, array_buffer_data, read_bytes); |
- array_buffer->Unmap(); |
- } |
- |
- read_bytes_ = read_bytes; |
- available_data_ = true; |
- pthread_cond_signal(&available_data_cond_); |
- pthread_mutex_unlock(&shared_state_lock_); |
-} |