X-Git-Url: https://git.quassel-irc.org/?p=quassel.git;a=blobdiff_plain;f=src%2Fclient%2Fclientbacklogmanager.h;h=2aa399b5e9b9e26ca74089d181e3f5ee6170a1cd;hp=e0bcfa30ce82c25fea762d398807c42b92e0c811;hb=526eccc444029c5a0d80694487c3aec6707cbeda;hpb=f824db0e31b54969e0b7fa0b5405b1e9173d482c diff --git a/src/client/clientbacklogmanager.h b/src/client/clientbacklogmanager.h index e0bcfa30..2aa399b5 100644 --- a/src/client/clientbacklogmanager.h +++ b/src/client/clientbacklogmanager.h @@ -38,22 +38,35 @@ public: void reset(); public slots: + virtual QVariantList requestBacklog(BufferId bufferId, MsgId first = -1, MsgId last = -1, int limit = -1, int additional = 0); virtual void receiveBacklog(BufferId bufferId, MsgId first, MsgId last, int limit, int additional, QVariantList msgs); virtual void receiveBacklogAll(MsgId first, MsgId last, int limit, int additional, QVariantList msgs); + void requestInitialBacklog(); + void checkForBacklog(BufferId bufferId); + void checkForBacklog(const BufferIdList &bufferIds); + signals: void messagesReceived(BufferId bufferId, int count) const; void messagesRequested(const QString &) const; void messagesProcessed(const QString &) const; + void updateProgress(int, int); + private: bool isBuffering(); - void stopBuffering(); + BufferIdList filterNewBufferIds(const BufferIdList &bufferIds); void dispatchMessages(const MessageList &messages, bool sort = false); BacklogRequester *_requester; + QSet _buffersRequested; }; +// inlines +inline void ClientBacklogManager::checkForBacklog(BufferId bufferId) { + checkForBacklog(BufferIdList() << bufferId); +} + #endif // CLIENTBACKLOGMANAGER_H