rprBroker.h

Go to the documentation of this file.

/****************************************************************************
 * Copyright (c) 2017 MAK Technologies, Inc.
 * All rights reserved.
 ****************************************************************************/


#pragma once

#include <broker/vrlBroker.h>
#include <broker/translatorFactory.h>
#include <rprBroker/globalIdMapper.h>
#include <vl/exerciseConn.h>

namespace MAKVrExchange
{

   class DtBrokerObject;
   class DtObjectTranslator;
   class DtGenericUserInterface;
   class DtPortalReflectedObject;
   class DtInteractionTranslator;

   namespace DtRprBroker
   {

      class DtRprBrokerInitializer;

      class DT_DLL_RPRBROKER DtRprBroker : public DtVrlBroker<DtExerciseConn>
      {
      public:

         static DtBroker* create( DtBrokerInitializer* init );

      protected:

         DtRprBroker();

      public:

         virtual ~DtRprBroker();

         virtual void tick();

         virtual void processDiscoveryTimeout();

         virtual DtString portalNameFind( const DtString& name ) const;

         virtual void updateSimTime() const;

         virtual DtRprBrokerInitializer* rprInitializer();
         virtual const DtRprBrokerInitializer* rprInitializer() const;

         virtual bool fillOutgoingIds() const;

         virtual bool usePersistentIds() const;

         virtual bool useHlaObjectIdForMarkingText() const;

         virtual bool useMarkingTextForHlaObjectId() const;

         virtual int outgoingSiteId() const;

         virtual int outgoingHostId() const;

         virtual DtU16 useNextEntityId();

         virtual int getPersistentId( const DtString& name );

         virtual void setPersistentId( const DtString& name, int );

         virtual int heartbeat() const { return myHeartbeat; }
         virtual void setHeartbeat( int i ) { myHeartbeat = i; }

         virtual bool isDiscoveryTimeoutActive() const { return myDiscoveryTimeoutActiveFlag; }

         static void setGlobalIdMapperCreator( DtGlobalIdMapperCreator func );

         static DtGlobalIdMapperCreator globalIdMapperCreator();

         virtual DtGlobalIdMapper* globalIdMapper();

      protected:

         virtual void initialize( DtRprBrokerInitializer* init );

         virtual void setupTranslators( DtRprBrokerInitializer* init );

         virtual void logBrokerSettings( DtBrokerInitializer* init );

         virtual void startBroker();

         virtual void initHlaConnection( const DtRprBrokerInitializer& init );

         virtual void initializeTranslators( DtStringSet& failedTranslators );

         virtual void initWholeFomTranslation();

         virtual void initGenericObjectTranslators( DtStringSet& failedTranslators );

         virtual void initGenericInteractionTranslators( DtStringSet& failedTranslators );

         virtual bool loadGenericObjectTranslator( const DtString& objName );

         virtual bool loadGenericInteractionTranslator( const DtString& interName );

         virtual void initPortalNameMapper( const DtFilename& mapFile);

         // Used for persisting entity Ids.
         virtual void loadEntityNumMappingFile();
         virtual void saveEntityNumMappingFile();

         virtual void shutdown();

      private:

         DtRprBroker( const DtRprBroker& other );

         DtRprBroker& operator = ( const DtRprBroker& other );

      protected:

         static DtGlobalIdMapperCreator theGlobalIdMapperCreator;

         int myHeartbeat;
         DtU16 myNextEntityId;
         DtGlobalIdMapper* myGlobalIdMapper;
         std::vector<DtString> myGenericInteractionsToTranslateSet;
         std::vector<DtString> myGenericObjectsToTranslateSet;

         DtTime myDiscoveryTimeoutActivationTime;
         bool myDiscoveryTimeoutActiveFlag;

         typedef std::map<DtString,int> PersistentEntityIdMap;
         PersistentEntityIdMap myNameToEntityNum;

         std::map<DtString,DtString> myPortalNameMapper;

      };


      inline DtU16 DtRprBroker::useNextEntityId()
      {
         return myNextEntityId++;
      }

   }
}