DtMessageStream.h

Go to the documentation of this file.

/******************************************************************************
** Copyright (c) 2017 MAK Technologies, Inc.
** All rights reserved.
******************************************************************************/
/******************************************************************************
** $RCSfile: DtMessageStream.h,v $ $Revision: 1.11 $ $State: Exp $
******************************************************************************/


#pragma once

#include <vrvUtil/vrvUtil.h>
#include <vrvUtil/DtMessage.h>

#include <vector>

namespace makVrv
{
   class DT_DLL_VRVUTIL DtMessageStream
   {
   public:
      typedef std::vector<DtMessage*> MessageList;

      typedef unsigned char Byte;
      typedef std::vector<Byte> ByteBuffer;

      //The message stream will be reset should not get larger than 5 MB.
      static const size_t theMaxPersistentStreamSize = 0x500000;

      DtMessageStream(size_t initialReserve = 0xFFF);

      ~DtMessageStream();

      void clearStream();


      void writeMessageToStream(DtMessage* message);

      void writeMessagesToStream(MessageList& messages );


      Byte* streamData() const;

      size_t streamDataSize() const;    

      void addDataToStream(char* data,size_t size);    

      Byte* addSpaceToStream(size_t size);

      void trimEnd(size_t n);

      int readMessagesFromStream( MessageList& messages);

   protected:
      ByteBuffer myMessageBuffer;
   };
}