hlaSimInput.h

Go to the documentation of this file.

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


#ifndef hlaSimInput_H_
#define hlaSimInput_H_

#if DtHLA

#include "lgrSim.h"
#include "lgrSimInput.h"
#include "lgrHlaAttribute.h"
#include "hlaMessageFactory.h"

#include <vl/rtiNamespace.h>
#include <vl/rtiCompatibility.h>

#include <list>
#include <map>

class DtHlaObject;
class DtInteraction;
class DtStateMsg;
class DtBaseEntityStateRepository;

namespace MAKLogger
{
   class DtLgrHlaSimulationManager;
   class DtMessageBuffer;
   class DtLgrHlaMessageIOInfo;

   class DT_DLL_LGRSIM DtLgrHlaSimInput : public DtLgrSimInput
   {
   public:

      DT_VIRTUAL_CTR(DtLgrHlaSimInput, (DtLgrHlaSimulationManager& manager))

      virtual ~DtLgrHlaSimInput();

      virtual void activateImplementation();
      virtual void deactivateImplementation();

      virtual void disconnecting();

      virtual const DtMessageIOInfo* info() const;

      virtual DtAbsoluteTime inputTime() const;

      virtual void tick();

      static void decodeIsPartOf_RPR_20014( DtBaseEntityStateRepository* stateRep,
         const RTI::AttributeHandleValuePairSet& attrs,
         int pairSetIndex );

   protected:

      static void discoverObjCb(DtHlaObject* object,void* usr);
      virtual void discoverObject(DtHlaObject* object);

      static void receiveInterCb( DtInteraction* inter, void* usr );
      virtual void receiveInteraction(const DtInteraction * interaction);

      virtual int getInteractionRegionSet(const DtInteraction *interaction, DtRegionDescSet& regionSet);

      static void reflectCb(const DtStateMsg& msg, DtHlaObject* obj, void* usr );
      virtual void reflect(const DtStateMsg& msg, DtHlaObject* obj);

      virtual int getObjectRegionSet(DtRegionDescSet& regionSet);

      static void removeObjCb(DtHlaObject* object,void* usr);
      virtual void removeObject(DtHlaObject* object);

      virtual void startListening();
      virtual void stopListening();

#if DtHLA_1516
      typedef std::map<RTI::ObjectInstanceHandle,DtLgrHlaHandle> ObjectInstanceMap;
#else
      typedef std::map<RTI::ObjectHandle,DtLgrHlaHandle> ObjectInstanceMap;
#endif

      DtLgrHlaSimulationManager& myHlaManager;

      std::map<DtHlaObject*, DtAbsoluteTime> myTimeoutTimeMap;

      ObjectInstanceMap myObjectInstanceMap;
      DtLgrHlaHandle myFreeInstanceHandle;

      bool myCurrentlyListeningFlag;

      DtLgrHlaMessageIOInfo* myInfo;
   };

}

#endif
#endif