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 | 60 TestMessage(size_t num_header_bytes, in TestMessage() argument
63 : Message(num_header_bytes, in TestMessage()
66 start_ = new char[num_header_bytes + num_payload_bytes + num_ports_bytes]; in TestMessage()
202 void AllocMessage(size_t num_header_bytes, ScopedMessage* message) override { in AllocMessage() argument
203 message->reset(new TestMessage(num_header_bytes, 0, 0)); in AllocMessage()
227 new TestMessage(message->num_header_bytes(), 0, 0)); in BroadcastMessage()
229 message->num_header_bytes()); in BroadcastMessage()
|
| /external/libmojo/mojo/edk/system/ |
| D | channel.cc | 94 header_->num_header_bytes = in Message()
138 if (header->num_bytes < header->num_header_bytes || in Deserialize()
139 header->num_header_bytes < sizeof(Header)) { in Deserialize()
141 << header->num_header_bytes; in Deserialize()
145 uint32_t extra_header_size = header->num_header_bytes - sizeof(Header); in Deserialize()
146 size_t payload_size = data_num_bytes - header->num_header_bytes; in Deserialize()
148 static_cast<const char*>(data) + header->num_header_bytes; in Deserialize()
180 DCHECK_EQ(message->header_->num_header_bytes, header->num_header_bytes); in Deserialize()
208 return size_ - header_->num_header_bytes; in payload_size()
526 if (header->num_header_bytes < sizeof(Message::Header) || in OnReadComplete()
[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 | channel.h | 57 uint16_t num_header_bytes; member
129 return header_->num_header_bytes - sizeof(Header); in extra_header_size()
132 void* mutable_payload() { return data_ + header_->num_header_bytes; } in mutable_payload()
133 const void* payload() const { return data_ + header_->num_header_bytes; } in payload()
|
| D | node_controller.cc | 80 size_t* num_header_bytes, in ParsePortsMessage() argument
83 DCHECK(data && num_data_bytes && num_header_bytes && num_payload_bytes && in ParsePortsMessage()
90 if (!ports::Message::Parse(*data, *num_data_bytes, num_header_bytes, in ParsePortsMessage()
728 void NodeController::AllocMessage(size_t num_header_bytes, in AllocMessage() argument
730 message->reset(new PortsMessage(num_header_bytes, 0, 0, nullptr)); in AllocMessage()
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()
1031 new PortsMessage(num_header_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 | ports_message.h | 55 PortsMessage(size_t num_header_bytes,
|
| D | node_controller.h | 165 void AllocMessage(size_t num_header_bytes,
|