FileStorageWatcher.h

Go to the documentation of this file.

//
// This file is part of the Marble Virtual Globe.
//
// This program is free software licensed under the GNU LGPL. You can
// find a copy of this license in LICENSE.txt in the top directory of
// the source code.
//
// Copyright 2009      Bastian Holst <bastianholst@gmx.de>
//

#ifndef MARBLE_FILESTORAGEWATCHER_H
#define MARBLE_FILESTORAGEWATCHER_H

#include <QThread>
#include <QMutex>
#include <QSet>

namespace Marble
{
    
// Lives inside the new Thread
class FileStorageWatcherThread : public QObject
{
    Q_OBJECT
    
    public:
    explicit FileStorageWatcherThread( const QString &dataDirectory, QObject * parent = 0 );
    
    ~FileStorageWatcherThread();
    
    quint64 cacheLimit();
    
    Q_SIGNALS:
    void variableChanged();
    
    public Q_SLOTS:
    void setCacheLimit( quint64 bytes );
    
    void addToCurrentSize( qint64 bytes );
    
    void resetCurrentSize();
    
    void updateTheme( const QString &mapTheme );
    
    void prepareQuit();
    
    void getCurrentCacheSize();

    private Q_SLOTS:
    void ensureCacheSize();
    
    private:
    Q_DISABLE_COPY( FileStorageWatcherThread )
    
    
    void ensureSizePerPlanet( const QString &planetDirectory, const QString &currentTheme = QString() );
    
    void ensureSizePerTheme( const QString &themeDirectory );
    
    bool keepDeleting() const;
    
    QString m_dataDirectory;
    
        quint64 m_cacheLimit;
    quint64 m_cacheSoftLimit;
        quint64 m_currentCacheSize;
    int     m_filesDeleted;
    bool    m_deleting;
    QString m_mapThemeId;
    QMutex  m_limitMutex;
    QMutex  m_themeMutex;
    bool    m_willQuit;
};


// Lives inside main thread
class FileStorageWatcher : public QThread
{
    Q_OBJECT
    
    public:
    explicit FileStorageWatcher( const QString &dataDirectory = QString(), QObject * parent = 0 );
    
    ~FileStorageWatcher();
    
    quint64 cacheLimit();
    
    public Q_SLOTS:
    void setCacheLimit( quint64 bytes );
    
    void addToCurrentSize( qint64 bytes );
    
    void resetCurrentSize();
    
    void updateTheme( const QString &mapTheme );
    
    Q_SIGNALS:
    void sizeChanged( qint64 bytes );
    void cleared();
    
    protected:
    void run();
    
    private:
    Q_DISABLE_COPY( FileStorageWatcher )
    
    QString m_dataDirectory;
    FileStorageWatcherThread *m_thread;
    QMutex *m_themeLimitMutex;
    QString m_theme;
    quint64 m_limit;
    bool m_started;
    bool m_quitting;
};

}

#endif