#include <ctime>
+#include <QDebug>
+
ClientBacklogManager::ClientBacklogManager(QObject *parent)
: BacklogManager(parent),
_requester(0)
if(msgs.isEmpty())
return;
+ emit messagesReceived(bufferId, msgs.count());
+
MessageList msglist;
foreach(QVariant v, msgs) {
Message msg = v.value<Message>();
Q_ASSERT(_requester);
dispatchMessages(_requester->bufferedMessages(), true);
-
- delete _requester;
- _requester = 0;
+ reset();
}
bool ClientBacklogManager::isBuffering() {
emit messagesProcessed(tr("Processed %1 messages in %2 seconds.").arg(msgs.count()).arg((float)(end_t - start_t) / CLOCKS_PER_SEC));
}
+
+void ClientBacklogManager::reset() {
+ delete _requester;
+ _requester = 0;
+}