summaryrefslogtreecommitdiffstats
path: root/third_party/mojo/src/mojo/edk/system/incoming_endpoint.h
diff options
context:
space:
mode:
Diffstat (limited to 'third_party/mojo/src/mojo/edk/system/incoming_endpoint.h')
-rw-r--r--third_party/mojo/src/mojo/edk/system/incoming_endpoint.h65
1 files changed, 0 insertions, 65 deletions
diff --git a/third_party/mojo/src/mojo/edk/system/incoming_endpoint.h b/third_party/mojo/src/mojo/edk/system/incoming_endpoint.h
deleted file mode 100644
index 18f76ea..0000000
--- a/third_party/mojo/src/mojo/edk/system/incoming_endpoint.h
+++ /dev/null
@@ -1,65 +0,0 @@
-// Copyright 2014 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_INCOMING_ENDPOINT_H_
-#define THIRD_PARTY_MOJO_SRC_MOJO_EDK_SYSTEM_INCOMING_ENDPOINT_H_
-
-#include <stddef.h>
-
-#include "base/memory/ref_counted.h"
-#include "mojo/public/cpp/system/macros.h"
-#include "third_party/mojo/src/mojo/edk/system/channel_endpoint_client.h"
-#include "third_party/mojo/src/mojo/edk/system/message_in_transit_queue.h"
-#include "third_party/mojo/src/mojo/edk/system/mutex.h"
-#include "third_party/mojo/src/mojo/edk/system/system_impl_export.h"
-
-struct MojoCreateDataPipeOptions;
-
-namespace mojo {
-namespace system {
-
-class ChannelEndpoint;
-class DataPipe;
-class MessagePipe;
-
-// This is a simple |ChannelEndpointClient| that only receives messages. It's
-// used for endpoints that are "received" by |Channel|, but not yet turned into
-// |MessagePipe|s or |DataPipe|s.
-class MOJO_SYSTEM_IMPL_EXPORT IncomingEndpoint final
- : public ChannelEndpointClient {
- public:
- IncomingEndpoint();
-
- // Must be called before any other method.
- scoped_refptr<ChannelEndpoint> Init() MOJO_NOT_THREAD_SAFE;
-
- scoped_refptr<MessagePipe> ConvertToMessagePipe();
- scoped_refptr<DataPipe> ConvertToDataPipeProducer(
- const MojoCreateDataPipeOptions& validated_options,
- size_t consumer_num_bytes);
- scoped_refptr<DataPipe> ConvertToDataPipeConsumer(
- const MojoCreateDataPipeOptions& validated_options);
-
- // Must be called before destroying this object if |ConvertToMessagePipe()|
- // wasn't called (but |Init()| was).
- void Close();
-
- // |ChannelEndpointClient| methods:
- bool OnReadMessage(unsigned port, MessageInTransit* message) override;
- void OnDetachFromChannel(unsigned port) override;
-
- private:
- ~IncomingEndpoint() override;
-
- Mutex mutex_;
- scoped_refptr<ChannelEndpoint> endpoint_ MOJO_GUARDED_BY(mutex_);
- MessageInTransitQueue message_queue_ MOJO_GUARDED_BY(mutex_);
-
- MOJO_DISALLOW_COPY_AND_ASSIGN(IncomingEndpoint);
-};
-
-} // namespace system
-} // namespace mojo
-
-#endif // THIRD_PARTY_MOJO_SRC_MOJO_EDK_SYSTEM_INCOMING_ENDPOINT_H_