Home
last modified time | relevance | path

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

/external/libmojo/mojo/edk/system/
Dports_message.cc14 std::unique_ptr<PortsMessage> PortsMessage::NewUserMessage( in NewUserMessage()
19 new PortsMessage(num_payload_bytes, num_ports, num_handles)); in NewUserMessage()
22 PortsMessage::~PortsMessage() {} in ~PortsMessage()
24 PortsMessage::PortsMessage(size_t num_payload_bytes, in PortsMessage() function in mojo::edk::PortsMessage
34 PortsMessage::PortsMessage(size_t num_header_bytes, in PortsMessage() function in mojo::edk::PortsMessage
Dports_message.h21 class PortsMessage : public ports::Message {
23 static std::unique_ptr<PortsMessage> NewUserMessage(size_t num_payload_bytes,
27 ~PortsMessage() override;
51 PortsMessage(size_t num_payload_bytes, size_t num_ports, size_t num_handles);
55 PortsMessage(size_t num_header_bytes,
Dmessage_for_transit.h66 std::unique_ptr<PortsMessage> message) { in WrapPortsMessage()
92 const PortsMessage& ports_message() const { return *message_; } in ports_message()
94 std::unique_ptr<PortsMessage> TakePortsMessage() { in TakePortsMessage()
99 explicit MessageForTransit(std::unique_ptr<PortsMessage> message);
107 std::unique_ptr<PortsMessage> message_;
Ddata_pipe_control_message.cc18 std::unique_ptr<PortsMessage> message = in SendDataPipeControlMessage()
19 PortsMessage::NewUserMessage(sizeof(DataPipeControlMessage), 0, 0); in SendDataPipeControlMessage()
Dmessage_for_transit.cc58 std::unique_ptr<PortsMessage> msg = PortsMessage::NewUserMessage( in Create()
131 MessageForTransit::MessageForTransit(std::unique_ptr<PortsMessage> message) in MessageForTransit()
Dnode_controller.cc272 std::unique_ptr<PortsMessage> message) { in SendMessage()
504 channel->PortsMessage(std::move(pending_messages.front())); in AddPeer()
585 static_cast<PortsMessage*>(message.get())->TakeChannelMessage(); in SendPeerMessage()
628 peer->PortsMessage(std::move(channel_message)); in SendPeerMessage()
730 message->reset(new PortsMessage(num_header_bytes, 0, 0, nullptr)); in AllocMessage()
775 static_cast<PortsMessage*>(message.get())->TakeChannelMessage(); in BroadcastMessage()
1030 std::unique_ptr<PortsMessage> ports_message( in OnPortsMessage()
1031 new PortsMessage(num_header_bytes, in OnPortsMessage()
1139 iter.second->PortsMessage(std::move(peer_message)); in OnBroadcast()
Ddata_pipe_control_message.h20 class PortsMessage; variable
Dmessage_pipe_dispatcher.cc194 const PortsMessage& message = in ReadMessage()
195 static_cast<const PortsMessage&>(next_message); in ReadMessage()
269 std::unique_ptr<PortsMessage> msg( in ReadMessage()
270 static_cast<PortsMessage*>(ports_message.release())); in ReadMessage()
Dnode_controller.h39 class PortsMessage; variable
99 std::unique_ptr<PortsMessage> message);
Dmessage_pipe_dispatcher.h24 class PortsMessage; variable
Dnode_channel.h133 void PortsMessage(Channel::MessagePtr message);
Dnode_channel.cc332 void NodeChannel::PortsMessage(Channel::MessagePtr message) { in PortsMessage() function in mojo::edk::NodeChannel
Dcore.cc753 const PortsMessage& ports_message = in NotifyBadMessage()