X-Git-Url: https://git.sesse.net/?p=cubemap;a=blobdiff_plain;f=udpinput.h;h=caff008793842cdce2b601e10ea8c61041ae889e;hp=e41266e0dc3340a151d1a1a44a45748dcc628f1a;hb=bd694fdd3dd1417399aecead2c8b91fc4fe95ce8;hpb=9abb89bcf7940e2ada9d708f86a218a56334f68d diff --git a/udpinput.h b/udpinput.h index e41266e..caff008 100644 --- a/udpinput.h +++ b/udpinput.h @@ -21,6 +21,8 @@ public: virtual void add_destination(int stream_index); + virtual InputStats get_stats() const; + private: // Actually gets the packets. virtual void do_work(); @@ -39,6 +41,15 @@ private: // The socket we are receiving on (or -1). int sock; + + // Temporary buffer, sized for the maximum size of an UDP packet. + char packet_buf[65536]; + + // Mutex protecting . + mutable pthread_mutex_t stats_mutex; + + // The current statistics for this connection. Protected by . + InputStats stats; }; #endif // !defined(_UDPINPUT_H)