From 1bbbac7f62d71f0d0c4c71d429aeb2cfdf96e5ac Mon Sep 17 00:00:00 2001
From: "Matthias P. Braendli" <matthias.braendli@mpb.li>
Date: Fri, 13 Jan 2017 16:33:33 +0100
Subject: EDI: add protection against runaway memory usage

---
 lib/UdpSocket.h | 3 ++-
 1 file changed, 2 insertions(+), 1 deletion(-)

(limited to 'lib/UdpSocket.h')

diff --git a/lib/UdpSocket.h b/lib/UdpSocket.h
index 81a7d2b..8c968d2 100644
--- a/lib/UdpSocket.h
+++ b/lib/UdpSocket.h
@@ -184,7 +184,7 @@ class UdpReceiver {
         UdpReceiver operator=(const UdpReceiver&) = delete;
 
         // Start the receiver in a separate thread
-        void start(int port);
+        void start(int port, size_t max_packets_queued);
 
         // Get the data contained in a UDP packet, blocks if none available
         // In case of error, throws a runtime_error
@@ -194,6 +194,7 @@ class UdpReceiver {
         void m_run(void);
 
         int m_port;
+        size_t m_max_packets_queued;
         std::thread m_thread;
         std::atomic<bool> m_stop;
         ThreadsafeQueue<UdpPacket> m_packets;
-- 
cgit v1.2.3