Set max size for received pkts queue

diff --git a/cpp_impl/src/UDPC_Defines.hpp b/cpp_impl/src/UDPC_Defines.hpp
index 52ffb4460edd45f302075c4254349b14231d7ec8..2950d1172d9d7d4711e9e20a601db144536e48f7 100644 (file)
--- a/cpp_impl/src/UDPC_Defines.hpp
+++ b/cpp_impl/src/UDPC_Defines.hpp
@@ -7,6 +7,7 @@
 #define UDPC_BAD_MODE_SEND_INTERVAL (1.0f / 10.0f)
 #define UDPC_SENT_PKTS_MAX_SIZE 33
 #define UDPC_QUEUED_PKTS_MAX_SIZE 32
+#define UDPC_RECEIVED_PKTS_MAX_SIZE 50
 #define UDPC_GOOD_RTT_LIMIT_SEC 0.25f
 #define UDPC_PACKET_TIMEOUT_SEC 1.0f
 

diff --git a/cpp_impl/src/UDPConnection.cpp b/cpp_impl/src/UDPConnection.cpp
index dddd7086b07d74059c126028c28dd74371fb6ba6..d7f85908772a5c2eb2a0c7635cf68abac8f4e545 100644 (file)
--- a/cpp_impl/src/UDPConnection.cpp
+++ b/cpp_impl/src/UDPConnection.cpp
@@ -21,17 +21,18 @@ toggledTimer(0.0f),
 sentPkts(),
 sendPkts(UDPC_QUEUED_PKTS_MAX_SIZE),
 priorityPkts(UDPC_QUEUED_PKTS_MAX_SIZE),
+receivedPkts(UDPC_RECEIVED_PKTS_MAX_SIZE),
 received(std::chrono::steady_clock::now()),
 sent(std::chrono::steady_clock::now()),
 rtt(0.0f)
 {
+    flags.set(0);
 }
 
 UDPC::ConnectionData::ConnectionData(bool isServer, Context *ctx) :
 UDPC::ConnectionData::ConnectionData()
 {
     if(isServer) {
-        flags.set(0);
         flags.set(3);
         id = UDPC::generateConnectionID(*ctx);
         flags.set(4);