X-Git-Url: https://git.quassel-irc.org/?p=quassel.git;a=blobdiff_plain;f=src%2Fclient%2Fbacklogrequester.h;h=e813c6c79d519d83fa7c47ed54b06212f308e882;hp=c3c6832b4f49bed6b1be7cda670e4816c511c180;hb=f6b9eeda207d42c99fc3e9085631722cf2ec83dc;hpb=5bd4e3fcf31a7a337f91b3bba86bd237aa5e7ed6 diff --git a/src/client/backlogrequester.h b/src/client/backlogrequester.h index c3c6832b..e813c6c7 100644 --- a/src/client/backlogrequester.h +++ b/src/client/backlogrequester.h @@ -32,28 +32,32 @@ class ClientBacklogManager; class BacklogRequester { public: - enum RequesterTypes { + enum RequesterType { InvalidRequester = 0, PerBufferFixed, PerBufferUnread, GlobalUnread }; - BacklogRequester(bool buffering, ClientBacklogManager *backlogManger); + BacklogRequester(bool buffering, RequesterType requesterType, ClientBacklogManager *backlogManger); virtual inline ~BacklogRequester() {} inline bool isBuffering() { return _isBuffering; } + inline RequesterType type() { return _requesterType; } inline const QList &bufferedMessages() { return _bufferedMessages; } inline int buffersWaiting() const { return _buffersWaiting.count(); } inline int totalBuffers() const { return _totalBuffers; } - //! returns false if it was the last missing backlogpart - bool buffer(BufferId bufferId, const MessageList &messages); - - virtual void requestBacklog() = 0; + + bool buffer(BufferId bufferId, const MessageList &messages); //! returns false if it was the last missing backlogpart + + virtual void requestBacklog(const BufferIdList &bufferIds) = 0; + virtual inline void requestInitialBacklog() { requestBacklog(allBufferIds()); } + + virtual void flushBuffer(); protected: - inline QList allBufferIds() const { return Client::networkModel()->allBufferIds(); } + BufferIdList allBufferIds() const; inline void setWaitingBuffers(const QList &buffers) { setWaitingBuffers(buffers.toSet()); } void setWaitingBuffers(const QSet &buffers); void addWaitingBuffer(BufferId buffer); @@ -62,6 +66,7 @@ protected: private: bool _isBuffering; + RequesterType _requesterType; MessageList _bufferedMessages; int _totalBuffers; QSet _buffersWaiting; @@ -73,7 +78,7 @@ private: class FixedBacklogRequester : public BacklogRequester { public: FixedBacklogRequester(ClientBacklogManager *backlogManager); - virtual void requestBacklog(); + virtual void requestBacklog(const BufferIdList &bufferIds); private: int _backlogCount; @@ -85,7 +90,8 @@ private: class GlobalUnreadBacklogRequester : public BacklogRequester { public: GlobalUnreadBacklogRequester(ClientBacklogManager *backlogManager); - virtual void requestBacklog(); + virtual void requestInitialBacklog(); + virtual void requestBacklog(const BufferIdList &) {} private: int _limit; @@ -98,7 +104,7 @@ private: class PerBufferUnreadBacklogRequester : public BacklogRequester { public: PerBufferUnreadBacklogRequester(ClientBacklogManager *backlogManager); - virtual void requestBacklog(); + virtual void requestBacklog(const BufferIdList &bufferIds); private: int _limit;