PaceventsWriter.h

Go to the documentation of this file.

//
// C++ Interface: PaceventsWriter
//
// Description:
//
//
// Author: Matthias Nagl <mnagl@uni-goettingen.de>, (C) 2009
//
// Copyright: See COPYING file that comes with this distribution
//
//
#ifndef PACEVENTSWRITER_H
#define PACEVENTSWRITER_H

#include <QtCore/QtGlobal>
#include <QObject>
#include <QDateTime>
#include <QHash>
#include <QMap>
#include "pacDataTypes.h"

#if defined(PACEVENTSWRITER_LIBRARY)
#  define PACEVENTSWRITER_EXPORT Q_DECL_EXPORT
#else
#  define PACEVENTSWRITER_EXPORT Q_DECL_IMPORT
#endif

class QFile;
class QtIOCompressor;

class PACEVENTSWRITER_EXPORT PaceventsWriter : public QObject
{
    Q_OBJECT
  public:


    PaceventsWriter(QObject *parent = 0);
    PaceventsWriter(QFile *file, QObject *parent = 0);
    ~PaceventsWriter();

    void useFile(QFile *file);
    void finalize();


    void setCompressionLevel(quint8 level);
    void setEventsPerChunk(quint64 events);
    void setStartOfMeasurement(const QDateTime &starttime);
    void setStopOfMeasurement(const QDateTime &stoptime);
    void setColumnContents(const QList<Pac::DataFileColumns> &colcontents);
    void setColumnTypes(const QList<Pac::DataFileColumType> &coltypes);
    void setNodeIds(const QList<quint8> &nodeids);
    void setNodeIdsToPhi(const QHash<quint8, float> &phi);
    void setNodeIdsToTheta(const QHash<quint8, float> &theta);
    void setSetupTree(const QMap<QString, QString> &setuptree);
    void setFlags(Pac::DataFileFlags  flags);
    void setFinalComment(const QString &comment);


    void writeEvent(const QByteArray &data);

  signals:
    void newChunkStarted();

  private:
    void writeHeader();
    static const quint32 version = 3;
    QFile * file;
    quint8 compressionlevel;
    quint64 eventsperchunk;
    QDateTime start, stop;
    QList<Pac::DataFileColumns> colcontents;
    QList<Pac::DataFileColumType> coltypes;
    QList<quint8> nodeids;
    QHash<quint8, float> phi, theta;
    QMap<QString, QString> setuptree;
    Pac::DataFileFlags flags;
    QString comment;

    quint64 stoptimepos, numrecordspos, flagspos;
    quint64 lastforwardpointer;
    bool writingrecords;
    QtIOCompressor *compress;
    quint64 numrecords;
};

#endif