Index: third_party/mojo/src/mojo/edk/system/data_pipe_consumer_dispatcher.h |
diff --git a/third_party/mojo/src/mojo/edk/system/data_pipe_consumer_dispatcher.h b/third_party/mojo/src/mojo/edk/system/data_pipe_consumer_dispatcher.h |
deleted file mode 100644 |
index 138c629d84298a6b24789a015b65ef69ed510288..0000000000000000000000000000000000000000 |
--- a/third_party/mojo/src/mojo/edk/system/data_pipe_consumer_dispatcher.h |
+++ /dev/null |
@@ -1,86 +0,0 @@ |
-// Copyright 2013 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. |
- |
-#ifndef THIRD_PARTY_MOJO_SRC_MOJO_EDK_SYSTEM_DATA_PIPE_CONSUMER_DISPATCHER_H_ |
-#define THIRD_PARTY_MOJO_SRC_MOJO_EDK_SYSTEM_DATA_PIPE_CONSUMER_DISPATCHER_H_ |
- |
-#include "base/memory/ref_counted.h" |
-#include "mojo/public/cpp/system/macros.h" |
-#include "third_party/mojo/src/mojo/edk/system/dispatcher.h" |
-#include "third_party/mojo/src/mojo/edk/system/system_impl_export.h" |
- |
-namespace mojo { |
-namespace system { |
- |
-class DataPipe; |
- |
-// This is the |Dispatcher| implementation for the consumer handle for data |
-// pipes (created by the Mojo primitive |MojoCreateDataPipe()|). This class is |
-// thread-safe. |
-class MOJO_SYSTEM_IMPL_EXPORT DataPipeConsumerDispatcher final |
- : public Dispatcher { |
- public: |
- static scoped_refptr<DataPipeConsumerDispatcher> Create() { |
- return make_scoped_refptr(new DataPipeConsumerDispatcher()); |
- } |
- |
- // Must be called before any other methods. |
- void Init(scoped_refptr<DataPipe> data_pipe) MOJO_NOT_THREAD_SAFE; |
- |
- // |Dispatcher| public methods: |
- Type GetType() const override; |
- |
- // The "opposite" of |SerializeAndClose()|. (Typically this is called by |
- // |Dispatcher::Deserialize()|.) |
- static scoped_refptr<DataPipeConsumerDispatcher> |
- Deserialize(Channel* channel, const void* source, size_t size); |
- |
- // Get access to the |DataPipe| for testing. |
- DataPipe* GetDataPipeForTest(); |
- |
- private: |
- DataPipeConsumerDispatcher(); |
- ~DataPipeConsumerDispatcher() override; |
- |
- // |Dispatcher| protected methods: |
- void CancelAllAwakablesNoLock() override; |
- void CloseImplNoLock() override; |
- scoped_refptr<Dispatcher> CreateEquivalentDispatcherAndCloseImplNoLock() |
- override; |
- MojoResult ReadDataImplNoLock(UserPointer<void> elements, |
- UserPointer<uint32_t> num_bytes, |
- MojoReadDataFlags flags) override; |
- MojoResult BeginReadDataImplNoLock(UserPointer<const void*> buffer, |
- UserPointer<uint32_t> buffer_num_bytes, |
- MojoReadDataFlags flags) override; |
- MojoResult EndReadDataImplNoLock(uint32_t num_bytes_read) override; |
- HandleSignalsState GetHandleSignalsStateImplNoLock() const override; |
- MojoResult AddAwakableImplNoLock(Awakable* awakable, |
- MojoHandleSignals signals, |
- uintptr_t context, |
- HandleSignalsState* signals_state) override; |
- void RemoveAwakableImplNoLock(Awakable* awakable, |
- HandleSignalsState* signals_state) override; |
- void StartSerializeImplNoLock(Channel* channel, |
- size_t* max_size, |
- size_t* max_platform_handles) override |
- MOJO_NOT_THREAD_SAFE; |
- bool EndSerializeAndCloseImplNoLock( |
- Channel* channel, |
- void* destination, |
- size_t* actual_size, |
- embedder::PlatformHandleVector* platform_handles) override |
- MOJO_NOT_THREAD_SAFE; |
- bool IsBusyNoLock() const override; |
- |
- // This will be null if closed. |
- scoped_refptr<DataPipe> data_pipe_ MOJO_GUARDED_BY(mutex()); |
- |
- MOJO_DISALLOW_COPY_AND_ASSIGN(DataPipeConsumerDispatcher); |
-}; |
- |
-} // namespace system |
-} // namespace mojo |
- |
-#endif // THIRD_PARTY_MOJO_SRC_MOJO_EDK_SYSTEM_DATA_PIPE_CONSUMER_DISPATCHER_H_ |