| /external/libmojo/mojo/edk/system/ |
| D | ports_message.cc | 15 size_t num_payload_bytes, in NewUserMessage() argument
19 new PortsMessage(num_payload_bytes, num_ports, num_handles)); in NewUserMessage()
24 PortsMessage::PortsMessage(size_t num_payload_bytes, in PortsMessage() argument
27 : ports::Message(num_payload_bytes, num_ports) { in PortsMessage()
28 size_t size = num_header_bytes_ + num_ports_bytes_ + num_payload_bytes; in PortsMessage()
35 size_t num_payload_bytes, in PortsMessage() argument
39 num_payload_bytes, in PortsMessage()
52 CHECK_EQ(num_payload_bytes, 0u); in PortsMessage()
|
| D | ports_message.h | 23 static std::unique_ptr<PortsMessage> NewUserMessage(size_t num_payload_bytes,
51 PortsMessage(size_t num_payload_bytes, size_t num_ports, size_t num_handles);
56 size_t num_payload_bytes,
|
| D | message_for_transit.h | 86 DCHECK_GE(message_->num_payload_bytes(), header_size); in num_bytes()
87 return message_->num_payload_bytes() - header_size; in num_bytes()
|
| D | message_pipe_dispatcher.cc | 196 if (message.num_payload_bytes() < sizeof(MessageHeader)) { in ReadMessage()
203 if (header->header_size > message.num_payload_bytes()) { in ReadMessage()
210 static_cast<uint32_t>(message.num_payload_bytes()) - in ReadMessage()
299 if (msg->num_payload_bytes() < next_payload_index || in ReadMessage()
536 message_size = message.num_payload_bytes(); in OnPortStatusChanged()
|
| D | node_controller.cc | 81 size_t* num_payload_bytes, in ParsePortsMessage() argument
83 DCHECK(data && num_data_bytes && num_header_bytes && num_payload_bytes && in ParsePortsMessage()
91 num_payload_bytes, num_ports_bytes)) { in ParsePortsMessage()
1021 size_t num_data_bytes, num_header_bytes, num_payload_bytes, num_ports_bytes; in OnPortsMessage() local
1023 &num_header_bytes, &num_payload_bytes, in OnPortsMessage()
1032 num_payload_bytes, in OnPortsMessage()
1118 size_t num_data_bytes, num_header_bytes, num_payload_bytes, num_ports_bytes; in OnBroadcast() local
1120 &num_header_bytes, &num_payload_bytes, in OnBroadcast()
|
| D | data_pipe_producer_dispatcher.cc | 512 if (message->num_payload_bytes() < sizeof(DataPipeControlMessage)) { in UpdateSignalsStateNoLock()
|
| D | data_pipe_consumer_dispatcher.cc | 534 if (message->num_payload_bytes() < sizeof(DataPipeControlMessage)) { in UpdateSignalsStateNoLock()
|
| /external/libmojo/mojo/edk/system/ports/ |
| D | message.cc | 20 size_t* num_payload_bytes, in Parse() argument
63 *num_payload_bytes = num_bytes - *num_header_bytes - *num_ports_bytes; in Parse()
67 *num_payload_bytes = 0; in Parse()
74 Message::Message(size_t num_payload_bytes, size_t num_ports) in Message() argument
77 num_payload_bytes, num_ports * sizeof(PortName)) { in Message()
82 size_t num_payload_bytes, in Message() argument
87 num_payload_bytes_(num_payload_bytes) { in Message()
|
| D | message.h | 35 size_t* num_payload_bytes,
48 size_t num_payload_bytes() const { return num_payload_bytes_; } in num_payload_bytes() function
64 Message(size_t num_payload_bytes, size_t num_ports);
69 size_t num_payload_bytes,
|
| D | ports_unittest.cc | 49 static ScopedMessage NewUserMessage(size_t num_payload_bytes, in NewUserMessage() argument
51 return ScopedMessage(new TestMessage(num_payload_bytes, num_ports)); in NewUserMessage()
54 TestMessage(size_t num_payload_bytes, size_t num_ports) in TestMessage() argument
55 : Message(num_payload_bytes, num_ports) { in TestMessage()
56 start_ = new char[num_header_bytes_ + num_ports_bytes_ + num_payload_bytes]; in TestMessage()
61 size_t num_payload_bytes, in TestMessage() argument
64 num_payload_bytes, in TestMessage()
66 start_ = new char[num_header_bytes + num_payload_bytes + num_ports_bytes]; in TestMessage()
|