kopia lustrzana https://gitlab.com/eliggett/wfview
Fix mutex
rodzic
fe7bdf1345
commit
3568c80fcc
|
@ -1325,11 +1325,12 @@ void udpBase::sendRetransmitRequest()
|
||||||
else if (rxMissing.size() > 100) {
|
else if (rxMissing.size() > 100) {
|
||||||
qDebug(logUdp()) << "Too many missing packets," << rxMissing.size() << "flushing all buffers";
|
qDebug(logUdp()) << "Too many missing packets," << rxMissing.size() << "flushing all buffers";
|
||||||
missingMutex.lock();
|
missingMutex.lock();
|
||||||
rxBufferMutex.lock();
|
|
||||||
qDebug(logUdp()) << "Too many missing packets, full reset!";
|
|
||||||
rxSeqBuf.clear();
|
|
||||||
rxMissing.clear();
|
rxMissing.clear();
|
||||||
missingMutex.unlock();
|
missingMutex.unlock();
|
||||||
|
|
||||||
|
rxBufferMutex.lock();
|
||||||
|
rxSeqBuf.clear();
|
||||||
|
rxBufferMutex.unlock();
|
||||||
return;
|
return;
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
|
@ -1690,10 +1690,10 @@ void udpServer::sendRetransmitRequest(CLIENT* c)
|
||||||
}
|
}
|
||||||
else if (c->rxMissing.size() > 100) {
|
else if (c->rxMissing.size() > 100) {
|
||||||
qDebug(logUdp()) << "Too many missing packets," << c->rxMissing.size() << "flushing all buffers";
|
qDebug(logUdp()) << "Too many missing packets," << c->rxMissing.size() << "flushing all buffers";
|
||||||
c->missMutex.lock();
|
|
||||||
c->rxMutex.lock();
|
c->rxMutex.lock();
|
||||||
qDebug(logUdp()) << "Too many missing packets, full reset!";
|
|
||||||
c->rxSeqBuf.clear();
|
c->rxSeqBuf.clear();
|
||||||
|
c->rxMutex.unlock();
|
||||||
|
c->missMutex.lock();
|
||||||
c->rxMissing.clear();
|
c->rxMissing.clear();
|
||||||
c->missMutex.unlock();
|
c->missMutex.unlock();
|
||||||
return;
|
return;
|
||||||
|
|
Ładowanie…
Reference in New Issue