| Index: third_party/mojo/src/mojo/edk/system/incoming_endpoint.h
|
| diff --git a/third_party/mojo/src/mojo/edk/system/incoming_endpoint.h b/third_party/mojo/src/mojo/edk/system/incoming_endpoint.h
|
| index 4db7d5a4bd575b89b12e88294464cde9db204540..6a6f04fc91811a0d1c6afae2b4280b437ee77339 100644
|
| --- a/third_party/mojo/src/mojo/edk/system/incoming_endpoint.h
|
| +++ b/third_party/mojo/src/mojo/edk/system/incoming_endpoint.h
|
| @@ -5,6 +5,8 @@
|
| #ifndef MOJO_EDK_SYSTEM_INCOMING_ENDPOINT_H_
|
| #define MOJO_EDK_SYSTEM_INCOMING_ENDPOINT_H_
|
|
|
| +#include <stddef.h>
|
| +
|
| #include "base/macros.h"
|
| #include "base/memory/ref_counted.h"
|
| #include "base/synchronization/lock.h"
|
| @@ -12,15 +14,18 @@
|
| #include "mojo/edk/system/message_in_transit_queue.h"
|
| #include "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.
|
| +// |MessagePipe|s or |DataPipe|s.
|
| class MOJO_SYSTEM_IMPL_EXPORT IncomingEndpoint : public ChannelEndpointClient {
|
| public:
|
| IncomingEndpoint();
|
| @@ -29,6 +34,11 @@ class MOJO_SYSTEM_IMPL_EXPORT IncomingEndpoint : public ChannelEndpointClient {
|
| scoped_refptr<ChannelEndpoint> Init();
|
|
|
| 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).
|
|
|