x3c/include/packetReader/CFileReader.h

/*
 * CFileReader.h
 *
 *  Created on: Nov 21, 2011
 *      Author: mtaveniku
 *
 *      This file defines class of file reader. A file reader is responsible
 *      for reading data from file to the packet buffer.
 */

#ifndef CFILEREADER_H_
#define CFILEREADER_H_

// C headers
#include <stdio.h>
#include <stdlib.h>
#include <pthread.h>
#include <unistd.h>
#include <string.h>
#include <errno.h>
#include <string>

// Project Headers
#include "X3cPacket.h"
#include "X3cFileBuf.h"
#include "exceptions/IoException.h"
#include "CPacketBuffer.h"


class CFileReader{

public:

        CFileReader(const char * inFileName, CPacketBuffer *pktBuf, 
                size_t chunkSz);


        virtual ~CFileReader();


        void init(UINT64 offset) throw (IoException);

    void initWithTimeFilter(UINT64 timeVal) throw (IoException);


        void start();

        void stop();


    void reset(UINT64 timeVal);

    void resume();

private:
        UINT64 getFPosFromTime(UINT64 timeVal);


        static void * threadHandler(void* arg);


        void bufferWriter();


        CPacketBuffer *mPktBuf;


    std::string mFileName;


        FILE *mFile;


        int mFileNo;


        X3C_HEADER mX3CFileHeader;


        size_t mChunkSz;


        bool mDoRun;


        pthread_t mBufWrThread;


        size_t mFileOffset;

        bool mIsInitialized;

    bool mResetting;

    pthread_mutex_t mResetLock;

    pthread_cond_t  mResetCond;
};

#endif /* CFILEREADER_H_ */