aboutsummaryrefslogtreecommitdiff
path: root/lib/connection.h
diff options
context:
space:
mode:
authorAlexey Andreyev <aa13q@ya.ru>2019-02-04 11:58:43 +0300
committerAlexey Andreyev <aa13q@ya.ru>2019-02-05 13:59:49 +0300
commitbf6cd3d29052f9e79fee29c6a6646d95271a196a (patch)
treea2cfed8c2815fd1a2098effc2ea64847324e49b9 /lib/connection.h
parent22dd5f1e8988b03a691487cdad164a82a36e7f8c (diff)
downloadlibquotient-bf6cd3d29052f9e79fee29c6a6646d95271a196a.tar.gz
libquotient-bf6cd3d29052f9e79fee29c6a6646d95271a196a.zip
Connection: simplified sync loop logic without delays
Signed-off-by: Alexey Andreyev <aa13q@ya.ru>
Diffstat (limited to 'lib/connection.h')
-rw-r--r--lib/connection.h26
1 files changed, 1 insertions, 25 deletions
diff --git a/lib/connection.h b/lib/connection.h
index ee7ad243..c9ca3580 100644
--- a/lib/connection.h
+++ b/lib/connection.h
@@ -26,7 +26,6 @@
#include <QtCore/QObject>
#include <QtCore/QUrl>
#include <QtCore/QSize>
-#include <QElapsedTimer>
#include <functional>
#include <memory>
@@ -106,8 +105,6 @@ namespace QMatrixClient
Q_PROPERTY(QUrl homeserver READ homeserver WRITE setHomeserver NOTIFY homeserverChanged)
Q_PROPERTY(bool cacheState READ cacheState WRITE setCacheState NOTIFY cacheStateChanged)
Q_PROPERTY(bool lazyLoading READ lazyLoading WRITE setLazyLoading NOTIFY lazyLoadingChanged)
- Q_PROPERTY(qint64 minSyncLoopDelayMs READ minSyncLoopDelayMs WRITE setMinSyncDelayMs NOTIFY minSyncDelayMsChanged)
- Q_PROPERTY(uint syncLoopAttemptNumber READ syncLoopAttemptNumber NOTIFY syncAttemptNumberChanged)
public:
// Room ids, rather than room pointers, are used in the direct chat
@@ -356,11 +353,6 @@ namespace QMatrixClient
template <typename T>
static void setUserType() { setUserFactory(defaultUserFactory<T>()); }
- qint64 minSyncLoopDelayMs() const;
- void setMinSyncDelayMs(qint64 minSyncLoopDelayMs);
-
- uint syncLoopAttemptNumber() const;
-
public slots:
/** Set the homeserver base URL */
void setHomeserver(const QUrl& baseUrl);
@@ -379,13 +371,6 @@ namespace QMatrixClient
void logout();
void sync(int timeout = -1);
-
- /** Start sync loop with the minSyncLoopDelayMs value
- where minSyncLoopDelayMs could be changed on the client
- according to syncDone/syncError signals and
- the syncLoopAttemptNumber counter.
- The syncLoopAttemptNumber counter is resetting
- after non-repeating syncDone/syncError events*/
void syncLoop(int timeout = -1);
void stopSync();
@@ -662,8 +647,6 @@ namespace QMatrixClient
void cacheStateChanged();
void lazyLoadingChanged();
void turnServersChanged(const QJsonObject& servers);
- void minSyncDelayMsChanged(qint64 minSyncLoopDelayMs);
- void syncAttemptNumberChanged(uint syncLoopAttemptNumber);
protected:
/**
@@ -699,9 +682,7 @@ namespace QMatrixClient
void onSyncSuccess(SyncData &&data, bool fromCache = false);
protected slots:
- void getNewEvents();
- void getNewEventsOnSyncDone();
- void getNewEventsOnSyncError();
+ void syncLoopIteration();
private:
class Private;
@@ -727,12 +708,7 @@ namespace QMatrixClient
static room_factory_t _roomFactory;
static user_factory_t _userFactory;
- QElapsedTimer _syncLoopElapsedTimer;
int _syncLoopTimeout = -1;
- qint64 _minSyncLoopDelayMs = 0;
- void syncLoopIteration();
- uint _syncLoopAttemptNumber = 0;
- bool _prevSyncLoopIterationDone = false;
};
} // namespace QMatrixClient
Q_DECLARE_METATYPE(QMatrixClient::Connection*)