X-Git-Url: http://git.localhorst.tv/?a=blobdiff_plain;f=src%2Fnet%2FConnectionHandler.hpp;h=be01d10add35ab3b597c4cec5c5efa5d8d17f4c5;hb=c256dca7c6ca2c7f8eeffae53c02fe62bd892198;hp=6e18da2727821b754904a3ebcc39534714f3b881;hpb=ae5a7e7d8517fac406a88e9bf98fd3d5bb1728b9;p=blank.git diff --git a/src/net/ConnectionHandler.hpp b/src/net/ConnectionHandler.hpp index 6e18da2..be01d10 100644 --- a/src/net/ConnectionHandler.hpp +++ b/src/net/ConnectionHandler.hpp @@ -11,16 +11,32 @@ namespace blank { class ConnectionHandler { public: + ConnectionHandler(); + + /// packet loss as factor + float PacketLoss() const noexcept { return packet_loss; } + /// smooth average round trip time in milliseconds + float RoundTripTime() const noexcept { return rtt; } + + void PacketSent(std::uint16_t); + void PacketLost(std::uint16_t); + void PacketReceived(std::uint16_t); + void Handle(const UDPpacket &); + virtual void OnTimeout() { } + +private: + void UpdatePacketLoss() noexcept; + void UpdateRTT(std::uint16_t) noexcept; + bool SamplePacket(std::uint16_t) const noexcept; + int HeadDiff(std::uint16_t) const noexcept; + // called as soon as the remote end ack'd given packet virtual void OnPacketReceived(std::uint16_t) { } // called if the remote end probably didn't get given packet virtual void OnPacketLost(std::uint16_t) { } - virtual void OnTimeout() { } - -private: virtual void On(const Packet::Ping &) { } virtual void On(const Packet::Login &) { } virtual void On(const Packet::Join &) { } @@ -32,6 +48,18 @@ private: virtual void On(const Packet::PlayerCorrection &) { } virtual void On(const Packet::ChunkBegin &) { } virtual void On(const Packet::ChunkData &) { } + virtual void On(const Packet::BlockUpdate &) { } + virtual void On(const Packet::Message &) { } + +private: + unsigned int packets_lost; + unsigned int packets_received; + float packet_loss; + + Uint32 stamps[16]; + std::size_t stamp_cursor; + std::uint16_t stamp_last; + float rtt; };