Searched refs:num_header_bytes (Results 1 – 10 of 10) sorted by relevance
| /external/libmojo/mojo/edk/system/ports/ |
| D | message.cc | 19 size_t* num_header_bytes, in Parse() argument
30 *num_header_bytes = sizeof(EventHeader); in Parse()
33 *num_header_bytes = sizeof(EventHeader) + sizeof(ObserveProxyEventData); in Parse()
36 *num_header_bytes = in Parse()
40 *num_header_bytes = sizeof(EventHeader) + sizeof(ObserveClosureEventData); in Parse()
43 *num_header_bytes = sizeof(EventHeader) + sizeof(MergePortEventData); in Parse()
57 *num_header_bytes = sizeof(EventHeader) + in Parse()
61 if (num_bytes < *num_header_bytes + *num_ports_bytes) in Parse()
63 *num_payload_bytes = num_bytes - *num_header_bytes - *num_ports_bytes; in Parse()
65 if (*num_header_bytes != num_bytes) in Parse()
[all …]
|
| D | message.h | 34 size_t* num_header_bytes,
40 size_t num_header_bytes() const { return num_header_bytes_; } in num_header_bytes() function
68 Message(size_t num_header_bytes,
|
| D | node_delegate.h | 28 virtual void AllocMessage(size_t num_header_bytes,
|
| D | ports_unittest.cc | 54 TestMessage(size_t num_header_bytes, in TestMessage() argument
57 : Message(num_header_bytes, in TestMessage()
60 start_ = new char[num_header_bytes + num_payload_bytes + num_ports_bytes]; in TestMessage()
204 void AllocMessage(size_t num_header_bytes, ScopedMessage* message) override { in AllocMessage() argument
205 message->reset(new TestMessage(num_header_bytes, 0, 0)); in AllocMessage()
423 new TestMessage(message->num_header_bytes(), 0, 0)); in BroadcastMessage()
425 message->num_header_bytes()); in BroadcastMessage()
|
| /external/libmojo/mojo/edk/system/ |
| D | channel.cc | 115 header()->num_header_bytes = in Message()
167 if (header->num_bytes < header->num_header_bytes || in Deserialize()
168 header->num_header_bytes < sizeof(Header)) { in Deserialize()
170 << header->num_header_bytes; in Deserialize()
173 extra_header_size = header->num_header_bytes - sizeof(Header); in Deserialize()
174 payload_size = data_num_bytes - header->num_header_bytes; in Deserialize()
175 payload = static_cast<const char*>(data) + header->num_header_bytes; in Deserialize()
214 DCHECK_EQ(message->header()->num_header_bytes, header->num_header_bytes); in Deserialize()
250 return header()->num_header_bytes - sizeof(Header); in extra_header_size()
256 return data_ + header()->num_header_bytes; in mutable_payload()
[all …]
|
| D | ports_message.cc | 34 PortsMessage::PortsMessage(size_t num_header_bytes, in PortsMessage() argument
38 : ports::Message(num_header_bytes, in PortsMessage()
56 NodeChannel::CreatePortsMessage(num_header_bytes, &ptr, 0); in PortsMessage()
|
| D | node_controller.cc | 82 size_t* num_header_bytes, in ParsePortsMessage() argument
85 DCHECK(data && num_data_bytes && num_header_bytes && num_payload_bytes && in ParsePortsMessage()
92 if (!ports::Message::Parse(*data, *num_data_bytes, num_header_bytes, in ParsePortsMessage()
824 void NodeController::AllocMessage(size_t num_header_bytes, in AllocMessage() argument
826 message->reset(new PortsMessage(num_header_bytes, 0, 0, nullptr)); in AllocMessage()
1120 size_t num_data_bytes, num_header_bytes, num_payload_bytes, num_ports_bytes; in OnPortsMessage() local
1122 &num_header_bytes, &num_payload_bytes, in OnPortsMessage()
1130 new PortsMessage(num_header_bytes, in OnPortsMessage()
1217 size_t num_data_bytes, num_header_bytes, num_payload_bytes, num_ports_bytes; in OnBroadcast() local
1219 &num_header_bytes, &num_payload_bytes, in OnBroadcast()
|
| D | ports_message.h | 55 PortsMessage(size_t num_header_bytes,
|
| D | channel.h | 76 uint16_t num_header_bytes; member
|
| D | node_controller.h | 198 void AllocMessage(size_t num_header_bytes,
|