/daten/ahuesgen/projects/vhist/code/vhistlib/include/unvhistlib/validationqueue.h

/* $HEADERS
 $Id: validationqueue.h 2792 2013-05-06 11:25:27Z michael $
 */

#ifndef VALIDATIONQUEUE_INCLUDED
#define VALIDATIONQUEUE_INCLUDED

#include "../shared/misc_defines.h"

#include <QObject>
#include <QString>
#include <QQueue>
#include <QFile>

#include "validator.h"
#include "../shared/stopwatch.h"
#include "../shared/logsource.h"

namespace vhist
{

class VhistParser;
struct FileTag;
struct SectionTag;

enum ValidateeType
{
    VALIDATEE_SECTION,
    VALIDATEE_FILE,
    VALIDATEE_SAVEDFILE
};


struct VHIST_EXTERN Validatee
{
    ValidateeType type;
    int id;
    int start;
    int numBytes;
    int tagPos;
    QByteArray replacementTag;
    QString md5;
    QString cmd5;
    QString name; // file- or sectionname
};


struct VHIST_EXTERN SavedFile
{
    QString filename;
    QString md5;
    int filesize;
};


class VHIST_EXTERN ValidationQueue : public LogSource
{
    Q_OBJECT
    public: // construction, destruction, assignment
        ValidationQueue(VhistParser* parser = NULL, int chunksize = 100000);
        virtual ~ValidationQueue();
        void reset(VhistParser* parser);
        void repopulate(VhistParser* parser);
        void addValidatees(QList<int> files, QList<int> sections);
        void addValidatees(QList<SavedFile> files);
    
    public slots:
        void cancelValidation();
    
    public:
        bool process();
    
    signals:
        void fileProcessed(int id, bool valid);
        void savedFileProcessed(const QString filename, bool valid);
        void sectionProcessed(int id, bool valid);
        void percentFinishedChanged(int, const QString name);
    
    private:
        void reinit(VhistParser* parser);
        void nextEntry();
        Validatee validateeFromFile(const FileTag& tag);
        Validatee validateeFromSection(const SectionTag& tag);
        Validatee validateeFromSavedFile(const SavedFile& file);
    
    private: // member variables
        VhistParser* m_parser;
        Validator m_validator;
        StopWatch m_stopwatch;
        QQueue<Validatee> m_validatees;
        // the number of processed bytes of the current validatee
        int m_bytesHandled;
        // the total number of bytes to handle since the last restart
        qint64 m_totalBytes;
        // the total number of bytes handled since the last restart
        qint64 m_totalHandled;
        QFile m_currentFile;
        int m_chunksize;
};

}

#endif // VALIDATIONQUEUE_INCLUDED