diff options
Diffstat (limited to 'mojo/edk/system/local_message_pipe_endpoint.h')
-rw-r--r-- | mojo/edk/system/local_message_pipe_endpoint.h | 67 |
1 files changed, 0 insertions, 67 deletions
diff --git a/mojo/edk/system/local_message_pipe_endpoint.h b/mojo/edk/system/local_message_pipe_endpoint.h deleted file mode 100644 index f792d90..0000000 --- a/mojo/edk/system/local_message_pipe_endpoint.h +++ /dev/null @@ -1,67 +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 MOJO_EDK_SYSTEM_LOCAL_MESSAGE_PIPE_ENDPOINT_H_ -#define MOJO_EDK_SYSTEM_LOCAL_MESSAGE_PIPE_ENDPOINT_H_ - -#include "base/compiler_specific.h" -#include "base/macros.h" -#include "mojo/edk/system/awakable_list.h" -#include "mojo/edk/system/handle_signals_state.h" -#include "mojo/edk/system/message_in_transit_queue.h" -#include "mojo/edk/system/message_pipe_endpoint.h" -#include "mojo/edk/system/system_impl_export.h" - -namespace mojo { -namespace system { - -class MOJO_SYSTEM_IMPL_EXPORT LocalMessagePipeEndpoint - : public MessagePipeEndpoint { - public: - // If |message_queue| is non-null, its contents will be taken as the queue of - // (already-received) messages. - explicit LocalMessagePipeEndpoint( - MessageInTransitQueue* message_queue = nullptr); - ~LocalMessagePipeEndpoint() override; - - // |MessagePipeEndpoint| implementation: - Type GetType() const override; - bool OnPeerClose() override; - void EnqueueMessage(scoped_ptr<MessageInTransit> message) override; - - // There's a dispatcher for |LocalMessagePipeEndpoint|s, so we have to - // implement/override these: - void Close() override; - void CancelAllAwakables() override; - MojoResult ReadMessage(UserPointer<void> bytes, - UserPointer<uint32_t> num_bytes, - DispatcherVector* dispatchers, - uint32_t* num_dispatchers, - MojoReadMessageFlags flags) override; - HandleSignalsState GetHandleSignalsState() const override; - MojoResult AddAwakable(Awakable* awakable, - MojoHandleSignals signals, - uint32_t context, - HandleSignalsState* signals_state) override; - void RemoveAwakable(Awakable* awakable, - HandleSignalsState* signals_state) override; - - // This is only to be used by |MessagePipe|: - MessageInTransitQueue* message_queue() { return &message_queue_; } - - private: - bool is_open_; - bool is_peer_open_; - - // Queue of incoming messages. - MessageInTransitQueue message_queue_; - AwakableList awakable_list_; - - DISALLOW_COPY_AND_ASSIGN(LocalMessagePipeEndpoint); -}; - -} // namespace system -} // namespace mojo - -#endif // MOJO_EDK_SYSTEM_LOCAL_MESSAGE_PIPE_ENDPOINT_H_ |