aboutsummaryrefslogtreecommitdiffstats
path: root/lib/Socket.cpp
diff options
context:
space:
mode:
authorMatthias P. Braendli <matthias.braendli@mpb.li>2020-06-23 15:45:53 +0200
committerMatthias P. Braendli <matthias.braendli@mpb.li>2020-06-23 15:45:53 +0200
commit2623b2736cef540aea937a7d48ba52e10f962198 (patch)
tree1e07a637b9d7d1914493708a1ef8b56ce2642723 /lib/Socket.cpp
parent0d15b12426f85916f5c896f844590df02442d6c6 (diff)
downloadODR-EDI2EDI-2623b2736cef540aea937a7d48ba52e10f962198.tar.gz
ODR-EDI2EDI-2623b2736cef540aea937a7d48ba52e10f962198.tar.bz2
ODR-EDI2EDI-2623b2736cef540aea937a7d48ba52e10f962198.zip
Update common code
Diffstat (limited to 'lib/Socket.cpp')
-rw-r--r--lib/Socket.cpp7
1 files changed, 6 insertions, 1 deletions
diff --git a/lib/Socket.cpp b/lib/Socket.cpp
index 159de7e..bc1b179 100644
--- a/lib/Socket.cpp
+++ b/lib/Socket.cpp
@@ -2,7 +2,7 @@
Copyright (C) 2003, 2004, 2005, 2006, 2007, 2008, 2009 Her Majesty the
Queen in Right of Canada (Communications Research Center Canada)
- Copyright (C) 2019
+ Copyright (C) 2020
Matthias P. Braendli, matthias.braendli@mpb.li
http://www.opendigitalradio.org
@@ -932,6 +932,11 @@ void TCPSendClient::sendall(const std::vector<uint8_t>& buffer)
}
m_queue.push(buffer);
+
+ if (m_queue.size() > MAX_QUEUE_SIZE) {
+ vector<uint8_t> discard;
+ m_queue.try_pop(discard);
+ }
}
void TCPSendClient::process()