loggerFileReader.h

Go to the documentation of this file.

/******************************************************************************
** Copyright (c) 1992-2010 VT MAK
** All rights reserved.
******************************************************************************/


#ifndef loggerFileReader_H_
#define loggerFileReader_H_

#include <lgrCore/lgrCore.h>

#include "lgrFileInput.h"
#include <lgrUtil/filePosition.h>
#include <lgrUtil/memoryBuffer.h>
#include <lgrUtil/virtualConstructor.h>

namespace MAKLogger
{
   class DtLoggerFile;
   class DtMessageIOInfo;
   class DtLoggerPlaybackFile;

   class DT_DLL_LGRCORE DtLoggerFileReader :  public DtLgrFileInput
   {

   public:

      DT_VIRTUAL_CTR(DtLoggerFileReader, (DtMessageIOInfo* info,DtLoggerPlaybackFile* file))

      
      virtual ~DtLoggerFileReader();
   
   private:
      DtLoggerFileReader(const DtLoggerFileReader&);
      DtLoggerFileReader& operator=(const DtLoggerFileReader&);
   public:

      virtual const DtLoggerPlaybackFile* playbackFile() const;

      virtual void setReadBufferSize(size_t);

      virtual size_t getReadBufferSize() const;


      virtual void activate();
      virtual void deactivate();

      virtual void getNextMessages(DtMessageBuffer&);
      virtual void dropNextMessages();

      virtual const DtMessageIOInfo* info() const;



      virtual double peekCurrentPacketTime();

      virtual int peekCurrentPacketType();

      virtual size_t peekCurrentPacketSize();

      virtual bool recoverLastPacket();

      virtual bool isCheckpointNecessary(DtAbsoluteTime currentTime,
         DtAbsoluteTime newTime);

      virtual void seekToPreviousCheckpoint(DtAbsoluteTime timeToJumpBefore);

      virtual void seekToNextCheckpoint(DtAbsoluteTime currentTime);

      virtual const DtString& filename() const;

      virtual DtFilePosition fileSize() const;  

      virtual DtFilePosition currentPosition() const;      

      virtual DtAbsoluteTime firstMessageTime() const;

      virtual DtAbsoluteTime lastMessageTime() const;

      virtual DtRelativeTime duration() const;

      virtual DtString description() const;

      virtual DtAbsoluteTime lastReadTime() const;

      virtual DtLgrEntityTracker* entityTracker() const;

      virtual bool testFileExpanding(bool updateLastTime=true);


   protected:

      DtLoggerPlaybackFile* myCurrentFile;
      DtAbsoluteTime myLastTimeRead;
      DtAbsoluteTime myLastTime;
      DtAbsoluteTime myFirstTime;
      size_t myBufferSize;
      DtMessageIOInfo* myMessageInfo;
      DtMemoryBufferSP myMemory;
   };
}

#endif