include/vrvVrl/DtEntitySimDataProcessor.h

Go to the documentation of this file.

/******************************************************************************
** Copyright (c) 2009 MAK Technologies, Inc.
** All rights reserved.
******************************************************************************/
/******************************************************************************
** $RCSfile: DtVrlinkEntitySimDataProcessor.h,v $ $Revision: 1.12 $ $State: Exp $
******************************************************************************/


#ifndef DtVrlinkEntitySimDataProcessor_H_
#define DtVrlinkEntitySimDataProcessor_H_

#include <vrvVrl/vrvVrl.h>
#include <vrvCore/DtSimDataProcessorInterface.h>
#include <vrvCore/DtEntityState.h>
#include <vrvCore/DtSimEntryUpdater.h>
#include <vrvUtil/DtBalancedUpdater.h>
#include <vrvUtil/DtSignalConnectionManager.h>

#include <vlutil/vlPerformanceStats.h>

#include <boost/bind.hpp>

#ifndef DT_PROTOCOL_NAMESPACE
#error Namespace Protocol Macro DT_PROTOCOL_NAMESPACE not defined.
#endif

namespace makVrv
{
   class DtEntityStateObjectAgent;
   class DtSimEntryObjectAgent;
   class DtEntityStateListener;

   namespace DT_PROTOCOL_NAMESPACE
   {
      class DtEntityExistenceListener;
      class DtVrlinkEntityStateListener;

      class DL_DLL_IGCONVRLINK DtEntitySimDataProcessor : public DtSimDataProcessorInterface
      {
      public:

         static DtEntitySimDataProcessor* findInstance(DtVrlinkConnection& sim);

         static void registerInstance(DtVrlinkConnection& sim,DtEntitySimDataProcessor*);

         DtEntitySimDataProcessor(DtVrlinkConnection& sim);

         virtual ~DtEntitySimDataProcessor();
         
         void postDrainInput();

         void setObjectUpdateRate(DtUniqueID uniqueId, DtSimEntryUpdater::UpdateRate rate);

         void forceObjectUpdate(DtUniqueID uniqueId);

         void entityDiscovered(DtVrlinkEntityStateListener& listener);

         void entityToBeDeleted(DtEntityStateListener& listener);

         virtual void createAndSendState(DtEntityStateListener& listener,
            DtEntityStateObjectAgent& objectDriver);

      protected:

         static void postDrainInput(void* usr);
         virtual void slot_postUpdateCallback(DtEntityStateListener&);
         virtual void setState(DtVrlinkEntityStateListener& listener, DtVrlinkSimulatedEntityState& state);

      protected:
         
         //A Listener and a driver which will be updated with it.
         class EntityStateUpdater
         {
         public:

            EntityStateUpdater(DtEntityStateListener& listener,
               DtEntityStateObjectAgent& driver, DtEntitySimDataProcessor& processor);

            EntityStateUpdater(const EntityStateUpdater& orig);

            EntityStateUpdater& operator=(const EntityStateUpdater& orig);

            //Are the updaters equal
            bool operator==(const EntityStateUpdater& orig) const;

            void update(double timeT);

         protected:

            DtEntityStateListener* myListener;
            DtEntityStateObjectAgent* myObjectAgent;
            DtEntitySimDataProcessor* myProcessor;
         };
    
         typedef std::vector<DtUniqueID> EntityIdList;

         struct EntitySimDataInstance
         {
            DtEntityStateListener* myListener;
            DtEntityStateObjectAgent* myAgent;
            DtSimEntryUpdater::UpdateRate myRate;
         };

         typedef std::map<DtUniqueID,EntitySimDataInstance > EntityAgentMap;

         typedef DtBalancedUpdater<EntityStateUpdater> EntityUpdaterGroup;
         typedef std::map<DtSimEntryUpdater::UpdateRate,EntityUpdaterGroup>
            EntityUpdateGroupMap;                  

      protected:

         DtSignalConnectionManager myConnections;

         DtVrlinkConnection& mySimulation;
         DtEntityExistenceListener& myListener;
         DtTimedSection myTimer;
         DtSimEntryObjectAgent* mySimEntryAgent;

         EntityAgentMap myEntityAgents;
         EntityUpdateGroupMap myRefreshRateGroups;
         EntityIdList myForceUpdateList;
         
      };
   }
}

#endif