messageInput.h

Go to the documentation of this file.

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


#ifndef messageInput_H_
#define messageInput_H_

#include <lgrCore/lgrCore.h>
#include <lgrCore/messageBuffer.h>

namespace MAKLogger
{
   class DtMessageIOInfo;

   class DT_DLL_LGRCORE DtMessageInput
   {
   protected:
      DtMessageInput();
   private:
      DtMessageInput(const DtMessageInput&);
      DtMessageInput& operator=(const DtMessageInput&);
   public:

      virtual ~DtMessageInput();

      virtual void activate() = 0;

      virtual void deactivate() = 0;

      virtual void startReadMessages(DtAbsoluteTime timeToRead);

      virtual void stopReadMessages();

      virtual DtAbsoluteTime inputTime() const;

      virtual void setStopReadingTimeBoundary(bool inclusive);

      virtual bool stopReadingBoundary() const;

      virtual void getNextMessages(DtMessageBuffer&) = 0;

      virtual void dropNextMessages() = 0;

      virtual const DtMessageIOInfo* info() const = 0;

      virtual void tick();

      virtual void setTimeLimit(double limit);

      virtual void insertPacket(DtPacket* packet);

   protected:

      DtAbsoluteTime myCurrentTime;
      bool myStopReadingBoundary;
      double myTimeLimit;
      // The time of the next packet waiting to be read if known; otherwise, -1.0.
      double myNextPacketTime;

      DtMessageBuffer myInsertBuffer;
   };

}

#endif