{
}
-void ClientBacklogManager::receiveBacklog(BufferId bufferId, int lastMsgs, int offset, QVariantList msgs) {
- Q_UNUSED(lastMsgs)
- Q_UNUSED(offset)
+void ClientBacklogManager::receiveBacklog(BufferId bufferId, MsgId first, MsgId last, int limit, QVariantList msgs) {
+ Q_UNUSED(first)
+ Q_UNUSED(last)
+ Q_UNUSED(limit)
if(msgs.isEmpty())
return;
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;
+}