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

Add check to stop processor before starting.

Browse source
This commit is contained in:
Kalila L 2021-03-14 21:50:08 -04:00
parent e12e746698
commit 9d15b00fbb
2 changed files with 5 additions and 1 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

4
assignment-client/src/messages/MessagesMixer.cpp
View file

@ -132,6 +132,10 @@ void MessagesMixer::processMaxMessagesContainer() {
} }
void MessagesMixer::startMaxMessagesProcessor() { void MessagesMixer::startMaxMessagesProcessor() {
if (_maxMessagesTimer) {
stopMaxMessagesProcessor();
}
_maxMessagesTimer = new QTimer(); _maxMessagesTimer = new QTimer();
connect(_maxMessagesTimer, &QTimer::timeout, this, &MessagesMixer::processMaxMessagesContainer); connect(_maxMessagesTimer, &QTimer::timeout, this, &MessagesMixer::processMaxMessagesContainer);
_maxMessagesTimer->start(MESSAGES_MIXER_RATE_LIMITER_INTERVAL); // Clear the container every second. _maxMessagesTimer->start(MESSAGES_MIXER_RATE_LIMITER_INTERVAL); // Clear the container every second.

2
assignment-client/src/messages/MessagesMixer.h
View file

@ -46,7 +46,7 @@ private:
const int DEFAULT_NODE_MESSAGES_PER_SECOND = 1000; const int DEFAULT_NODE_MESSAGES_PER_SECOND = 1000;
int _maxMessagesPerSecond { 0 }; int _maxMessagesPerSecond { 0 };
QTimer* _maxMessagesTimer; QTimer* _maxMessagesTimer { nullptr };
}; };
#endif // hifi_MessagesMixer_h #endif // hifi_MessagesMixer_h