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();


        int seek(UINT64 pos);

        //      /**
        //       * Get the current file position
        //       * @return
        //       */
        //              size_t getFilePosition();

private:
        UINT64 getFPosFromTime(UINT64 timeVal);


        static void * threadHandler(void* arg);


        void bufferWriter();

private:

        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;
};

#endif /* CFILEREADER_H_ */