Method read_command_header

src/p2p/LevinProtocol.cpp:72–85

size_t LevinProtocol::HEADER_SIZE() { return sizeof(bucket_head2); }

size_t LevinProtocol::read_command_header(const BinaryArray &raw_header, CommandType *rrn, uint32_t *command) {
	bucket_head2 head = {};
	if (raw_header.size() != sizeof(head))
		throw std::runtime_error("Levin wrong header size " + common::to_string(raw_header.size()));
	memmove(&head, raw_header.data(), sizeof(head));  // TODO - endian

	if (head.m_magic != LEVIN_MAGIC)
		throw std::runtime_error("Levin magic mismatch raw_header=" + common::to_hex(raw_header));

	*command = head.m_command;
	*rrn     = (head.m_flags & LEVIN_PACKET_RESPONSE) == LEVIN_PACKET_RESPONSE ? RESPONSE
	                                                                       : head.m_command_type ? REQUEST : NOTIFY;
	return common::integer_cast<size_t>(head.m_cb);
}