Mirrors/overte
3
0
Fork 0
mirror of https://github.com/overte-org/overte.git synced 2025-04-14 07:47:30 +02:00
Code Issues Projects Releases Packages Wiki Activity Actions 2

Take out useless noisy message timer

Browse source
This commit is contained in:
Simon Walton 2018-04-04 16:03:56 -07:00
parent d05f0600d4
commit 104788de50
1 changed files with 2 additions and 17 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

19
domain-server/src/DomainServer.cpp
View file

@ -1273,24 +1273,11 @@ void DomainServer::processRequestAssignmentPacket(QSharedPointer<ReceivedMessage
return; return;
} }
// Suppress these for Assignment::AgentType to once per 5 seconds
static QElapsedTimer noisyMessageTimer;
static bool wasNoisyTimerStarted = false;
if (!wasNoisyTimerStarted) {
noisyMessageTimer.start();
wasNoisyTimerStarted = true;
}
const qint64 NOISY_MESSAGE_INTERVAL_MSECS = 5 * 1000;
static bool printedAssignmentTypeMessage = false; static bool printedAssignmentTypeMessage = false;
if (!printedAssignmentTypeMessage && (requestAssignment.getType() != Assignment::AgentType if (!printedAssignmentTypeMessage && requestAssignment.getType() != Assignment::AgentType) {
|| noisyMessageTimer.elapsed() > NOISY_MESSAGE_INTERVAL_MSECS)) {
printedAssignmentTypeMessage = true; printedAssignmentTypeMessage = true;
qDebug() << "Received a request for assignment type" << requestAssignment.getType() qDebug() << "Received a request for assignment type" << requestAssignment.getType()
<< "from" << message->getSenderSockAddr(); << "from" << message->getSenderSockAddr();
noisyMessageTimer.restart();
} }
SharedAssignmentPointer assignmentToDeploy = deployableAssignmentForRequest(requestAssignment); SharedAssignmentPointer assignmentToDeploy = deployableAssignmentForRequest(requestAssignment);
@ -1325,12 +1312,10 @@ void DomainServer::processRequestAssignmentPacket(QSharedPointer<ReceivedMessage
requestAssignment.getWalletUUID(), requestAssignment.getNodeVersion()); requestAssignment.getWalletUUID(), requestAssignment.getNodeVersion());
} else { } else {
static bool printedAssignmentRequestMessage = false; static bool printedAssignmentRequestMessage = false;
if (!printedAssignmentRequestMessage && (requestAssignment.getType() != Assignment::AgentType if (!printedAssignmentRequestMessage && requestAssignment.getType() != Assignment::AgentType) {
|| noisyMessageTimer.elapsed() > NOISY_MESSAGE_INTERVAL_MSECS)) {
printedAssignmentRequestMessage = true; printedAssignmentRequestMessage = true;
qDebug() << "Unable to fulfill assignment request of type" << requestAssignment.getType() qDebug() << "Unable to fulfill assignment request of type" << requestAssignment.getType()
<< "from" << message->getSenderSockAddr(); << "from" << message->getSenderSockAddr();
noisyMessageTimer.restart();
} }
} }
} }