x3c/include/packetReader/CPacketBuffer.h

/*
 * CPacketBuffer.h
 *
 *      Description:    this file defines the class of packet buffer.
 *  Created on:         Nov 18, 2011
 *      Author:         mtaveniku
 *
 */

#ifndef CPACKETBUFFER_H_
#define CPACKETBUFFER_H_

#include <stddef.h>
#include <semaphore.h>
#include <unistd.h>
#include <vector>
using namespace std;

//#include "X3cPacketTypes.h"
#include "X3cPacket.h"

class CPacketBuffer {
public:


        CPacketBuffer();


        virtual ~CPacketBuffer();


        bool initialize(size_t bufSz);


        bool isOkToWrite(size_t nByte, bool isBlock);


        char *getWrPtr();


        void addBytesWritten(size_t nBytes);


        void setEOF();


        bool hasEOF();


        size_t getFreeBytes();


        size_t getValidBytes();


        X3cPacket *getPacket();


        char *getBytes(size_t nbytes);


        void freeBytes(char *ptr, size_t nBytes);

        void reset();

        void waitForRead();

        void waitForWrite();


private:


        void *allocSharedMemory(size_t bufSz);

        void *mShmSeg1;

        void *mShmSeg2;

        int   mShmId;

        size_t mBufSz;

        char *mPhyStart;

        size_t mWrIdx;

        size_t mRdIdx;

        size_t mFreeIdx;

        bool mIsOk;

        bool mIsEOF;

        unsigned long long mBytesWritten;

        unsigned long long mBytesRead;

        bool mIsFull;

        bool mWriterIsWaiting;

        sem_t mWrSem;

        bool mReaderIsWaiting;

        sem_t mRdSem;

        const static unsigned mRdWTo = 2;

        const static unsigned mWrWTo = 2;

        vector<int> mBadShrBuf;
        vector<void*> mAreas;
};

#endif /* CPACKETBUFFER_H_ */