X-Git-Url: http://git.tdb.fi/?a=blobdiff_plain;f=source%2Fnet%2Fprotocol.cpp;h=ce200a2c0ea49afed1f320b0914c252a094669bd;hb=1565dec0f4a86e4bda7095dd7415234f7c7a84e9;hp=db663821c370cef914676eb1da698cdb473f5c50;hpb=ee01d294f9078fbf17dc6a0a645ad3a342c49b1a;p=libs%2Fnet.git diff --git a/source/net/protocol.cpp b/source/net/protocol.cpp index db66382..ce200a2 100644 --- a/source/net/protocol.cpp +++ b/source/net/protocol.cpp @@ -1,6 +1,5 @@ #include #include -#include #include #include #include @@ -15,14 +14,14 @@ Protocol::Protocol(unsigned npi): header_def(0), next_packet_id(npi) { - PacketDefBuilder >(*this, header_def, NullSerializer()) - (&PacketHeader::type)(&PacketHeader::length); + PacketDefBuilder>(*this, header_def, Serializer()) + .fields(&PacketHeader::type, &PacketHeader::length); } Protocol::~Protocol() { - for(map::iterator i=packet_class_defs.begin(); i!=packet_class_defs.end(); ++i) - delete i->second; + for(auto &kvp: packet_class_defs) + delete kvp.second; } unsigned Protocol::get_next_packet_class_id() @@ -57,11 +56,11 @@ const Protocol::PacketDefBase &Protocol::get_packet_by_id(unsigned id) const size_t Protocol::dispatch(ReceiverBase &rcv, const char *buf, size_t size) const { PacketHeader header; - buf = header_def.deserialize(header, buf, buf+size); + const char *ptr = header_def.deserialize(header, buf, buf+size); if(header.length>size) throw bad_packet("truncated"); const PacketDefBase &pdef = get_packet_by_id(header.type); - const char *ptr = pdef.dispatch(rcv, buf, buf+header.length); + ptr = pdef.dispatch(rcv, ptr, ptr+header.length); return ptr-buf; } @@ -76,10 +75,13 @@ size_t Protocol::get_packet_size(const char *buf, size_t size) const uint64_t Protocol::get_hash() const { - string description; - for(PacketMap::const_iterator i=packet_id_defs.begin(); i!=packet_id_defs.end(); ++i) - description += format("%d:%s\n", i->first, i->second->describe()); - return hash<64>(description); + uint64_t result = hash<64>(packet_id_defs.size()); + for(auto &kvp: packet_id_defs) + { + hash_update<64>(result, kvp.first); + hash_update<64>(result, kvp.second->get_hash()); + } + return result; } @@ -164,11 +166,6 @@ Protocol::PacketDefBase::PacketDefBase(unsigned i): { } -Protocol::PacketHeader::PacketHeader(): - type(0), - length(0) -{ } - Protocol::PacketHeader::PacketHeader(uint16_t t, uint16_t l): type(t), length(l)