X-Git-Url: https://git.quassel-irc.org/?p=quassel.git;a=blobdiff_plain;f=src%2Fclient%2Fbacklogrequester.h;fp=src%2Fclient%2Fbacklogrequester.h;h=06d0c2b81fa5262c51657ef8f7cce4e52d7d3a91;hp=e813c6c79d519d83fa7c47ed54b06212f308e882;hb=694f9bfbf7f1af19108461c7e00d133e55082bce;hpb=61c8d84d1c849373e0f115dc748ed45cff95287d diff --git a/src/client/backlogrequester.h b/src/client/backlogrequester.h index e813c6c7..06d0c2b8 100644 --- a/src/client/backlogrequester.h +++ b/src/client/backlogrequester.h @@ -30,85 +30,93 @@ class ClientBacklogManager; -class BacklogRequester { +class BacklogRequester +{ public: - enum RequesterType { - InvalidRequester = 0, - PerBufferFixed, - PerBufferUnread, - GlobalUnread - }; + enum RequesterType { + InvalidRequester = 0, + PerBufferFixed, + PerBufferUnread, + GlobalUnread + }; - BacklogRequester(bool buffering, RequesterType requesterType, ClientBacklogManager *backlogManger); - virtual inline ~BacklogRequester() {} + 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 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; } + inline int buffersWaiting() const { return _buffersWaiting.count(); } + inline int totalBuffers() const { return _totalBuffers; } - bool buffer(BufferId bufferId, const MessageList &messages); //! returns false if it was the last missing backlogpart + 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 requestBacklog(const BufferIdList &bufferIds) = 0; + virtual inline void requestInitialBacklog() { requestBacklog(allBufferIds()); } - virtual void flushBuffer(); + virtual void flushBuffer(); protected: - BufferIdList allBufferIds() const; - inline void setWaitingBuffers(const QList &buffers) { setWaitingBuffers(buffers.toSet()); } - void setWaitingBuffers(const QSet &buffers); - void addWaitingBuffer(BufferId buffer); + BufferIdList allBufferIds() const; + inline void setWaitingBuffers(const QList &buffers) { setWaitingBuffers(buffers.toSet()); } + void setWaitingBuffers(const QSet &buffers); + void addWaitingBuffer(BufferId buffer); - ClientBacklogManager *backlogManager; + ClientBacklogManager *backlogManager; private: - bool _isBuffering; - RequesterType _requesterType; - MessageList _bufferedMessages; - int _totalBuffers; - QSet _buffersWaiting; + bool _isBuffering; + RequesterType _requesterType; + MessageList _bufferedMessages; + int _totalBuffers; + QSet _buffersWaiting; }; + // ======================================== // FIXED BACKLOG REQUESTER // ======================================== -class FixedBacklogRequester : public BacklogRequester { +class FixedBacklogRequester : public BacklogRequester +{ public: - FixedBacklogRequester(ClientBacklogManager *backlogManager); - virtual void requestBacklog(const BufferIdList &bufferIds); + FixedBacklogRequester(ClientBacklogManager *backlogManager); + virtual void requestBacklog(const BufferIdList &bufferIds); private: - int _backlogCount; + int _backlogCount; }; + // ======================================== // GLOBAL UNREAD BACKLOG REQUESTER // ======================================== -class GlobalUnreadBacklogRequester : public BacklogRequester { +class GlobalUnreadBacklogRequester : public BacklogRequester +{ public: - GlobalUnreadBacklogRequester(ClientBacklogManager *backlogManager); - virtual void requestInitialBacklog(); - virtual void requestBacklog(const BufferIdList &) {} + GlobalUnreadBacklogRequester(ClientBacklogManager *backlogManager); + virtual void requestInitialBacklog(); + virtual void requestBacklog(const BufferIdList &) {} private: - int _limit; - int _additional; + int _limit; + int _additional; }; + // ======================================== // PER BUFFER UNREAD BACKLOG REQUESTER // ======================================== -class PerBufferUnreadBacklogRequester : public BacklogRequester { +class PerBufferUnreadBacklogRequester : public BacklogRequester +{ public: - PerBufferUnreadBacklogRequester(ClientBacklogManager *backlogManager); - virtual void requestBacklog(const BufferIdList &bufferIds); + PerBufferUnreadBacklogRequester(ClientBacklogManager *backlogManager); + virtual void requestBacklog(const BufferIdList &bufferIds); private: - int _limit; - int _additional; + int _limit; + int _additional; }; + #endif //BACKLOGREQUESTER_H