X-Git-Url: https://git.quassel-irc.org/?p=quassel.git;a=blobdiff_plain;f=src%2Fclient%2Fbacklogrequester.h;h=b942d7b34f0db9997e83f6c70f0281df73ddcc65;hp=5ef71b28784b7b7bdae562fbbf3b0ff02c5c8e8d;hb=8f0946673bc3edc84b6f13e16cbe8ece912b4a3b;hpb=954b1a6f53da55f9713fb4e75a2fb46dae7d9df8 diff --git a/src/client/backlogrequester.h b/src/client/backlogrequester.h index 5ef71b28..b942d7b3 100644 --- a/src/client/backlogrequester.h +++ b/src/client/backlogrequester.h @@ -24,6 +24,7 @@ #include #include "client.h" +#include "message.h" #include "networkmodel.h" #include "types.h" @@ -31,25 +32,47 @@ class BacklogManager; class BacklogRequester { public: - BacklogRequester(BacklogManager *backlogManger); + enum RequesterTypes { + InvalidRequester = 0, + GlobalUnread, + PerBufferUnread, + PerBufferFixed + }; + + BacklogRequester(bool buffering, BacklogManager *backlogManger); virtual inline ~BacklogRequester() {} + inline bool isBuffering() { return _isBuffering; } + inline const QList &bufferedMessages() { return _bufferedMessages; } + + //! returns false if it was the last missing backlogpart + bool buffer(BufferId bufferId, const MessageList &messages); + virtual void requestBacklog() = 0; protected: inline QList allBufferIds() const { return Client::networkModel()->allBufferIds(); } + inline void setWaitingBuffers(const QList &buffers) { _buffersWaiting = buffers.toSet(); } + inline void setWaitingBuffers(const QSet &buffers) { _buffersWaiting = buffers; } + inline void addWaitingBuffer(BufferId buffer) { _buffersWaiting << buffer; } BacklogManager *backlogManager; -}; +private: + bool _isBuffering; + MessageList _bufferedMessages; + QSet _buffersWaiting; +}; +// ======================================== +// FIXED BACKLOG REQUESTER +// ======================================== class FixedBacklogRequester : public BacklogRequester { public: FixedBacklogRequester(BacklogManager *backlogManager); - virtual void requestBacklog(); private: - static const int backlogCount; + int _backlogCount; };