X-Git-Url: https://git.quassel-irc.org/?a=blobdiff_plain;f=src%2Fclient%2Fclientbacklogmanager.cpp;h=b485726d6cf60054583094336c15a867043b0630;hb=6a590134d0ceca46e83a6b5b24e44550b68e9b4b;hp=519135a0867ecb0569d2fca43e15b7721331c3c1;hpb=ea372dac8dda146255c7232922904e9f90a0d7f9;p=quassel.git diff --git a/src/client/clientbacklogmanager.cpp b/src/client/clientbacklogmanager.cpp index 519135a0..b485726d 100644 --- a/src/client/clientbacklogmanager.cpp +++ b/src/client/clientbacklogmanager.cpp @@ -25,6 +25,7 @@ #include "client.h" #include +#include ClientBacklogManager::ClientBacklogManager(QObject *parent) : BacklogManager(parent), @@ -52,8 +53,11 @@ void ClientBacklogManager::receiveBacklog(BufferId bufferId, int lastMsgs, int o _buffersWaiting.remove(bufferId); if(_buffersWaiting.isEmpty()) { _buffer = false; + clock_t start_t = clock(); qSort(_messageBuffer); Client::messageProcessor()->process(_messageBuffer); + clock_t end_t = clock(); + qDebug() << "Processed" << _messageBuffer.count() << "Messages in" << (float)(end_t - start_t) / CLOCKS_PER_SEC << "seconds ==" << end_t - start_t << "clocks."; _messageBuffer.clear(); } } else { @@ -73,3 +77,9 @@ void ClientBacklogManager::requestInitialBacklog() { FixedBacklogRequester backlogRequester(this); backlogRequester.requestBacklog(); } + +void ClientBacklogManager::reset() { + _buffer = true; + _messageBuffer.clear(); + _buffersWaiting.clear(); +}