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

Optimize rate limiting on messaging mixer further.

Browse source
This commit is contained in:
Kalila L 2021-03-12 17:36:01 -05:00
parent 4b61d3328d
commit e12e746698
1 changed files with 0 additions and 14 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

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

@ -73,8 +73,6 @@ void MessagesMixer::handleMessagesSubscribe(QSharedPointer<ReceivedMessage> mess
QString channel = QString::fromUtf8(message->getMessage()); QString channel = QString::fromUtf8(message->getMessage());
_channelSubscribers[channel] << senderUUID; _channelSubscribers[channel] << senderUUID;
_allSubscribers[senderUUID] = 0;
} }
void MessagesMixer::handleMessagesUnsubscribe(QSharedPointer<ReceivedMessage> message, SharedNodePointer senderNode) { void MessagesMixer::handleMessagesUnsubscribe(QSharedPointer<ReceivedMessage> message, SharedNodePointer senderNode) {
@ -84,18 +82,6 @@ void MessagesMixer::handleMessagesUnsubscribe(QSharedPointer<ReceivedMessage> me
if (_channelSubscribers.contains(channel)) { if (_channelSubscribers.contains(channel)) {
_channelSubscribers[channel].remove(senderUUID); _channelSubscribers[channel].remove(senderUUID);
} }
bool isSenderSubscribed = false;
QList<QSet<QUuid>> allChannels = _channelSubscribers.values();
foreach (const QSet<QUuid> channel, allChannels) {
if (channel.contains(senderUUID)) {
isSenderSubscribed = true;
}
}
if (!isSenderSubscribed && _allSubscribers.contains(senderUUID)) {
_allSubscribers.remove(senderUUID);
}
} }
void MessagesMixer::sendStatsPacket() { void MessagesMixer::sendStatsPacket() {