X-Git-Url: https://git.quassel-irc.org/?p=quassel.git;a=blobdiff_plain;f=src%2Fclient%2Fclientbacklogmanager.h;h=83497aecc388474dd42573b333798fb7746b169b;hp=400edcbab7c578b5e9d0c1be63158ae9a80b869a;hb=0a43227b8cd44625f4881cc1545d42c8c8a4876c;hpb=bcd6ecbc69fba90189c16e84e74488b2817d0700 diff --git a/src/client/clientbacklogmanager.h b/src/client/clientbacklogmanager.h index 400edcba..83497aec 100644 --- a/src/client/clientbacklogmanager.h +++ b/src/client/clientbacklogmanager.h @@ -1,5 +1,5 @@ /*************************************************************************** - * Copyright (C) 2005-08 by the Quassel IRC Team * + * Copyright (C) 2005-2016 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 CLIENTBACKLOGMANAGER_H @@ -26,35 +26,53 @@ class BacklogRequester; -class ClientBacklogManager : public BacklogManager { - Q_OBJECT +class ClientBacklogManager : public BacklogManager +{ + SYNCABLE_OBJECT + Q_OBJECT public: - ClientBacklogManager(QObject *parent = 0); + ClientBacklogManager(QObject *parent = 0); - virtual const QMetaObject *syncMetaObject() const { return &BacklogManager::staticMetaObject; } + // helper for the backlogRequester, as it isn't a QObject and can't emit itself + inline void emitMessagesRequested(const QString &msg) const { emit messagesRequested(msg); } - // helper for the backlogRequester, as it isn't a QObject and can't emit itself - inline void emitMessagesRequested(const QString &msg) const { emit messagesRequested(msg); } - - void reset(); + void reset(); public slots: - virtual void receiveBacklog(BufferId bufferId, int lastMsgs, int offset, QVariantList msgs); - void requestInitialBacklog(); + virtual QVariantList requestBacklog(BufferId bufferId, MsgId first = -1, MsgId last = -1, int limit = -1, int additional = 0); + virtual void receiveBacklog(BufferId bufferId, MsgId first, MsgId last, int limit, int additional, QVariantList msgs); + virtual void receiveBacklogAll(MsgId first, MsgId last, int limit, int additional, QVariantList msgs); + + void requestInitialBacklog(); + + void checkForBacklog(BufferId bufferId); + void checkForBacklog(const BufferIdList &bufferIds); signals: - void messagesReceived(BufferId bufferId, int count) const; - void messagesRequested(const QString &) const; - void messagesProcessed(const QString &) const; + void messagesReceived(BufferId bufferId, int count) const; + void messagesRequested(const QString &) const; + void messagesProcessed(const QString &) const; + + void updateProgress(int, int); private: - bool isBuffering(); - void stopBuffering(); + bool isBuffering(); + BufferIdList filterNewBufferIds(const BufferIdList &bufferIds); - void dispatchMessages(const MessageList &messages, bool sort = false); + void dispatchMessages(const MessageList &messages, bool sort = false); - BacklogRequester *_requester; + BacklogRequester *_requester; + bool _initBacklogRequested; + QSet _buffersRequested; }; + +// inlines +inline void ClientBacklogManager::checkForBacklog(BufferId bufferId) +{ + checkForBacklog(BufferIdList() << bufferId); +} + + #endif // CLIENTBACKLOGMANAGER_H