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

/* $HEADERS
 $Id: extractionqueue.h 2791 2013-05-06 11:24:28Z michael $
 */

#ifndef EXTRACTIONQUEUE_INCLUDED
#define EXTRACTIONQUEUE_INCLUDED

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

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

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

namespace vhist
{

class VhistParser;
struct FileTag;

struct VHIST_EXTERN Extractee
{
    int id;
    int start;
    int numBytes;
    QString md5;
    QString cmd5;
    QString fullpath;
};


class VHIST_EXTERN ExtractionQueue : public LogSource
{
    Q_OBJECT
    public: // construction, destruction, assignment
        ExtractionQueue(VhistParser* parser = NULL);
        virtual ~ExtractionQueue();
        void reset(VhistParser* parser);
        void addExtractees(QHash<int, QString> files);
    
    public slots:
        void cancelExtraction();
    
    public:
        bool process();
    
    signals:
        void fileProcessed(int id, bool valid);
        void percentFinishedChanged(int percent, const QString filename);
    
    private:
        void reinit(VhistParser* parser);
        void nextEntry();
        Extractee extracteeFromFile(const FileTag& tag);
        bool handleError(const QString& error, const Extractee& e);
    
    private: // member variables
        VhistParser* m_parser;
        Inflater m_inflater;
        StopWatch m_stopwatch;
        QQueue<Extractee> m_extractees;
        QFile m_currentFile;
        // the number of processed bytes of the current extractee
        int m_bytesHandled;
        // the total number of bytes to handle since the last reset
        qint64 m_totalBytes;
        // the total number of bytes handled since the last reset
        qint64 m_totalHandled;
};


} // namespace

#endif // EXTRACTIONQUEUE_INCLUDED