1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
|
// 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.
#ifndef THIRD_PARTY_MOJO_SRC_MOJO_EDK_SYSTEM_REMOTE_CONSUMER_DATA_PIPE_IMPL_H_
#define THIRD_PARTY_MOJO_SRC_MOJO_EDK_SYSTEM_REMOTE_CONSUMER_DATA_PIPE_IMPL_H_
#include "base/memory/aligned_memory.h"
#include "base/memory/ref_counted.h"
#include "base/memory/scoped_ptr.h"
#include "mojo/public/cpp/system/macros.h"
#include "third_party/mojo/src/mojo/edk/system/channel_endpoint.h"
#include "third_party/mojo/src/mojo/edk/system/data_pipe_impl.h"
#include "third_party/mojo/src/mojo/edk/system/system_impl_export.h"
namespace mojo {
namespace system {
// |RemoteConsumerDataPipeImpl| is a subclass that "implements" |DataPipe| for
// data pipes whose producer is local and whose consumer is remote. See
// |DataPipeImpl| for more details.
class MOJO_SYSTEM_IMPL_EXPORT RemoteConsumerDataPipeImpl final
: public DataPipeImpl {
public:
// |buffer| is only required if |producer_two_phase_max_num_bytes_written()|
// is nonzero (i.e., if we're in the middle of a two-phase write when the
// consumer handle is transferred); |start_index| is ignored if it is zero.
RemoteConsumerDataPipeImpl(ChannelEndpoint* channel_endpoint,
size_t consumer_num_bytes,
scoped_ptr<char, base::AlignedFreeDeleter> buffer,
size_t start_index);
~RemoteConsumerDataPipeImpl() override;
// Processes messages that were received and queued by an |IncomingEndpoint|.
// |*consumer_num_bytes| should be set to the value from the
// |SerializedDataPipeProducerDispatcher|. On success, returns true and
// updates |*consumer_num_bytes|. On failure, returns false (it may or may not
// modify |*consumer_num_bytes|). Always clears |*messages|.
static bool ProcessMessagesFromIncomingEndpoint(
const MojoCreateDataPipeOptions& validated_options,
size_t* consumer_num_bytes,
MessageInTransitQueue* messages);
private:
// |DataPipeImpl| implementation:
// Note: None of the |Consumer...()| methods should be called, except
// |ConsumerGetHandleSignalsState()|.
void ProducerClose() override;
MojoResult ProducerWriteData(UserPointer<const void> elements,
UserPointer<uint32_t> num_bytes,
uint32_t max_num_bytes_to_write,
uint32_t min_num_bytes_to_write) override;
MojoResult ProducerBeginWriteData(
UserPointer<void*> buffer,
UserPointer<uint32_t> buffer_num_bytes) override;
MojoResult ProducerEndWriteData(uint32_t num_bytes_written) override;
HandleSignalsState ProducerGetHandleSignalsState() const override;
void ProducerStartSerialize(Channel* channel,
size_t* max_size,
size_t* max_platform_handles) override;
bool ProducerEndSerialize(
Channel* channel,
void* destination,
size_t* actual_size,
embedder::PlatformHandleVector* platform_handles) override;
void ConsumerClose() override;
MojoResult ConsumerReadData(UserPointer<void> elements,
UserPointer<uint32_t> num_bytes,
uint32_t max_num_bytes_to_read,
uint32_t min_num_bytes_to_read,
bool peek) override;
MojoResult ConsumerDiscardData(UserPointer<uint32_t> num_bytes,
uint32_t max_num_bytes_to_discard,
uint32_t min_num_bytes_to_discard) override;
MojoResult ConsumerQueryData(UserPointer<uint32_t> num_bytes) override;
MojoResult ConsumerBeginReadData(
UserPointer<const void*> buffer,
UserPointer<uint32_t> buffer_num_bytes) override;
MojoResult ConsumerEndReadData(uint32_t num_bytes_read) override;
HandleSignalsState ConsumerGetHandleSignalsState() const override;
void ConsumerStartSerialize(Channel* channel,
size_t* max_size,
size_t* max_platform_handles) override;
bool ConsumerEndSerialize(
Channel* channel,
void* destination,
size_t* actual_size,
embedder::PlatformHandleVector* platform_handles) override;
bool OnReadMessage(unsigned port, MessageInTransit* message) override;
void OnDetachFromChannel(unsigned port) override;
void EnsureBuffer();
void DestroyBuffer();
void Disconnect();
// Should be valid if and only if |consumer_open()| returns true.
scoped_refptr<ChannelEndpoint> channel_endpoint_;
// The number of bytes we've sent the consumer, but don't *know* have been
// consumed.
size_t consumer_num_bytes_;
// Used for two-phase writes.
scoped_ptr<char, base::AlignedFreeDeleter> buffer_;
// This is nearly always zero, except when the two-phase write started on a
// |LocalDataPipeImpl|.
size_t start_index_;
MOJO_DISALLOW_COPY_AND_ASSIGN(RemoteConsumerDataPipeImpl);
};
} // namespace system
} // namespace mojo
#endif // THIRD_PARTY_MOJO_SRC_MOJO_EDK_SYSTEM_REMOTE_CONSUMER_DATA_PIPE_IMPL_H_
|
