Mirrors/overte-lubosz
3
0
Fork 0
mirror of https://github.com/lubosz/overte.git synced 2025-04-13 14:52:36 +02:00
Code Issues Projects Releases Packages Wiki Activity Actions

Timebox readPendingDatagrams

Browse source
This commit is contained in:
Clement 2018-10-04 16:12:40 -07:00
parent 8a95c58f86
commit bcbbe884c7
1 changed files with 10 additions and 1 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

11
libraries/networking/src/udt/Socket.cpp
View file

@ -315,9 +315,18 @@ void Socket::checkForReadyReadBackup() {
}
void Socket::readPendingDatagrams() {
using namespace std::chrono;
static const auto MAX_PROCESS_TIME { 100ms };
const auto abortTime = system_clock::now() + MAX_PROCESS_TIME;
int packetSizeWithHeader = -1;
while (_udpSocket.hasPendingDatagrams() && (packetSizeWithHeader = _udpSocket.pendingDatagramSize()) != -1) {
while (_udpSocket.hasPendingDatagrams() &&
(packetSizeWithHeader = _udpSocket.pendingDatagramSize()) != -1) {
if (system_clock::now() > abortTime) {
// We've been running for too long, stop processing packets for now
// Once we've processed the event queue, we'll come back to packet processing
break;
}
// we're reading a packet so re-start the readyRead backup timer
_readyReadBackupTimer->start();