include/sp605/Iterator.h (r4864/r3204)

Go to the documentation of this file.

#ifndef SP605_ITERATOR_H
#define SP605_ITERATOR_H

#include "sp605/Message.h"

#include "roc/Message.h"

namespace sp605 {

   class Board;

   class Iterator {
      protected:

         enum IteratorMessageKind { kindNone, kindRoc, kindSpadic };

         enum { MaxGroupId = 2, MaxSpadicId = 4 };

         sp605::Board*  fBoard;      

         int            fFormat;     

         void*          fBuffer;     
         unsigned       fBufferLen;  
         unsigned       fBufferPos;  

         void*          fInterm;     
         unsigned       fIntermSize; 
         unsigned       fIntermFill; 

         unsigned       fSP605Id;    

         IteratorMessageKind fKind; 

         sp605::Message fMsg;        
         unsigned       fLastEpoch[MaxSpadicId][MaxGroupId];  
         unsigned       fLastSenderId; 
         unsigned       fSpadicId;  

         roc::Message   fRocMsg;     
         unsigned       fLastRocEpoch; 

         void           allocateInterm();

      public:
         Iterator(int fmt = formatSpadic10Optic);
         ~Iterator();

         void setFormat(int fmt) { fFormat = fmt; }
         int getFormat() const { return fFormat; }

         void setBoardId(unsigned id) { fSP605Id = id; }
         void resetBoardId() { fSP605Id = 0xffffffff; }
         bool isBoardId() const { return fSP605Id != 0xffffffff; }
         unsigned getBoardId() const { return isBoardId() ? fSP605Id : 0; }

         bool assign(void* buf, unsigned sz);

         bool nextBuffer(sp605::Board* brd, double tmout = 1.);

         bool next(double tmout=1.);

         bool at_the_end() const { return fBufferPos>=fBufferLen; }


         bool isSpadicMsg() const { return fKind == kindSpadic; }
         sp605::Message& msg() { return fMsg; }

         void setSpadicId(unsigned id) { fSpadicId = id; }
         unsigned getSpadicId() const { return fSpadicId; }


         bool isRocMsg() const { return fKind == kindRoc; }
         roc::Message& rocmsg() { return fRocMsg; }

         uint64_t getMsgFullTime() const;
         double getMsgFullTimeD() const;

         void printMessage();

   };
}

#endif