QGCTileCacheWorker.h 3.34 KB
Newer Older
1 2 3 4 5 6 7 8
/****************************************************************************
 *
 *   (c) 2009-2016 QGROUNDCONTROL PROJECT <http://www.qgroundcontrol.org>
 *
 * QGroundControl is licensed according to the terms in the file
 * COPYING.md in the root of the source code directory.
 *
 ****************************************************************************/
dogmaphobic's avatar
dogmaphobic committed
9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28


/**
 * @file
 *   @brief Map Tile Cache Worker Thread
 *
 *   @author Gus Grubba <mavlink@grubba.com>
 *
 */

#ifndef QGC_TILE_CACHE_WORKER_H
#define QGC_TILE_CACHE_WORKER_H

#include <QString>
#include <QThread>
#include <QQueue>
#include <QMutex>
#include <QWaitCondition>
#include <QMutexLocker>
#include <QtSql/QSqlDatabase>
29
#include <QHostInfo>
dogmaphobic's avatar
dogmaphobic committed
30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52

#include "QGCLoggingCategory.h"

Q_DECLARE_LOGGING_CATEGORY(QGCTileCacheLog)

class QGCMapTask;
class QGCCachedTileSet;

//-----------------------------------------------------------------------------
class QGCCacheWorker : public QThread
{
    Q_OBJECT
public:
    QGCCacheWorker  ();
    ~QGCCacheWorker ();

    void    quit            ();
    bool    enqueueTask     (QGCMapTask* task);
    void    setDatabaseFile (const QString& path);

protected:
    void    run             ();

53 54 55
private slots:
    void        _lookupReady            (QHostInfo info);

dogmaphobic's avatar
dogmaphobic committed
56 57 58 59 60 61 62 63
private:
    void        _saveTile               (QGCMapTask* mtask);
    void        _getTile                (QGCMapTask* mtask);
    void        _getTileSets            (QGCMapTask* mtask);
    void        _createTileSet          (QGCMapTask* mtask);
    void        _getTileDownloadList    (QGCMapTask* mtask);
    void        _updateTileDownloadState(QGCMapTask* mtask);
    void        _deleteTileSet          (QGCMapTask* mtask);
Gus Grubba's avatar
Gus Grubba committed
64
    void        _renameTileSet          (QGCMapTask* mtask);
dogmaphobic's avatar
dogmaphobic committed
65 66
    void        _resetCacheDatabase     (QGCMapTask* mtask);
    void        _pruneCache             (QGCMapTask* mtask);
67
    void        _exportSets             (QGCMapTask* mtask);
Gus Grubba's avatar
Gus Grubba committed
68
    void        _importSets             (QGCMapTask* mtask);
69
    bool        _testTask               (QGCMapTask* mtask);
70
    void        _testInternet           ();
dogmaphobic's avatar
dogmaphobic committed
71

dogmaphobic's avatar
dogmaphobic committed
72
    quint64     _findTile               (const QString hash);
dogmaphobic's avatar
dogmaphobic committed
73 74 75
    bool        _findTileSetID          (const QString name, quint64& setID);
    void        _updateSetTotals        (QGCCachedTileSet* set);
    bool        _init                   ();
76
    bool        _createDB               (QSqlDatabase *db, bool createDefault = true);
dogmaphobic's avatar
dogmaphobic committed
77 78 79 80 81
    quint64     _getDefaultTileSet      ();
    void        _updateTotals           ();

signals:
    void        updateTotals            (quint32 totaltiles, quint64 totalsize, quint32 defaulttiles, quint64 defaultsize);
82
    void        internetStatus          (bool active);
dogmaphobic's avatar
dogmaphobic committed
83 84 85 86 87 88 89 90 91 92 93 94 95 96 97 98 99

private:
    QQueue<QGCMapTask*>     _taskQueue;
    QMutex                  _mutex;
    QMutex                  _waitmutex;
    QWaitCondition          _waitc;
    QString                 _databasePath;
    QSqlDatabase*           _db;
    bool                    _valid;
    bool                    _failed;
    quint64                 _defaultSet;
    quint64                 _totalSize;
    quint32                 _totalCount;
    quint64                 _defaultSize;
    quint32                 _defaultCount;
    time_t                  _lastUpdate;
    int                     _updateTimeout;
100
    int                     _hostLookupID;
dogmaphobic's avatar
dogmaphobic committed
101 102 103
};

#endif // QGC_TILE_CACHE_WORKER_H