msgBundler.h

Go to the documentation of this file.

/*********************************************************************
** Copyright (c) 2010 MaK Technologies, Inc.
** All rights reserved.
*********************************************************************/
/*********************************************************************
** $RCSfile: msgBundler.h,v $ $Revision: $ $State: Exp $
*********************************************************************/


#pragma once

#include "rtiMsConfig.h"
#include "msgHeaderReader.h"

#include <vlutil/vlMachineTypes.h>
#include <vlutil/vlSmartPointers.h>

#include <vector>


class DT_DLL_RTIUTIL DtMsgBundler
{
public:

   DtMsgBundler(std::shared_ptr<DtMsgHeaderReader> hdrReader, size_t maxBundleSize = 0, size_t byteAlignment = 0);

   virtual ~DtMsgBundler();

   virtual bool addToBundle(char* msg, size_t msgSize);

   virtual bool getBundle(char** bundlePtr, size_t& bundleSize);

   virtual bool isBundled(const char* bufferPtr, size_t size) const;

   virtual bool unbundle(char* bufferPtr, size_t size);

   virtual bool isEmpty();

   virtual bool recvNextMsgFromBundle(char** msgPtr, size_t& msgSize);

   virtual size_t maxSendBundleSize() const;
   virtual void setMaxSendBundleSize(size_t maxSize);

protected:

   std::vector<char> mySendBundlingBuff;

   size_t myCurrSendBundleSize;

   size_t myRemainingRecvBundleSize;

   char* myNextRecvMsg;

   bool myResizeSendBuff;

   size_t myNewSendBuffSize;

   std::shared_ptr<DtMsgHeaderReader> myHeaderReader;

   size_t myMsgAddrByteAlignment;

};