| 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_);
 | 
| -}
 | 
| 
 |