lgrHlaAggregatePublisher.h

Go to the documentation of this file.

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


#ifndef lgrHlaAggregatePublisher_H_
#define lgrHlaAggregatePublisher_H_

#if DtHLA

#include <lgrUtil/virtualConstructor.h>

#include "lgrPublisherInterface.h"
#include <vl/rtiCompatibility.h>
#include <vl/aggregatePublisherHLA.h>

class DtBaseEntityStateRepository;
class DtDeadReckoner;

namespace MAKLogger
{

   class DtLgrHlaSimulationManager;

   class DT_DLL_LGRSIM DtLgrHlaAggregatePublisher : public DtAggregatePublisher,
      public DtLgrPublisherInterface
   {
   public:

      DT_VIRTUAL_CTR_DEFAULTS(DtLgrHlaAggregatePublisher,
                              (DtLgrHlaSimulationManager& simMgr, RTI::ObjectClassHandle classHandle,
                               const char* objName, const DtDDMRegionSet* regionSetToUse,
                               double hbtime, bool waitForRegionData, bool stat),
                              (DtLgrHlaSimulationManager& simMgr, RTI::ObjectClassHandle classHandle,
                               const char* objName, const DtDDMRegionSet* regionSetToUse,
                               double hbtime=0.0, bool waitForRegionData=false, bool stat=true))

      
      virtual ~DtLgrHlaAggregatePublisher();

      virtual void update(const DtStateMsg& msg, double scaling, bool isStatic);

      virtual DtObjectPublisher* objPublisher();

      virtual void tick(double scale, bool isStatic);

      virtual void sendUpdateAtScaleChangePoint(double oldScale, double newScale, bool wasStatic, bool isStatic);

      bool sendAllNextTick();

      void setSendAllNextTick(bool yesNo = true);

      virtual void setRegion(const DtDDMRegionSet& region);

      virtual const DtDDMRegionSet& publishingRegions() const;

      virtual bool publishingToRegion( DtDDMRegionSP region );

      virtual void setPauseUpdateAttributes(double &scale);

   protected:
      virtual void sendRequestedAttrs(double scale, bool isStatic);

      virtual void sendTheseAttrs(const RTI::AttributeHandleSet& attrs, double scale, bool isStatic);

      virtual void send(DtStateMsg& msg);

      DtLgrHlaAggregatePublisher(const DtLgrHlaAggregatePublisher &other);

      DtLgrHlaAggregatePublisher &operator=(const DtLgrHlaAggregatePublisher &other);

   protected:

      DtLgrHlaSimulationManager& mySimMgr;

      bool mySendAllNextTick;

      RTI::AttributeHandleSet* myAttrsToSend;

      DtBaseEntityStateRepository* mySeenByAttrs;

      DtDeadReckoner* myDeadReckoner;

      double myLastScaling;
      
      // Frozen state saved when scale goes to 0 (i.e. paused)
      // and is restored when unpaused.
      bool myFrozenBeforePause;
      //Flag to set when the next message is a "pause" update
      bool mySendingPauseUpdate;

      double myHeartbeatInterval;
      double myLastHeartbeatTime;

      DtDeadReckoner* myOldDeadReckoner;
      DtDeadReckonTypes myOldDRType;
      bool myDRTypeChanged;

      DtVector32 myOrigVelocity;
      DtVector32 myOrigAcceleration;
      DtVector32 myOrigRotVel;
      DtTaitBryan myOrigOrientation;
      DtVector myOrigLocation;
      DtTime myOrigTime;
   };


}

#endif   

#endif