Home
last modified time | relevance | path

Searched refs:MessagePtr (Results 1 – 13 of 13) sorted by relevance

/external/libmojo/mojo/edk/system/
Dnode_channel.h59 Channel::MessagePtr message) = 0;
69 Channel::MessagePtr message) = 0;
74 Channel::MessagePtr message) = 0;
77 Channel::MessagePtr message) = 0;
94 static Channel::MessagePtr CreatePortsMessage(size_t payload_size,
133 void PortsMessage(Channel::MessagePtr message);
139 void Broadcast(Channel::MessagePtr message);
147 Channel::MessagePtr message);
153 Channel::MessagePtr message);
159 using PendingMessageQueue = std::queue<Channel::MessagePtr>;
[all …]
Dnode_channel.cc126 Channel::MessagePtr CreateMessage(MessageType type, in CreateMessage()
130 Channel::MessagePtr message( in CreateMessage()
169 Channel::MessagePtr NodeChannel::CreatePortsMessage(size_t payload_size, in CreatePortsMessage()
268 Channel::MessagePtr message = CreateMessage( in AcceptChild()
278 Channel::MessagePtr message = CreateMessage( in AcceptParent()
292 Channel::MessagePtr message = CreateMessage( in AddBrokerClient()
310 Channel::MessagePtr message = CreateMessage( in BrokerClientAdded()
324 Channel::MessagePtr message = CreateMessage( in AcceptBrokerClient()
332 void NodeChannel::PortsMessage(Channel::MessagePtr message) { in PortsMessage()
339 Channel::MessagePtr message = CreateMessage( in RequestPortMerge()
[all …]
Dbroker_messages.h36 inline Channel::MessagePtr CreateBrokerMessage(BrokerMessageType type, in CreateBrokerMessage()
40 Channel::MessagePtr message(new Channel::Message(message_size, num_handles)); in CreateBrokerMessage()
49 inline Channel::MessagePtr CreateBrokerMessage( in CreateBrokerMessage()
53 Channel::MessagePtr message( in CreateBrokerMessage()
Dports_message.h40 Channel::MessagePtr TakeChannelMessage() { in TakeChannelMessage()
58 Channel::MessagePtr channel_message);
60 Channel::MessagePtr channel_message_;
Dchannel_win.cc34 MessageView(Channel::MessagePtr message, size_t offset) in MessageView()
62 Channel::MessagePtr TakeChannelMessage() { return std::move(message_); } in TakeChannelMessage()
65 Channel::MessagePtr message_;
98 void Write(MessagePtr message) override { in Write()
265 Channel::MessagePtr message = message_view.TakeChannelMessage(); in OnWriteDone()
Dnode_controller.h135 using OutgoingMessageQueue = std::queue<Channel::MessagePtr>;
189 Channel::MessagePtr message) override;
199 Channel::MessagePtr message) override;
204 Channel::MessagePtr message) override;
207 Channel::MessagePtr message) override;
Dchannel_posix.cc41 MessageView(Channel::MessagePtr message, size_t offset) in MessageView()
72 Channel::MessagePtr TakeMessage() { return std::move(message_); } in TakeMessage()
79 Channel::MessagePtr message_;
119 void Write(MessagePtr message) override { in Write()
356 MessagePtr fds_message( in WriteNoLock()
423 MessagePtr message(new Channel::Message( in OnControlMessage()
Dchannel.h28 using MessagePtr = std::unique_ptr<Message>; variable
114 static MessagePtr Deserialize(const void* data, size_t data_num_bytes);
226 virtual void Write(MessagePtr message) = 0;
Dbroker_host_posix.cc53 Channel::MessagePtr message = in SendChannel()
76 Channel::MessagePtr message = CreateBrokerMessage( in OnBufferRequest()
Dbroker_posix.cc30 Channel::MessagePtr message( in WaitForBrokerMessage()
96 Channel::MessagePtr out_message = CreateBrokerMessage( in GetSharedBuffer()
Dnode_controller.cc584 Channel::MessagePtr channel_message = in SendPeerMessage()
774 Channel::MessagePtr channel_message = in BroadcastMessage()
1017 Channel::MessagePtr channel_message) { in OnPortsMessage()
1114 Channel::MessagePtr message) { in OnBroadcast()
1135 Channel::MessagePtr peer_message( in OnBroadcast()
1147 Channel::MessagePtr message) { in OnRelayPortsMessage()
1211 Channel::MessagePtr message) { in OnPortsMessageFromRelay()
Dports_message.cc37 Channel::MessagePtr channel_message) in PortsMessage()
Dchannel.cc122 Channel::MessagePtr Channel::Message::Deserialize(const void* data, in Deserialize()
171 MessagePtr message(new Message(payload_size, max_handles)); in Deserialize()