messageThrottle.h

Go to the documentation of this file.

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


#ifndef DtMessageThrottle_H_
#define DtMessageThrottle_H_

#include "rtiMsConfig.h"
#include <vlutil/vlFedTarget.h> 
#include <vlutil/vlTime.h>
#include <vlutil/vlInetAddr.h>
#include <queue>



class DtConnectionMgr;
class DtRtiMsg;

class DtDelayedMessage
{
protected:
   DtDelayedMessage();

public:

   DtDelayedMessage(DtRtiMsg* msg, MAKRti::DtTransportType transport, MAKRti::DtInetAddr addr);

   ~DtDelayedMessage();

   DtRtiMsg* msg;
   MAKRti::DtTransportType transport;
   MAKRti::DtInetAddr addr;
};

class DT_DLL_LRC DtMessageThrottle
{
protected:
   DtMessageThrottle();

public:

   DtMessageThrottle(float transmitDelay, float transmitRate, float autoProvideDelay );

   virtual ~DtMessageThrottle();

   virtual void activateTransmitDelay();

   virtual bool delayTransmit() const;

   virtual bool queueMessage(DtRtiMsg const& msg, MAKRti::DtTransportType transport,
      MAKRti::DtInetAddr addr);

   virtual bool queueMessage(DtRtiMsg* msg, MAKRti::DtTransportType transport,
      MAKRti::DtInetAddr addr);

   virtual void testTransmitDelay(DtConnectionMgr* connMgr);

   virtual void activateAutoProvideDelay();

   virtual bool delayAutoProvide() const;

   virtual void testAutoProvideDelay(DtConnectionMgr* connMgr);
   
   virtual void processQueuedMessages(DtConnectionMgr* connMgr);

   virtual void flush(DtConnectionMgr* connMgr);

   virtual void clear();

protected:

   MAKRti::DtClock myClock;
   std::queue<DtDelayedMessage*> myMessageQueue;
   MAKRti::DtTime myTransmitTime;
   MAKRti::DtTime myTickTime;
   MAKRti::DtTime myAutoProvideTime;
   float myTransmitDelayInterval;
   float myAutoProvideDelayInterval;
   float myMessageRate;
   unsigned long myMessagePerTick;
   unsigned long myMessagesSent;
   bool myMeterMessages;
   bool myDelayMessages;
   bool myDelayTransmit;
   bool myDelayProvides;
   bool myDelayAutoProvide;
   bool myTransmitTick;
   bool myAutoProvideTick;
};

#endif