From e12e74669877d24f56fa8dd6abb6394794b24010 Mon Sep 17 00:00:00 2001 From: Kalila L Date: Fri, 12 Mar 2021 17:36:01 -0500 Subject: [PATCH] Optimize rate limiting on messaging mixer further. --- assignment-client/src/messages/MessagesMixer.cpp | 14 -------------- 1 file changed, 14 deletions(-) diff --git a/assignment-client/src/messages/MessagesMixer.cpp b/assignment-client/src/messages/MessagesMixer.cpp index c54229b7f2..1ab698b456 100644 --- a/assignment-client/src/messages/MessagesMixer.cpp +++ b/assignment-client/src/messages/MessagesMixer.cpp @@ -73,8 +73,6 @@ void MessagesMixer::handleMessagesSubscribe(QSharedPointer mess QString channel = QString::fromUtf8(message->getMessage()); _channelSubscribers[channel] << senderUUID; - - _allSubscribers[senderUUID] = 0; } void MessagesMixer::handleMessagesUnsubscribe(QSharedPointer message, SharedNodePointer senderNode) { @@ -84,18 +82,6 @@ void MessagesMixer::handleMessagesUnsubscribe(QSharedPointer me if (_channelSubscribers.contains(channel)) { _channelSubscribers[channel].remove(senderUUID); } - - bool isSenderSubscribed = false; - QList> allChannels = _channelSubscribers.values(); - foreach (const QSet channel, allChannels) { - if (channel.contains(senderUUID)) { - isSenderSubscribed = true; - } - } - - if (!isSenderSubscribed && _allSubscribers.contains(senderUUID)) { - _allSubscribers.remove(senderUUID); - } } void MessagesMixer::sendStatsPacket() {