X-Git-Url: https://git.quassel-irc.org/?p=quassel.git;a=blobdiff_plain;f=src%2Fclient%2Fbacklogrequester.h;h=7192abac8f5923dbc26650b79e545aeba023d08c;hp=c7c3afe922fbcc34e0a1e47cc4cf9c92c8765c1d;hb=921e54680da16fcf2adb7a90506875aceb6633a4;hpb=29c6d838bafecd697d55b51f72f1813f36b78ae3 diff --git a/src/client/backlogrequester.h b/src/client/backlogrequester.h index c7c3afe9..7192abac 100644 --- a/src/client/backlogrequester.h +++ b/src/client/backlogrequester.h @@ -1,5 +1,5 @@ /*************************************************************************** - * Copyright (C) 2005-09 by the Quassel Project * + * Copyright (C) 2005-2015 by the Quassel Project * * devel@quassel-irc.org * * * * This program is free software; you can redistribute it and/or modify * @@ -15,7 +15,7 @@ * You should have received a copy of the GNU General Public License * * along with this program; if not, write to the * * Free Software Foundation, Inc., * - * 59 Temple Place - Suite 330, Boston, MA 02111-1307, USA. * + * 51 Franklin Street, Fifth Floor, Boston, MA 02110-1301, USA. * ***************************************************************************/ #ifndef BACKLOGREQUESTER_H @@ -30,83 +30,93 @@ class ClientBacklogManager; -class BacklogRequester { +class BacklogRequester +{ public: - enum RequesterType { - InvalidRequester = 0, - PerBufferFixed, - PerBufferUnread, - GlobalUnread - }; - - 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(const BufferIdList &bufferIds) = 0; - virtual inline void requestInitialBacklog() { requestBacklog(allBufferIds()); } + enum RequesterType { + InvalidRequester = 0, + PerBufferFixed, + PerBufferUnread, + GlobalUnread + }; + + 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; } + + 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: - 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