Searched refs:BrokerMessageHeader (Results 1 – 4 of 4) sorted by relevance
22 struct BrokerMessageHeader { struct27 static_assert(IsAlignedForChannelMessage(sizeof(BrokerMessageHeader)), argument52 const size_t required_size = sizeof(BrokerMessageHeader) + sizeof(T); in GetBrokerMessageData()56 auto* header = static_cast<BrokerMessageHeader*>(message->mutable_payload()); in GetBrokerMessageData()68 const size_t message_size = sizeof(BrokerMessageHeader) +71 BrokerMessageHeader* header =72 reinterpret_cast<BrokerMessageHeader*>(message->mutable_payload());86 new Channel::Message(sizeof(BrokerMessageHeader), num_handles)); in CreateBrokerMessage()87 BrokerMessageHeader* header = in CreateBrokerMessage()88 reinterpret_cast<BrokerMessageHeader*>(message->mutable_payload()); in CreateBrokerMessage()
61 if (!message || message->payload_size() < sizeof(BrokerMessageHeader)) { in WaitForBrokerMessage()70 const BrokerMessageHeader* header = in WaitForBrokerMessage()71 reinterpret_cast<const BrokerMessageHeader*>(message->payload()); in WaitForBrokerMessage()101 const BrokerMessageHeader* header = in Broker()102 static_cast<const BrokerMessageHeader*>(message->payload()); in Broker()104 sizeof(BrokerMessageHeader) + sizeof(InitData)); in Broker()107 sizeof(BrokerMessageHeader) + sizeof(InitData) + in Broker()
145 if (payload_size < sizeof(BrokerMessageHeader)) in OnChannelMessage()148 const BrokerMessageHeader* header = in OnChannelMessage()149 static_cast<const BrokerMessageHeader*>(payload); in OnChannelMessage()153 sizeof(BrokerMessageHeader) + sizeof(BufferRequestData)) { in OnChannelMessage()
33 sizeof(BrokerMessageHeader) + expected_data_size, expected_num_handles)); in WaitForBrokerMessage()53 const BrokerMessageHeader* header = in WaitForBrokerMessage()54 reinterpret_cast<const BrokerMessageHeader*>(message->payload()); in WaitForBrokerMessage()