MessageInTransit 40 mojo/embedder/embedder.cc system::MessageInTransit::EndpointId endpoint_id = MessageInTransit 18 mojo/system/channel.cc MessageInTransit::kInvalidEndpointId, MessageInTransit 21 mojo/system/channel.cc STATIC_CONST_MEMBER_DEFINITION const MessageInTransit::EndpointId MessageInTransit 69 mojo/system/channel.cc MessageInTransit::EndpointId Channel::AttachMessagePipeEndpoint( MessageInTransit 75 mojo/system/channel.cc MessageInTransit::EndpointId local_id; MessageInTransit 79 mojo/system/channel.cc while (next_local_id_ == MessageInTransit::kInvalidEndpointId || MessageInTransit 97 mojo/system/channel.cc void Channel::RunMessagePipeEndpoint(MessageInTransit::EndpointId local_id, MessageInTransit 98 mojo/system/channel.cc MessageInTransit::EndpointId remote_id) { MessageInTransit 117 mojo/system/channel.cc MessageInTransit::EndpointId local_id, MessageInTransit 118 mojo/system/channel.cc MessageInTransit::EndpointId remote_id) { MessageInTransit 124 mojo/system/channel.cc scoped_ptr<MessageInTransit> message(new MessageInTransit( MessageInTransit 125 mojo/system/channel.cc MessageInTransit::kTypeChannel, MessageInTransit 126 mojo/system/channel.cc MessageInTransit::kSubtypeChannelRunMessagePipeEndpoint, MessageInTransit 137 mojo/system/channel.cc bool Channel::WriteMessage(scoped_ptr<MessageInTransit> message) { MessageInTransit 155 mojo/system/channel.cc void Channel::DetachMessagePipeEndpoint(MessageInTransit::EndpointId local_id) { MessageInTransit 156 mojo/system/channel.cc DCHECK_NE(local_id, MessageInTransit::kInvalidEndpointId); MessageInTransit 171 mojo/system/channel.cc void Channel::OnReadMessage(const MessageInTransit::View& message_view) { MessageInTransit 177 mojo/system/channel.cc case MessageInTransit::kTypeMessagePipeEndpoint: MessageInTransit 178 mojo/system/channel.cc case MessageInTransit::kTypeMessagePipe: MessageInTransit 181 mojo/system/channel.cc case MessageInTransit::kTypeChannel: MessageInTransit 197 mojo/system/channel.cc bool Channel::ValidateReadMessage(const MessageInTransit::View& message_view) { MessageInTransit 209 mojo/system/channel.cc const MessageInTransit::View& message_view) { MessageInTransit 210 mojo/system/channel.cc DCHECK(message_view.type() == MessageInTransit::kTypeMessagePipeEndpoint || MessageInTransit 211 mojo/system/channel.cc message_view.type() == MessageInTransit::kTypeMessagePipe); MessageInTransit 213 mojo/system/channel.cc MessageInTransit::EndpointId local_id = message_view.destination_id(); MessageInTransit 214 mojo/system/channel.cc if (local_id == MessageInTransit::kInvalidEndpointId) { MessageInTransit 247 mojo/system/channel.cc scoped_ptr<MessageInTransit> message(new MessageInTransit(message_view)); MessageInTransit 260 mojo/system/channel.cc const MessageInTransit::View& message_view) { MessageInTransit 261 mojo/system/channel.cc DCHECK_EQ(message_view.type(), MessageInTransit::kTypeChannel); MessageInTransit 264 mojo/system/channel.cc case MessageInTransit::kSubtypeChannelRunMessagePipeEndpoint: MessageInTransit 56 mojo/system/channel.h static const MessageInTransit::EndpointId kBootstrapEndpointId = 1; MessageInTransit 76 mojo/system/channel.h MessageInTransit::EndpointId AttachMessagePipeEndpoint( MessageInTransit 78 mojo/system/channel.h void RunMessagePipeEndpoint(MessageInTransit::EndpointId local_id, MessageInTransit 79 mojo/system/channel.h MessageInTransit::EndpointId remote_id); MessageInTransit 87 mojo/system/channel.h void RunRemoteMessagePipeEndpoint(MessageInTransit::EndpointId local_id, MessageInTransit 88 mojo/system/channel.h MessageInTransit::EndpointId remote_id); MessageInTransit 91 mojo/system/channel.h bool WriteMessage(scoped_ptr<MessageInTransit> message); MessageInTransit 101 mojo/system/channel.h void DetachMessagePipeEndpoint(MessageInTransit::EndpointId local_id); MessageInTransit 109 mojo/system/channel.h const MessageInTransit::View& message_view) OVERRIDE; MessageInTransit 113 mojo/system/channel.h bool ValidateReadMessage(const MessageInTransit::View& message_view); MessageInTransit 114 mojo/system/channel.h void OnReadMessageForDownstream(const MessageInTransit::View& message_view); MessageInTransit 115 mojo/system/channel.h void OnReadMessageForChannel(const MessageInTransit::View& message_view); MessageInTransit 142 mojo/system/channel.h typedef base::hash_map<MessageInTransit::EndpointId, EndpointInfo> MessageInTransit 147 mojo/system/channel.h MessageInTransit::EndpointId next_local_id_; MessageInTransit 29 mojo/system/dispatcher.h class MessageInTransit; MessageInTransit 156 mojo/system/dispatcher.h friend class MessageInTransit; MessageInTransit 54 mojo/system/local_message_pipe_endpoint.cc scoped_ptr<MessageInTransit> message) { MessageInTransit 90 mojo/system/local_message_pipe_endpoint.cc MessageInTransit* message = message_queue_.PeekMessage(); MessageInTransit 29 mojo/system/local_message_pipe_endpoint.h virtual void EnqueueMessage(scoped_ptr<MessageInTransit> message) OVERRIDE; MessageInTransit 24 mojo/system/message_in_transit.cc struct MessageInTransit::PrivateStructForCompileAsserts { MessageInTransit 48 mojo/system/message_in_transit.cc STATIC_CONST_MEMBER_DEFINITION const MessageInTransit::Type MessageInTransit 49 mojo/system/message_in_transit.cc MessageInTransit::kTypeMessagePipeEndpoint; MessageInTransit 50 mojo/system/message_in_transit.cc STATIC_CONST_MEMBER_DEFINITION const MessageInTransit::Type MessageInTransit 51 mojo/system/message_in_transit.cc MessageInTransit::kTypeMessagePipe; MessageInTransit 52 mojo/system/message_in_transit.cc STATIC_CONST_MEMBER_DEFINITION const MessageInTransit::Type MessageInTransit 53 mojo/system/message_in_transit.cc MessageInTransit::kTypeChannel; MessageInTransit 54 mojo/system/message_in_transit.cc STATIC_CONST_MEMBER_DEFINITION const MessageInTransit::Subtype MessageInTransit 55 mojo/system/message_in_transit.cc MessageInTransit::kSubtypeMessagePipeEndpointData; MessageInTransit 56 mojo/system/message_in_transit.cc STATIC_CONST_MEMBER_DEFINITION const MessageInTransit::Subtype MessageInTransit 57 mojo/system/message_in_transit.cc MessageInTransit::kSubtypeMessagePipePeerClosed; MessageInTransit 58 mojo/system/message_in_transit.cc STATIC_CONST_MEMBER_DEFINITION const MessageInTransit::EndpointId MessageInTransit 59 mojo/system/message_in_transit.cc MessageInTransit::kInvalidEndpointId; MessageInTransit 60 mojo/system/message_in_transit.cc STATIC_CONST_MEMBER_DEFINITION const size_t MessageInTransit::kMessageAlignment; MessageInTransit 62 mojo/system/message_in_transit.cc MessageInTransit::kMaxSerializedDispatcherSize; MessageInTransit 65 mojo/system/message_in_transit.cc const size_t MessageInTransit::kMaxSecondaryBufferSize = kMaxMessageNumHandles * MessageInTransit 68 mojo/system/message_in_transit.cc MessageInTransit::View::View(size_t message_size, const void* buffer) MessageInTransit 71 mojo/system/message_in_transit.cc DCHECK(MessageInTransit::GetNextMessageSize(buffer_, message_size, MessageInTransit 78 mojo/system/message_in_transit.cc bool MessageInTransit::View::IsValid(const char** error_message) const { MessageInTransit 96 mojo/system/message_in_transit.cc MessageInTransit::MessageInTransit(Type type, MessageInTransit 120 mojo/system/message_in_transit.cc memcpy(MessageInTransit::bytes(), bytes, num_bytes); MessageInTransit 121 mojo/system/message_in_transit.cc memset(static_cast<char*>(MessageInTransit::bytes()) + num_bytes, 0, MessageInTransit 124 mojo/system/message_in_transit.cc memset(MessageInTransit::bytes(), 0, main_buffer_size_ - sizeof(Header)); MessageInTransit 130 mojo/system/message_in_transit.cc MessageInTransit::MessageInTransit(const View& message_view) MessageInTransit 148 mojo/system/message_in_transit.cc MessageInTransit::~MessageInTransit() { MessageInTransit 178 mojo/system/message_in_transit.cc bool MessageInTransit::GetNextMessageSize(const void* buffer, MessageInTransit 186 mojo/system/message_in_transit.cc MessageInTransit::kMessageAlignment, 0u); MessageInTransit 197 mojo/system/message_in_transit.cc void MessageInTransit::SetDispatchers( MessageInTransit 209 mojo/system/message_in_transit.cc void MessageInTransit::SerializeAndCloseDispatchers(Channel* channel) { MessageInTransit 272 mojo/system/message_in_transit.cc void MessageInTransit::DeserializeDispatchers(Channel* channel) { MessageInTransit 313 mojo/system/message_in_transit.cc const char* MessageInTransit::ValidateSecondaryBuffer( MessageInTransit 354 mojo/system/message_in_transit.cc void MessageInTransit::UpdateTotalSize() { MessageInTransit 43 mojo/system/message_in_transit.h class MOJO_SYSTEM_IMPL_EXPORT MessageInTransit { MessageInTransit 134 mojo/system/message_in_transit.h MessageInTransit(Type type, MessageInTransit 140 mojo/system/message_in_transit.h explicit MessageInTransit(const View& message_view); MessageInTransit 142 mojo/system/message_in_transit.h ~MessageInTransit(); MessageInTransit 300 mojo/system/message_in_transit.h DISALLOW_COPY_AND_ASSIGN(MessageInTransit); MessageInTransit 36 mojo/system/message_in_transit_queue.h void AddMessage(scoped_ptr<MessageInTransit> message) { MessageInTransit 40 mojo/system/message_in_transit_queue.h scoped_ptr<MessageInTransit> GetMessage() { MessageInTransit 41 mojo/system/message_in_transit_queue.h MessageInTransit* rv = queue_.front(); MessageInTransit 46 mojo/system/message_in_transit_queue.h MessageInTransit* PeekMessage() { MessageInTransit 60 mojo/system/message_in_transit_queue.h std::deque<MessageInTransit*> queue_; MessageInTransit 77 mojo/system/message_pipe.cc make_scoped_ptr(new MessageInTransit( MessageInTransit 78 mojo/system/message_pipe.cc MessageInTransit::kTypeMessagePipeEndpoint, MessageInTransit 79 mojo/system/message_pipe.cc MessageInTransit::kSubtypeMessagePipeEndpointData, MessageInTransit 146 mojo/system/message_pipe.cc scoped_ptr<MessageInTransit> message, MessageInTransit 165 mojo/system/message_pipe.cc if (message->type() == MessageInTransit::kTypeMessagePipe) { MessageInTransit 170 mojo/system/message_pipe.cc DCHECK_EQ(message->type(), MessageInTransit::kTypeMessagePipeEndpoint); MessageInTransit 228 mojo/system/message_pipe.cc MessageInTransit::EndpointId local_id) { MessageInTransit 231 mojo/system/message_pipe.cc DCHECK_NE(local_id, MessageInTransit::kInvalidEndpointId); MessageInTransit 239 mojo/system/message_pipe.cc void MessagePipe::Run(unsigned port, MessageInTransit::EndpointId remote_id) { MessageInTransit 241 mojo/system/message_pipe.cc DCHECK_NE(remote_id, MessageInTransit::kInvalidEndpointId); MessageInTransit 258 mojo/system/message_pipe.cc scoped_ptr<MessageInTransit> message) { MessageInTransit 261 mojo/system/message_pipe.cc DCHECK_EQ(message->type(), MessageInTransit::kTypeMessagePipe); MessageInTransit 264 mojo/system/message_pipe.cc case MessageInTransit::kSubtypeMessagePipePeerClosed: { MessageInTransit 81 mojo/system/message_pipe.h scoped_ptr<MessageInTransit> message, MessageInTransit 87 mojo/system/message_pipe.h MessageInTransit::EndpointId local_id); MessageInTransit 88 mojo/system/message_pipe.h void Run(unsigned port, MessageInTransit::EndpointId remote_id); MessageInTransit 97 mojo/system/message_pipe.h scoped_ptr<MessageInTransit> message); MessageInTransit 24 mojo/system/message_pipe_dispatcher.cc MessageInTransit::EndpointId endpoint_id; MessageInTransit 74 mojo/system/message_pipe_dispatcher.cc MessageInTransit::EndpointId remote_id = MessageInTransit 76 mojo/system/message_pipe_dispatcher.cc MessageInTransit::EndpointId local_id = MessageInTransit 190 mojo/system/message_pipe_dispatcher.cc MessageInTransit::EndpointId endpoint_id = MessageInTransit 192 mojo/system/message_pipe_dispatcher.cc DCHECK_NE(endpoint_id, MessageInTransit::kInvalidEndpointId); MessageInTransit 38 mojo/system/message_pipe_endpoint.cc MessageInTransit::EndpointId /*local_id*/) { MessageInTransit 42 mojo/system/message_pipe_endpoint.cc void MessagePipeEndpoint::Run(MessageInTransit::EndpointId /*remote_id*/) { MessageInTransit 51 mojo/system/message_pipe_endpoint.h virtual void EnqueueMessage(scoped_ptr<MessageInTransit> message) = 0; MessageInTransit 76 mojo/system/message_pipe_endpoint.h MessageInTransit::EndpointId local_id); MessageInTransit 77 mojo/system/message_pipe_endpoint.h virtual void Run(MessageInTransit::EndpointId remote_id); MessageInTransit 18 mojo/system/proxy_message_pipe_endpoint.cc : local_id_(MessageInTransit::kInvalidEndpointId), MessageInTransit 19 mojo/system/proxy_message_pipe_endpoint.cc remote_id_(MessageInTransit::kInvalidEndpointId), MessageInTransit 27 mojo/system/proxy_message_pipe_endpoint.cc : local_id_(MessageInTransit::kInvalidEndpointId), MessageInTransit 28 mojo/system/proxy_message_pipe_endpoint.cc remote_id_(MessageInTransit::kInvalidEndpointId), MessageInTransit 54 mojo/system/proxy_message_pipe_endpoint.cc local_id_ = MessageInTransit::kInvalidEndpointId; MessageInTransit 55 mojo/system/proxy_message_pipe_endpoint.cc remote_id_ = MessageInTransit::kInvalidEndpointId; MessageInTransit 65 mojo/system/proxy_message_pipe_endpoint.cc new MessageInTransit(MessageInTransit::kTypeMessagePipe, MessageInTransit 66 mojo/system/proxy_message_pipe_endpoint.cc MessageInTransit::kSubtypeMessagePipePeerClosed, MessageInTransit 74 mojo/system/proxy_message_pipe_endpoint.cc scoped_ptr<MessageInTransit> message) { MessageInTransit 90 mojo/system/proxy_message_pipe_endpoint.cc MessageInTransit::EndpointId local_id) { MessageInTransit 92 mojo/system/proxy_message_pipe_endpoint.cc DCHECK_NE(local_id, MessageInTransit::kInvalidEndpointId); MessageInTransit 102 mojo/system/proxy_message_pipe_endpoint.cc void ProxyMessagePipeEndpoint::Run(MessageInTransit::EndpointId remote_id) { MessageInTransit 104 mojo/system/proxy_message_pipe_endpoint.cc DCHECK_NE(remote_id, MessageInTransit::kInvalidEndpointId); MessageInTransit 121 mojo/system/proxy_message_pipe_endpoint.cc DCHECK_NE(local_id_, MessageInTransit::kInvalidEndpointId); MessageInTransit 123 mojo/system/proxy_message_pipe_endpoint.cc DCHECK_EQ(local_id_, MessageInTransit::kInvalidEndpointId); MessageInTransit 124 mojo/system/proxy_message_pipe_endpoint.cc DCHECK_EQ(remote_id_, MessageInTransit::kInvalidEndpointId); MessageInTransit 58 mojo/system/proxy_message_pipe_endpoint.h virtual void EnqueueMessage(scoped_ptr<MessageInTransit> message) OVERRIDE; MessageInTransit 60 mojo/system/proxy_message_pipe_endpoint.h MessageInTransit::EndpointId local_id) OVERRIDE; MessageInTransit 61 mojo/system/proxy_message_pipe_endpoint.h virtual void Run(MessageInTransit::EndpointId remote_id) OVERRIDE; MessageInTransit 69 mojo/system/proxy_message_pipe_endpoint.h return remote_id_ != MessageInTransit::kInvalidEndpointId; MessageInTransit 83 mojo/system/proxy_message_pipe_endpoint.h MessageInTransit::EndpointId local_id_; MessageInTransit 89 mojo/system/proxy_message_pipe_endpoint.h MessageInTransit::EndpointId remote_id_; MessageInTransit 47 mojo/system/raw_channel.cc MessageInTransit* message = message_queue_.front(); MessageInTransit 89 mojo/system/raw_channel.cc MessageInTransit* message = message_queue_.front(); MessageInTransit 152 mojo/system/raw_channel.cc bool RawChannel::WriteMessage(scoped_ptr<MessageInTransit> message) { MessageInTransit 248 mojo/system/raw_channel.cc MessageInTransit::GetNextMessageSize( MessageInTransit 252 mojo/system/raw_channel.cc MessageInTransit::View MessageInTransit 58 mojo/system/raw_channel.h virtual void OnReadMessage(const MessageInTransit::View& message_view) = 0; MessageInTransit 89 mojo/system/raw_channel.h bool WriteMessage(scoped_ptr<MessageInTransit> message); MessageInTransit 144 mojo/system/raw_channel.h std::deque<MessageInTransit*> message_queue_; MessageInTransit 36 mojo/system/raw_channel_unittest.cc scoped_ptr<MessageInTransit> MakeTestMessage(uint32_t num_bytes) { MessageInTransit 41 mojo/system/raw_channel_unittest.cc new MessageInTransit(MessageInTransit::kTypeMessagePipeEndpoint, MessageInTransit 42 mojo/system/raw_channel_unittest.cc MessageInTransit::kSubtypeMessagePipeEndpointData, MessageInTransit 61 mojo/system/raw_channel_unittest.cc scoped_ptr<MessageInTransit> message(MakeTestMessage(num_bytes)); MessageInTransit 109 mojo/system/raw_channel_unittest.cc const MessageInTransit::View& /*message_view*/) OVERRIDE { MessageInTransit 143 mojo/system/raw_channel_unittest.cc if (MessageInTransit::GetNextMessageSize( MessageInTransit 150 mojo/system/raw_channel_unittest.cc MessageInTransit::View message_view(message_size, &bytes_[0]); MessageInTransit 228 mojo/system/raw_channel_unittest.cc const MessageInTransit::View& message_view) OVERRIDE { MessageInTransit 350 mojo/system/raw_channel_unittest.cc const MessageInTransit::View& message_view) OVERRIDE { MessageInTransit 125 mojo/system/remote_message_pipe_unittest.cc MessageInTransit::EndpointId local_id0 = MessageInTransit 127 mojo/system/remote_message_pipe_unittest.cc MessageInTransit::EndpointId local_id1 =