OpenGrok
Home
Sort by relevance
Sort by last modified time
Full Search
Definition
Symbol
File Path
History
|
|
Help
Searched
refs:MessageInTransit
(Results
1 - 23
of
23
) sorted by null
/external/chromium_org/mojo/system/
channel.h
55
static const
MessageInTransit
::EndpointId kBootstrapEndpointId = 1;
86
MessageInTransit
::EndpointId AttachEndpoint(
94
bool RunMessagePipeEndpoint(
MessageInTransit
::EndpointId local_id,
95
MessageInTransit
::EndpointId remote_id);
103
void RunRemoteMessagePipeEndpoint(
MessageInTransit
::EndpointId local_id,
104
MessageInTransit
::EndpointId remote_id);
107
bool WriteMessage(scoped_ptr<
MessageInTransit
> message);
118
void DetachMessagePipeEndpoint(
MessageInTransit
::EndpointId local_id,
119
MessageInTransit
::EndpointId remote_id);
134
const
MessageInTransit
::View& message_view
[
all
...]
channel_endpoint.cc
19
local_id_(
MessageInTransit
::kInvalidEndpointId),
20
remote_id_(
MessageInTransit
::kInvalidEndpointId) {
30
bool ChannelEndpoint::EnqueueMessage(scoped_ptr<
MessageInTransit
> message) {
35
if (!channel_ || remote_id_ ==
MessageInTransit
::kInvalidEndpointId) {
46
DCHECK_NE(remote_id_,
MessageInTransit
::kInvalidEndpointId);
60
DCHECK_NE(local_id_,
MessageInTransit
::kInvalidEndpointId);
71
MessageInTransit
::EndpointId local_id) {
73
DCHECK_NE(local_id,
MessageInTransit
::kInvalidEndpointId);
77
DCHECK_EQ(local_id_,
MessageInTransit
::kInvalidEndpointId);
82
void ChannelEndpoint::Run(
MessageInTransit
::EndpointId remote_id)
[
all
...]
message_in_transit_queue.h
18
// A simple queue for |
MessageInTransit
|s (that owns its messages).
28
void AddMessage(scoped_ptr<
MessageInTransit
> message) {
32
scoped_ptr<
MessageInTransit
> GetMessage() {
33
MessageInTransit
* rv = queue_.front();
38
MessageInTransit
* PeekMessage() { return queue_.front(); }
53
std::deque<
MessageInTransit
*> queue_;
message_in_transit.cc
17
STATIC_CONST_MEMBER_DEFINITION const
MessageInTransit
::Type
18
MessageInTransit
::kTypeMessagePipeEndpoint;
19
STATIC_CONST_MEMBER_DEFINITION const
MessageInTransit
::Type
20
MessageInTransit
::kTypeMessagePipe;
21
STATIC_CONST_MEMBER_DEFINITION const
MessageInTransit
::Type
22
MessageInTransit
::kTypeChannel;
23
STATIC_CONST_MEMBER_DEFINITION const
MessageInTransit
::Type
24
MessageInTransit
::kTypeRawChannel;
25
STATIC_CONST_MEMBER_DEFINITION const
MessageInTransit
::Subtype
26
MessageInTransit
::kSubtypeMessagePipeEndpointData
[
all
...]
channel_endpoint.h
126
bool EnqueueMessage(scoped_ptr<
MessageInTransit
> message);
133
void AttachToChannel(Channel* channel,
MessageInTransit
::EndpointId local_id);
136
void Run(
MessageInTransit
::EndpointId remote_id);
161
bool WriteMessageNoLock(scoped_ptr<
MessageInTransit
> message);
176
MessageInTransit
::EndpointId local_id_;
177
MessageInTransit
::EndpointId remote_id_;
channel.cc
22
MessageInTransit
::kInvalidEndpointId,
25
STATIC_CONST_MEMBER_DEFINITION const
MessageInTransit
::EndpointId
99
MessageInTransit
::EndpointId Channel::AttachEndpoint(
103
MessageInTransit
::EndpointId local_id;
110
while (next_local_id_ ==
MessageInTransit
::kInvalidEndpointId ||
124
bool Channel::RunMessagePipeEndpoint(
MessageInTransit
::EndpointId local_id,
125
MessageInTransit
::EndpointId remote_id) {
157
MessageInTransit
::EndpointId local_id,
158
MessageInTransit
::EndpointId remote_id) {
168
MessageInTransit
::kSubtypeChannelRunMessagePipeEndpoint
[
all
...]
proxy_message_pipe_endpoint.h
39
virtual void EnqueueMessage(scoped_ptr<
MessageInTransit
> message) OVERRIDE;
message_pipe.h
96
scoped_ptr<
MessageInTransit
> message);
113
scoped_ptr<
MessageInTransit
> message,
119
MessageInTransit
* message,
125
scoped_ptr<
MessageInTransit
> message);
proxy_message_pipe_endpoint.cc
38
scoped_ptr<
MessageInTransit
> message) {
raw_channel.h
68
const
MessageInTransit
::View& message_view,
102
bool WriteMessage(scoped_ptr<
MessageInTransit
> message);
110
// Returns the amount of space needed in the |
MessageInTransit
|'s
175
// |
MessageInTransit
| should be popped (and destroyed); this is done in
186
std::deque<
MessageInTransit
*> message_queue_;
225
virtual void EnqueueMessageNoLock(scoped_ptr<
MessageInTransit
> message);
234
const
MessageInTransit
::View& message_view);
transport_data.cc
25
static_assert(kMaxSizePerPlatformHandle %
MessageInTransit
::kMessageAlignment ==
50
static_assert(sizeof(Header) %
MessageInTransit
::kMessageAlignment == 0,
51
"sizeof(
MessageInTransit
::Header) not a multiple of alignment");
53
MessageInTransit
::kMessageAlignment ==
57
MessageInTransit
::kMessageAlignment ==
59
"sizeof(
MessageInTransit
::HandleTableEntry) not a multiple of "
92
estimated_size +=
MessageInTransit
::RoundUpMessageAlignment(max_size);
111
estimated_size =
MessageInTransit
::RoundUpMessageAlignment(estimated_size);
116
base::AlignedAlloc(estimated_size,
MessageInTransit
::kMessageAlignment)));
174
current_offset +=
MessageInTransit
::RoundUpMessageAlignment(actual_size)
[
all
...]
message_in_transit.h
28
// |
MessageInTransit
| buffers:
30
// A |
MessageInTransit
| can be serialized by writing the main buffer and then,
43
class MOJO_SYSTEM_IMPL_EXPORT
MessageInTransit
{
84
// be as provided by |
MessageInTransit
::GetNextMessageSize()|.) The buffer
100
// API parallel to that for |
MessageInTransit
| itself (mostly getters for
136
MessageInTransit
(Type type,
141
MessageInTransit
(Type type,
145
// Constructs a |
MessageInTransit
| from a |View|.
146
explicit
MessageInTransit
(const View& message_view);
148
~
MessageInTransit
();
[
all
...]
message_pipe.cc
98
make_scoped_ptr(new
MessageInTransit
(
99
MessageInTransit
::kTypeMessagePipeEndpoint,
100
MessageInTransit
::kSubtypeMessagePipeEndpointData,
183
scoped_ptr<
MessageInTransit
> message) {
215
scoped_ptr<
MessageInTransit
> message,
220
if (message->type() ==
MessageInTransit
::kTypeMessagePipe) {
225
DCHECK_EQ(message->type(),
MessageInTransit
::kTypeMessagePipeEndpoint);
247
MessageInTransit
* message,
291
scoped_ptr<
MessageInTransit
> message) {
local_message_pipe_endpoint.h
28
virtual void EnqueueMessage(scoped_ptr<
MessageInTransit
> message) OVERRIDE;
message_pipe_endpoint.h
50
virtual void EnqueueMessage(scoped_ptr<
MessageInTransit
> message) = 0;
message_pipe_dispatcher.cc
26
MessageInTransit
::EndpointId endpoint_id;
111
MessageInTransit
::EndpointId remote_id =
113
if (remote_id ==
MessageInTransit
::kInvalidEndpointId) {
121
MessageInTransit
::EndpointId local_id =
123
if (local_id ==
MessageInTransit
::kInvalidEndpointId) {
253
MessageInTransit
::EndpointId endpoint_id =
raw_channel_posix.cc
46
scoped_ptr<
MessageInTransit
> message) OVERRIDE;
49
const
MessageInTransit
::View& message_view) OVERRIDE;
124
scoped_ptr<
MessageInTransit
> message) {
137
scoped_ptr<
MessageInTransit
> fd_message(new
MessageInTransit
(
138
MessageInTransit
::kTypeRawChannel,
139
MessageInTransit
::kSubtypeRawChannelPosixExtraPlatformHandles,
162
const
MessageInTransit
::View& message_view) {
163
DCHECK_EQ(message_view.type(),
MessageInTransit
::kTypeRawChannel);
166
MessageInTransit
::kSubtypeRawChannelPosixExtraPlatformHandles)
[
all
...]
raw_channel_unittest.cc
37
scoped_ptr<
MessageInTransit
> MakeTestMessage(uint32_t num_bytes) {
42
new
MessageInTransit
(
MessageInTransit
::kTypeMessagePipeEndpoint,
43
MessageInTransit
::kSubtypeMessagePipeEndpointData,
63
scoped_ptr<
MessageInTransit
> message(MakeTestMessage(num_bytes));
111
const
MessageInTransit
::View& /*message_view*/,
146
if (
MessageInTransit
::GetNextMessageSize(
153
MessageInTransit
::View message_view(message_size, &bytes_[0]);
227
const
MessageInTransit
::View& message_view,
345
const
MessageInTransit
::View& message_view
[
all
...]
raw_channel.cc
100
MessageInTransit
* message = message_queue_.front();
228
bool RawChannel::WriteMessage(scoped_ptr<
MessageInTransit
> message) {
313
while (remaining_bytes > 0 &&
MessageInTransit
::GetNextMessageSize(
318
MessageInTransit
::View message_view(
332
if (message_view.type() ==
MessageInTransit
::kTypeRawChannel) {
444
void RawChannel::EnqueueMessageNoLock(scoped_ptr<
MessageInTransit
> message) {
450
const
MessageInTransit
::View& message_view) {
494
MessageInTransit
* message = write_buffer_->message_queue_.front();
local_message_pipe_endpoint.cc
44
scoped_ptr<
MessageInTransit
> message) {
85
MessageInTransit
* message = message_queue_.PeekMessage();
channel_unittest.cc
201
MessageInTransit
::EndpointId local_id =
241
MessageInTransit
::EndpointId local_id =
294
MessageInTransit
::EndpointId local_id =
remote_message_pipe_unittest.cc
139
MessageInTransit
::EndpointId local_id0 = channels_[0]->AttachEndpoint(ep0);
140
MessageInTransit
::EndpointId local_id1 = channels_[1]->AttachEndpoint(ep1);
152
MessageInTransit
::EndpointId endpoint_id =
154
if (endpoint_id ==
MessageInTransit
::kInvalidEndpointId)
[
all
...]
/external/chromium_org/mojo/embedder/
embedder.cc
61
system::
MessageInTransit
::EndpointId endpoint_id =
63
if (endpoint_id == system::
MessageInTransit
::kInvalidEndpointId) {
Completed in 268 milliseconds