X-Git-Url: http://git.tdb.fi/?a=blobdiff_plain;f=source%2Fnet%2Fprotocol.h;h=0721ec5b5403adebb4013e54a07358700beebecc;hb=c2e9e03b191a6ffe44a83be32aadf2a325491c02;hp=35d3cb2cbfe177de4214816d70643f9ff97e32bd;hpb=1565dec0f4a86e4bda7095dd7415234f7c7a84e9;p=libs%2Fnet.git diff --git a/source/net/protocol.h b/source/net/protocol.h index 35d3cb2..0721ec5 100644 --- a/source/net/protocol.h +++ b/source/net/protocol.h @@ -3,29 +3,31 @@ #include #include +#include #include #include #include +#include "mspnet_api.h" #include "receiver.h" namespace Msp { namespace Net { -class bad_packet: public std::runtime_error +class MSPNET_API bad_packet: public std::runtime_error { public: bad_packet(const std::string &w): std::runtime_error(w) { } }; -class buffer_error: public std::runtime_error +class MSPNET_API buffer_error: public std::runtime_error { public: buffer_error(const std::string &w): std::runtime_error(w) { } }; -class Protocol +class MSPNET_API Protocol { private: template @@ -142,11 +144,10 @@ private: class PacketTypeDef: public PacketDefBase { private: - Serializer

*serializer; + std::unique_ptr> serializer; public: PacketTypeDef(unsigned); - ~PacketTypeDef(); unsigned get_class_id() const override { return get_packet_class_id

(); } @@ -188,17 +189,13 @@ private: PacketHeader(std::uint16_t, std::uint16_t); }; - typedef std::map PacketMap; - PacketTypeDef header_def; unsigned next_packet_id; - PacketMap packet_class_defs; - PacketMap packet_id_defs; + std::map> packet_class_defs; + std::map packet_id_defs; protected: Protocol(unsigned = 1); -public: - ~Protocol(); private: static unsigned get_next_packet_class_id(); @@ -206,7 +203,7 @@ private: template static unsigned get_packet_class_id(); - void add_packet(PacketDefBase *); + void add_packet(std::unique_ptr); protected: template @@ -229,10 +226,10 @@ protected: public: template - std::size_t serialize(const P &, char *, std::size_t) const; + std::size_t serialize(const P &, char *, std::size_t, unsigned = 0) const; std::size_t get_packet_size(const char *, std::size_t) const; - std::size_t dispatch(ReceiverBase &, const char *, std::size_t) const; + std::size_t dispatch(ReceiverBase &, const char *, std::size_t, unsigned = 0) const; std::uint64_t get_hash() const; }; @@ -248,9 +245,10 @@ unsigned Protocol::get_packet_class_id() template Protocol::PacketDefBuilder> Protocol::add(unsigned id) { - PacketTypeDef

*pdef = new PacketTypeDef

(id); - add_packet(pdef); - return PacketDefBuilder>(*this, *pdef, Serializer

()); + std::unique_ptr> pdef = std::make_unique>(id); + PacketDefBuilder> next(*this, *pdef, Serializer

()); + add_packet(move(pdef)); + return next; } template @@ -267,14 +265,14 @@ const Protocol::PacketTypeDef

&Protocol::get_packet_by_class() const } template -std::size_t Protocol::serialize(const P &pkt, char *buf, std::size_t size) const +std::size_t Protocol::serialize(const P &pkt, char *buf, std::size_t size, unsigned base_id) const { const PacketTypeDef

&pdef = get_packet_by_class

(); if(!pdef.get_id()) throw std::invalid_argument("no packet id"); char *ptr = pdef.serialize(pkt, buf+4, buf+size); size = ptr-buf; - header_def.serialize(PacketHeader(pdef.get_id(), size), buf, buf+4); + header_def.serialize(PacketHeader(base_id+pdef.get_id(), size), buf, buf+4); return size; } @@ -413,21 +411,14 @@ const char *Protocol::FieldSerializer::deserialize(C &com, const cha template Protocol::PacketTypeDef

::PacketTypeDef(unsigned i): PacketDefBase(i), - serializer(new Serializer

) + serializer(std::make_unique>()) { } -template -Protocol::PacketTypeDef

::~PacketTypeDef() -{ - delete serializer; -} - template template void Protocol::PacketTypeDef

::set_serializer(const S &ser) { - delete serializer; - serializer = new S(ser); + serializer = std::make_unique(ser); } template