Chromium Code Reviews
chromiumcodereview-hr@appspot.gserviceaccount.com (chromiumcodereview-hr) | Please choose your nickname with Settings | Help | Chromium Project | Gerrit Changes | Sign out
(210)

Unified Diff: mojo/services/files/public/cpp/lib/output_stream_file.cc

Issue 1388413005: Move //mojo/services/X/public/... to //mojo/services/X/... (part 1). (Closed) Base URL: https://github.com/domokit/mojo.git@master
Patch Set: Created 5 years, 2 months ago
Use n/p to move between diff chunks; N/P to move between comments. Draft comments are only viewable by you.
Jump to:
View side-by-side diff with in-line comments
Download patch
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
« no previous file with comments | « mojo/services/files/public/cpp/lib/input_stream_file.cc ('k') | mojo/services/files/public/cpp/output_stream_file.h » ('j') | no next file with comments »

Powered by Google App Engine
This is Rietveld 408576698