VFS_datastore.h

Go to the documentation of this file.

#ifndef VFS_DATASTORE_H
#define VFS_DATASTORE_H
 
#include <QCache>
#include <QBasicTimer>
#include <QJsonDocument>
#include <QJsonObject>
#include <QJsonArray>
 
#include "VFS_base/VFS_node.h"
 
class VFS_datastore_cache_entry : public QObject
{
        Q_OBJECT
 
        public:
                explicit VFS_datastore_cache_entry(bool debug, int flushInterval, int expireInterval, bool raw=false);
                virtual ~VFS_datastore_cache_entry();
 
                virtual void            setData(QJsonObject json);
                virtual QJsonDocument   getData();
 
                virtual void            setData(QByteArray data);
                virtual QByteArray      getRawData();
 
                QString                 _key;                   
 
                quint64                 size();
                virtual bool            valid(QString &reason);
 
        protected:
                QJsonDocument           _data;                  
                QByteArray              _rawData;               
                quint64                 _size;                  
                bool                    _raw;                   
                bool                    _dirty;                 
                bool                    _valid;                 
                QString                 _reason;                
                bool                    _debug;                 
 
                int                     _flushID;               
                int                     _flushInterval;         
                int                     _expireID;              
                int                     _expireInterval;        
                QBasicTimer             _expireTimer;           
 
        //pure virtual
                virtual void            flush() = 0;            
                virtual void            touch();
 
        public slots:
                virtual void            timerEvent(QTimerEvent *e);
 
        signals:
                void expired(VFS_datastore_cache_entry *);      
                void touched();                                 
};
 
//FIXME: multiple inheritance is bad! should be a HasA instead of IsA
class VFS_datastore_cache : public QObject, public QCache<QString, VFS_datastore_cache_entry>
{
        Q_OBJECT
 
        public:
                explicit VFS_datastore_cache(quint64 size);
                virtual ~VFS_datastore_cache();
 
                //virtual VFS_datastore_cache_entry *createEntry(QString p);
                //VFS_datastore_cache_entry *operator [](QString p);
 
                bool insert(const QString &key, VFS_datastore_cache_entry *object);
 
                //static const quint64 DEFAULT_DATACACHE_SIZE = 8000000;        //!< The default size to create a cache.  Defaults to ~8mb.
                static const quint64 DEFAULT_DATACACHE_SIZE = 104857600;        
                //static const int DATACACHE_PRUNE_INTERVAL = 60000;            //1 minute
 
        private slots:
                void expired(VFS_datastore_cache_entry *);
                void touched();
};
 
 
class VFS_datastore : public VFS_node
{
        Q_OBJECT
 
        public:
                explicit VFS_datastore(quint64 size, bool debug=false);
                virtual ~VFS_datastore();
 
                virtual VFS_node *find(VFS_request *r);
                virtual bool isContainer();
 
                virtual QString reportDetails();
 
                static QJsonObject applyJsonDiff(QJsonObject obj, QJsonObject diff, QString trace="", QString user="server");
                static QString applyDeltaDiff(QString data, QJsonObject delta, QString trace="", QString user="server");
 
        protected:
                VFS_datastore_cache _cache;                     
                bool _debug;                                    
 
                //virtual void ls(VFS_request *r);
                //virtual void read(VFS_request *r);
                //virtual void write(VFS_request *r);
                //virtual void metadata(VFS_request *r);
                //virtual void report(VFS_request *r);
                //virtual void submit(VFS_request *r);
                //virtual void rm(VFS_request *r);
                //virtual void requestLock(VFS_request *r);
                //virtual void releaseLock(VFS_request *r);
                //virtual void aclDefaults(VFS_request *r);
 
        private:
 
        signals:
 
        public slots:
};
 
#endif // VFS_DATASTORE_H