QGCTileCacheWorker.h

Go to the documentation of this file.

#pragma once
 
#include <QtCore/QElapsedTimer>
#include <QtCore/QLoggingCategory>
#include <QtCore/QMutex>
#include <QtCore/QQueue>
#include <QtCore/QString>
#include <QtCore/QThread>
#include <QtCore/QWaitCondition>
 
#include <memory>
 
Q_DECLARE_LOGGING_CATEGORY(QGCTileCacheWorkerLog)
 
class QGCMapTask;
class QGCTileCacheDatabase;
 
class QGCCacheWorker : public QThread
{
    Q_OBJECT
 
public:
    explicit QGCCacheWorker(QObject *parent = nullptr);
    ~QGCCacheWorker();
 
    void setDatabaseFile(const QString &path) { if (isRunning()) { return; } _databasePath = path; }
 
public slots:
    bool enqueueTask(QGCMapTask *task);
    void stop();
 
signals:
    void updateTotals(quint32 totaltiles, quint64 totalsize, quint32 defaulttiles, quint64 defaultsize);
 
protected:
    void run() final;
 
private:
    void _runTask(QGCMapTask *task);
 
    void _saveTile(QGCMapTask *task);
    void _getTile(QGCMapTask *task);
    void _getTileSets(QGCMapTask *task);
    void _createTileSet(QGCMapTask *task);
    void _getTileDownloadList(QGCMapTask *task);
    void _updateTileDownloadState(QGCMapTask *task);
    void _pruneCache(QGCMapTask *task);
    void _deleteTileSet(QGCMapTask *task);
    void _renameTileSet(QGCMapTask *task);
    void _resetCacheDatabase(QGCMapTask *task);
    void _importSets(QGCMapTask *task);
    void _exportSets(QGCMapTask *task);
    bool _testTask(QGCMapTask *task);
    void _emitTotals();
 
    std::unique_ptr<QGCTileCacheDatabase> _database;
    QMutex _taskQueueMutex;
    QQueue<QGCMapTask*> _taskQueue;
    QWaitCondition _waitc;
    QString _databasePath;
    QElapsedTimer _updateTimer;
    int _updateTimeout = kShortTimeoutMs;
    std::atomic_bool _dbValid = false;
    std::atomic_bool _stopRequested = false;
 
    static constexpr int kShortTimeoutMs = 2000;
    static constexpr int kLongTimeoutMs = 5000;
};