HomeSort by relevance Sort by last modified time
    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