| Index: mojo/services/files/public/cpp/lib/output_stream_file.cc
 | 
| diff --git a/mojo/services/files/public/cpp/lib/output_stream_file.cc b/mojo/services/files/public/cpp/lib/output_stream_file.cc
 | 
| deleted file mode 100644
 | 
| index a1a068aecc442ac58f5023e0ffacf64c78e9bf21..0000000000000000000000000000000000000000
 | 
| --- a/mojo/services/files/public/cpp/lib/output_stream_file.cc
 | 
| +++ /dev/null
 | 
| @@ -1,232 +0,0 @@
 | 
| -// Copyright 2015 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 "mojo/services/files/public/cpp/output_stream_file.h"
 | 
| -
 | 
| -#include "mojo/public/cpp/environment/logging.h"
 | 
| -
 | 
| -namespace files_impl {
 | 
| -
 | 
| -// static
 | 
| -std::unique_ptr<OutputStreamFile> OutputStreamFile::Create(
 | 
| -    Client* client,
 | 
| -    mojo::InterfaceRequest<mojo::files::File> request) {
 | 
| -  // TODO(vtl): Use make_unique when we have C++14.
 | 
| -  return std::unique_ptr<OutputStreamFile>(
 | 
| -      new OutputStreamFile(client, request.Pass()));
 | 
| -}
 | 
| -
 | 
| -OutputStreamFile::~OutputStreamFile() {}
 | 
| -
 | 
| -OutputStreamFile::OutputStreamFile(
 | 
| -    Client* client,
 | 
| -    mojo::InterfaceRequest<mojo::files::File> request)
 | 
| -    : client_(client), is_closed_(false), binding_(this, request.Pass()) {
 | 
| -  binding_.set_connection_error_handler([this]() {
 | 
| -    if (client_)
 | 
| -      client_->OnClosed();
 | 
| -  });
 | 
| -}
 | 
| -
 | 
| -void OutputStreamFile::Close(const CloseCallback& callback) {
 | 
| -  if (is_closed_) {
 | 
| -    callback.Run(mojo::files::Error::CLOSED);
 | 
| -    return;
 | 
| -  }
 | 
| -
 | 
| -  is_closed_ = true;
 | 
| -  callback.Run(mojo::files::Error::OK);
 | 
| -
 | 
| -  if (client_)
 | 
| -    client_->OnClosed();
 | 
| -}
 | 
| -
 | 
| -void OutputStreamFile::Read(uint32_t num_bytes_to_read,
 | 
| -                            int64_t offset,
 | 
| -                            mojo::files::Whence whence,
 | 
| -                            const ReadCallback& callback) {
 | 
| -  if (is_closed_) {
 | 
| -    callback.Run(mojo::files::Error::CLOSED, mojo::Array<uint8_t>());
 | 
| -    return;
 | 
| -  }
 | 
| -
 | 
| -  // TODO(vtl): Is this what we want? (Also is "unavailable" right? Maybe
 | 
| -  // unsupported/EINVAL is better.)
 | 
| -  callback.Run(mojo::files::Error::UNAVAILABLE, mojo::Array<uint8_t>());
 | 
| -}
 | 
| -
 | 
| -void OutputStreamFile::Write(mojo::Array<uint8_t> bytes_to_write,
 | 
| -                             int64_t offset,
 | 
| -                             mojo::files::Whence whence,
 | 
| -                             const WriteCallback& callback) {
 | 
| -  MOJO_DCHECK(!bytes_to_write.is_null());
 | 
| -
 | 
| -  if (is_closed_) {
 | 
| -    callback.Run(mojo::files::Error::CLOSED, 0);
 | 
| -    return;
 | 
| -  }
 | 
| -
 | 
| -  if (offset != 0 || whence != mojo::files::Whence::FROM_CURRENT) {
 | 
| -    // TODO(vtl): Is this the "right" behavior?
 | 
| -    callback.Run(mojo::files::Error::INVALID_ARGUMENT, 0);
 | 
| -    return;
 | 
| -  }
 | 
| -
 | 
| -  if (!bytes_to_write.size()) {
 | 
| -    callback.Run(mojo::files::Error::OK, 0);
 | 
| -    return;
 | 
| -  }
 | 
| -
 | 
| -  // We require the client to handle all the output, so we run the callback now.
 | 
| -  // TODO(vtl): This means that the callback will be run (and the response
 | 
| -  // message sent), even if the client decides to destroy us -- and thus close
 | 
| -  // the message pipe -- in |OnDataReceived()|. This may makes throttling
 | 
| -  // slightly less effective -- but increase parallelism -- since the writer may
 | 
| -  // enqueue another write immediately.
 | 
| -  callback.Run(mojo::files::Error::OK,
 | 
| -               static_cast<uint32_t>(bytes_to_write.size()));
 | 
| -
 | 
| -  if (client_)
 | 
| -    client_->OnDataReceived(&bytes_to_write.front(), bytes_to_write.size());
 | 
| -}
 | 
| -
 | 
| -void OutputStreamFile::ReadToStream(mojo::ScopedDataPipeProducerHandle source,
 | 
| -                                    int64_t offset,
 | 
| -                                    mojo::files::Whence whence,
 | 
| -                                    int64_t num_bytes_to_read,
 | 
| -                                    const ReadToStreamCallback& callback) {
 | 
| -  if (is_closed_) {
 | 
| -    callback.Run(mojo::files::Error::CLOSED);
 | 
| -    return;
 | 
| -  }
 | 
| -
 | 
| -  // TODO(vtl): Is this what we want? (Also is "unavailable" right? Maybe
 | 
| -  // unsupported/EINVAL is better.)
 | 
| -  callback.Run(mojo::files::Error::UNAVAILABLE);
 | 
| -}
 | 
| -
 | 
| -void OutputStreamFile::WriteFromStream(
 | 
| -    mojo::ScopedDataPipeConsumerHandle sink,
 | 
| -    int64_t offset,
 | 
| -    mojo::files::Whence whence,
 | 
| -    const WriteFromStreamCallback& callback) {
 | 
| -  if (is_closed_) {
 | 
| -    callback.Run(mojo::files::Error::CLOSED);
 | 
| -    return;
 | 
| -  }
 | 
| -
 | 
| -  // TODO(vtl)
 | 
| -  MOJO_DLOG(ERROR) << "Not implemented";
 | 
| -  callback.Run(mojo::files::Error::UNIMPLEMENTED);
 | 
| -}
 | 
| -
 | 
| -void OutputStreamFile::Tell(const TellCallback& callback) {
 | 
| -  if (is_closed_) {
 | 
| -    callback.Run(mojo::files::Error::CLOSED, 0);
 | 
| -    return;
 | 
| -  }
 | 
| -
 | 
| -  // TODO(vtl): Is this what we want? (Also is "unavailable" right? Maybe
 | 
| -  // unsupported/EINVAL is better.)
 | 
| -  callback.Run(mojo::files::Error::UNAVAILABLE, 0);
 | 
| -}
 | 
| -
 | 
| -void OutputStreamFile::Seek(int64_t offset,
 | 
| -                            mojo::files::Whence whence,
 | 
| -                            const SeekCallback& callback) {
 | 
| -  if (is_closed_) {
 | 
| -    callback.Run(mojo::files::Error::CLOSED, 0);
 | 
| -    return;
 | 
| -  }
 | 
| -
 | 
| -  // TODO(vtl): Is this what we want? (Also is "unavailable" right? Maybe
 | 
| -  // unsupported/EINVAL is better.)
 | 
| -  callback.Run(mojo::files::Error::UNAVAILABLE, 0);
 | 
| -}
 | 
| -
 | 
| -void OutputStreamFile::Stat(const StatCallback& callback) {
 | 
| -  if (is_closed_) {
 | 
| -    callback.Run(mojo::files::Error::CLOSED, nullptr);
 | 
| -    return;
 | 
| -  }
 | 
| -
 | 
| -  // TODO(vtl)
 | 
| -  MOJO_DLOG(ERROR) << "Not implemented";
 | 
| -  callback.Run(mojo::files::Error::UNIMPLEMENTED, nullptr);
 | 
| -}
 | 
| -
 | 
| -void OutputStreamFile::Truncate(int64_t size,
 | 
| -                                const TruncateCallback& callback) {
 | 
| -  if (is_closed_) {
 | 
| -    callback.Run(mojo::files::Error::CLOSED);
 | 
| -    return;
 | 
| -  }
 | 
| -
 | 
| -  // TODO(vtl): Is this what we want? (Also is "unavailable" right? Maybe
 | 
| -  // unsupported/EINVAL is better.)
 | 
| -  callback.Run(mojo::files::Error::UNAVAILABLE);
 | 
| -}
 | 
| -
 | 
| -void OutputStreamFile::Touch(mojo::files::TimespecOrNowPtr atime,
 | 
| -                             mojo::files::TimespecOrNowPtr mtime,
 | 
| -                             const TouchCallback& callback) {
 | 
| -  if (is_closed_) {
 | 
| -    callback.Run(mojo::files::Error::CLOSED);
 | 
| -    return;
 | 
| -  }
 | 
| -
 | 
| -  // TODO(vtl): Is this what we want? (Also is "unavailable" right? Maybe
 | 
| -  // unsupported/EINVAL is better.)
 | 
| -  callback.Run(mojo::files::Error::UNAVAILABLE);
 | 
| -}
 | 
| -
 | 
| -void OutputStreamFile::Dup(mojo::InterfaceRequest<mojo::files::File> file,
 | 
| -                           const DupCallback& callback) {
 | 
| -  if (is_closed_) {
 | 
| -    callback.Run(mojo::files::Error::CLOSED);
 | 
| -    return;
 | 
| -  }
 | 
| -
 | 
| -  // TODO(vtl): Is this what we want? (Also is "unavailable" right? Maybe
 | 
| -  // unsupported/EINVAL is better.)
 | 
| -  callback.Run(mojo::files::Error::UNAVAILABLE);
 | 
| -}
 | 
| -
 | 
| -void OutputStreamFile::Reopen(mojo::InterfaceRequest<mojo::files::File> file,
 | 
| -                              uint32_t open_flags,
 | 
| -                              const ReopenCallback& callback) {
 | 
| -  if (is_closed_) {
 | 
| -    callback.Run(mojo::files::Error::CLOSED);
 | 
| -    return;
 | 
| -  }
 | 
| -
 | 
| -  // TODO(vtl): Is this what we want? (Also is "unavailable" right? Maybe
 | 
| -  // unsupported/EINVAL is better.)
 | 
| -  callback.Run(mojo::files::Error::UNAVAILABLE);
 | 
| -}
 | 
| -
 | 
| -void OutputStreamFile::AsBuffer(const AsBufferCallback& callback) {
 | 
| -  if (is_closed_) {
 | 
| -    callback.Run(mojo::files::Error::CLOSED, mojo::ScopedSharedBufferHandle());
 | 
| -    return;
 | 
| -  }
 | 
| -
 | 
| -  // TODO(vtl): Is this what we want? (Also is "unavailable" right? Maybe
 | 
| -  // unsupported/EINVAL is better.)
 | 
| -  callback.Run(mojo::files::Error::UNAVAILABLE,
 | 
| -               mojo::ScopedSharedBufferHandle());
 | 
| -}
 | 
| -
 | 
| -void OutputStreamFile::Ioctl(uint32_t request,
 | 
| -                             mojo::Array<uint32_t> in_values,
 | 
| -                             const IoctlCallback& callback) {
 | 
| -  if (is_closed_) {
 | 
| -    callback.Run(mojo::files::Error::CLOSED, mojo::Array<uint32_t>());
 | 
| -    return;
 | 
| -  }
 | 
| -
 | 
| -  callback.Run(mojo::files::Error::UNIMPLEMENTED, mojo::Array<uint32_t>());
 | 
| -}
 | 
| -
 | 
| -}  // namespace files_impl
 | 
| 
 |