X-Git-Url: https://git.quassel-irc.org/?p=quassel.git;a=blobdiff_plain;f=src%2Fclient%2Fclientbacklogmanager.h;h=f52eb1646926ade691e5368e40a3c71c47a102b6;hp=e0bcfa30ce82c25fea762d398807c42b92e0c811;hb=2a00e8f57d66d9913a10c30408b89676a74010a1;hpb=f824db0e31b54969e0b7fa0b5405b1e9173d482c diff --git a/src/client/clientbacklogmanager.h b/src/client/clientbacklogmanager.h index e0bcfa30..f52eb164 100644 --- a/src/client/clientbacklogmanager.h +++ b/src/client/clientbacklogmanager.h @@ -27,6 +27,7 @@ class BacklogRequester; class ClientBacklogManager : public BacklogManager { + SYNCABLE_OBJECT Q_OBJECT public: @@ -38,22 +39,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