Index: mojo/services/files/public/cpp/output_stream_file.h |
diff --git a/mojo/services/files/public/cpp/output_stream_file.h b/mojo/services/files/public/cpp/output_stream_file.h |
deleted file mode 100644 |
index 037ea948265aa182317a3cdd2bcccb06b58ee975..0000000000000000000000000000000000000000 |
--- a/mojo/services/files/public/cpp/output_stream_file.h |
+++ /dev/null |
@@ -1,114 +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. |
- |
-// This is a helper class for implementing a |mojo::files::File| that behaves |
-// like an "output stream" ("output" from the point of view of the client -- |
-// i.e., the client can write/stream output to it, but not read or seek). |
- |
-#ifndef MOJO_SERVICES_FILES_PUBLIC_CPP_OUTPUT_STREAM_FILE_H_ |
-#define MOJO_SERVICES_FILES_PUBLIC_CPP_OUTPUT_STREAM_FILE_H_ |
- |
-#include <stddef.h> |
- |
-#include <memory> |
- |
-#include "mojo/public/cpp/bindings/binding.h" |
-#include "mojo/public/cpp/bindings/interface_request.h" |
-#include "mojo/public/cpp/system/macros.h" |
-#include "mojo/services/files/public/interfaces/file.mojom.h" |
-#include "mojo/services/files/public/interfaces/types.mojom.h" |
- |
-namespace files_impl { |
- |
-class OutputStreamFile : public mojo::files::File { |
- public: |
- // The |Client| receives data written to the stream "file" as well as other |
- // notifications (e.g., of the "file" being closed). From any of the methods |
- // below, the client may choose to destroy the |OutputStreamFile|. |
- class Client { |
- public: |
- // Called when we receive data from the stream "file". |
- // TODO(vtl): Maybe add a way to throttle (e.g., for the client to not |
- // accept all the data). |
- virtual void OnDataReceived(const void* bytes, size_t num_bytes) = 0; |
- |
- // Called when the stream "file" is closed, via |Close()| or due to the |
- // other end of the message pipe being closed. (This will not be called due |
- // the |OutputStreamFile| being destroyed.) |
- virtual void OnClosed() = 0; |
- |
- protected: |
- virtual ~Client() {} |
- }; |
- |
- // Static factory method. |client| may be null, but if not it should typically |
- // outlive us (see |set_client()|). |
- static std::unique_ptr<OutputStreamFile> Create( |
- Client* client, |
- mojo::InterfaceRequest<mojo::files::File> request); |
- |
- ~OutputStreamFile() override; |
- |
- // Sets the client (which may be null, in which case all |Write()|s to the |
- // stream "file" will just succeed). If non-null, |client| must be valid |
- // whenever the run (a.k.a. message) loop is run, i.e., whenever a client |
- // method may be called. |
- void set_client(Client* client) { client_ = client; } |
- |
- private: |
- OutputStreamFile(Client* client, |
- mojo::InterfaceRequest<mojo::files::File> request); |
- |
- // We should only be deleted by "ourself" (via the strong binding). |
- friend class mojo::Binding<mojo::files::File>; |
- |
- // |mojo::files::File| implementation: |
- void Close(const CloseCallback& callback) override; |
- void Read(uint32_t num_bytes_to_read, |
- int64_t offset, |
- mojo::files::Whence whence, |
- const ReadCallback& callback) override; |
- void Write(mojo::Array<uint8_t> bytes_to_write, |
- int64_t offset, |
- mojo::files::Whence whence, |
- const WriteCallback& callback) override; |
- void ReadToStream(mojo::ScopedDataPipeProducerHandle source, |
- int64_t offset, |
- mojo::files::Whence whence, |
- int64_t num_bytes_to_read, |
- const ReadToStreamCallback& callback) override; |
- void WriteFromStream(mojo::ScopedDataPipeConsumerHandle sink, |
- int64_t offset, |
- mojo::files::Whence whence, |
- const WriteFromStreamCallback& callback) override; |
- void Tell(const TellCallback& callback) override; |
- void Seek(int64_t offset, |
- mojo::files::Whence whence, |
- const SeekCallback& callback) override; |
- void Stat(const StatCallback& callback) override; |
- void Truncate(int64_t size, const TruncateCallback& callback) override; |
- void Touch(mojo::files::TimespecOrNowPtr atime, |
- mojo::files::TimespecOrNowPtr mtime, |
- const TouchCallback& callback) override; |
- void Dup(mojo::InterfaceRequest<mojo::files::File> file, |
- const DupCallback& callback) override; |
- void Reopen(mojo::InterfaceRequest<mojo::files::File> file, |
- uint32_t open_flags, |
- const ReopenCallback& callback) override; |
- void AsBuffer(const AsBufferCallback& callback) override; |
- void Ioctl(uint32_t request, |
- mojo::Array<uint32_t> in_values, |
- const IoctlCallback& callback) override; |
- |
- Client* client_; |
- bool is_closed_; |
- |
- mojo::Binding<mojo::files::File> binding_; |
- |
- MOJO_DISALLOW_COPY_AND_ASSIGN(OutputStreamFile); |
-}; |
- |
-} // namespace files_impl |
- |
-#endif // MOJO_SERVICES_FILES_PUBLIC_CPP_OUTPUT_STREAM_FILE_H_ |