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=b2e346fbccd915bb1ec9a90d747447a65a1db2b0;hp=420ef5d1eb3b50e260d8f2ebb73f40f984347b77;hb=c1cf157116de7fc3da96203aa6f03c38c7ebb650;hpb=30b159cb876a9495de42e9a3e70ca050516f0805 diff --git a/src/client/backlogrequester.h b/src/client/backlogrequester.h index 420ef5d1..b2e346fb 100644 --- a/src/client/backlogrequester.h +++ b/src/client/backlogrequester.h @@ -33,37 +33,38 @@ class ClientBacklogManager; class BacklogRequester { public: - enum RequesterType { + enum RequesterType + { InvalidRequester = 0, PerBufferFixed, PerBufferUnread, GlobalUnread }; - BacklogRequester(bool buffering, RequesterType requesterType, ClientBacklogManager *backlogManger); + BacklogRequester(bool buffering, RequesterType requesterType, ClientBacklogManager* backlogManger); virtual ~BacklogRequester() = default; inline bool isBuffering() { return _isBuffering; } inline RequesterType type() { return _requesterType; } - inline const QList &bufferedMessages() { return _bufferedMessages; } + inline const QList& bufferedMessages() { return _bufferedMessages; } 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 void requestBacklog(const BufferIdList& bufferIds) = 0; virtual inline void requestInitialBacklog() { requestBacklog(allBufferIds()); } virtual void flushBuffer(); protected: BufferIdList allBufferIds() const; - inline void setWaitingBuffers(const QList &buffers) { setWaitingBuffers(buffers.toSet()); } - void setWaitingBuffers(const QSet &buffers); + 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; @@ -73,50 +74,46 @@ private: QSet _buffersWaiting; }; - // ======================================== // FIXED BACKLOG REQUESTER // ======================================== class FixedBacklogRequester : public BacklogRequester { public: - FixedBacklogRequester(ClientBacklogManager *backlogManager); - void requestBacklog(const BufferIdList &bufferIds) override; + FixedBacklogRequester(ClientBacklogManager* backlogManager); + void requestBacklog(const BufferIdList& bufferIds) override; private: int _backlogCount; }; - // ======================================== // GLOBAL UNREAD BACKLOG REQUESTER // ======================================== class GlobalUnreadBacklogRequester : public BacklogRequester { public: - GlobalUnreadBacklogRequester(ClientBacklogManager *backlogManager); + GlobalUnreadBacklogRequester(ClientBacklogManager* backlogManager); void requestInitialBacklog() override; - void requestBacklog(const BufferIdList &) override {} + void requestBacklog(const BufferIdList&) override {} private: int _limit; int _additional; }; - // ======================================== // PER BUFFER UNREAD BACKLOG REQUESTER // ======================================== class PerBufferUnreadBacklogRequester : public BacklogRequester { public: - PerBufferUnreadBacklogRequester(ClientBacklogManager *backlogManager); - void requestBacklog(const BufferIdList &bufferIds) override; + PerBufferUnreadBacklogRequester(ClientBacklogManager* backlogManager); + void requestBacklog(const BufferIdList& bufferIds) override; private: int _limit; int _additional; }; - -#endif //BACKLOGREQUESTER_H +#endif // BACKLOGREQUESTER_H