rprBroker.h

Go to the documentation of this file.

/****************************************************************************
 * Copyright (c) 2013 VT MAK
 * All rights reserved.
 ****************************************************************************/


#pragma once

#include <broker/vrlBroker.h>

#include "translatorFactory.h"
#include "globalIdMapper.h"

namespace MAKVrExchange
{

   class DtPortalReflectedObject;

   namespace DtRprBroker
   {

      class DtBrokerObject;
      class DtObjectTranslator;
      class DtRprBrokerInitializer;
      class DtGenericUserInterface;

      //
      class DT_DLL_RPRBROKER DtRprBroker : public DtVrlBroker
      {
      public:

         virtual ~DtRprBroker();

         virtual void initializeUi( DtGenericUserInterface* ui );

      protected:

         DtRprBroker();

         virtual void initialize( DtRprBrokerInitializer* init );

         virtual void logBrokerSettings( DtBrokerInitializer* init );

      public:

         virtual void processEvents();

         virtual void updateSimTime() const;

         virtual void loadTranslators();

         virtual void loadObjectTranslator(const DtString& translatorName);

         virtual void loadInteractionTranslator(const DtString& translatorName);

         virtual void loadKnownObjectTranslators();

         virtual void loadKnownInteractionTranslators();

         virtual DtObjectTranslator* getObjectTranslator(const DtString& name);

         virtual DtInteractionTranslator* getInteractionTranslator(const DtString& name);

         virtual DtGlobalIdMapper* globalIdMapper();

         virtual DtRprBrokerInitializer* hlaInitializer();

         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() {return myHeartbeat;};
         virtual void setHeartbeat(int i) {myHeartbeat = i;}

      public:

         virtual void tick();

         virtual void launchGui();

         virtual void launchInfoGui();

         virtual void reloadBrokerSettings();

         virtual DtInteractionTranslatorFactory* interactionTranslatorFactory();

         virtual DtObjectTranslatorFactory* objectTranslatorFactory();

         virtual void initHlaConnection(const DtRprBrokerInitializer& init);

         virtual DtString portalNameFind(const DtString& name);

      public:

         static DtRprBroker *create(DtRprBrokerInitializer* init);

         static void setGlobalIdMapperCreator(DtGlobalIdMapperCreator func);

         static DtGlobalIdMapperCreator globalIdMapperCreator();

      protected:

         virtual void shutdownBroker();

         void initializeHlaBroker();

         virtual void addTranslator(DtInteractionTranslator *intTrans, bool enabled);

         virtual void addTranslator(DtObjectTranslator *objTrans, bool enabled);

         virtual void initWholeFomTranslation();

         virtual void initGenericTranslators();

         virtual void shutdownTranslators();

         virtual void objectDiscovered(const DtBrokerObject* brokerObject);

         virtual void objectUpdated(const DtBrokerObject* brokerObject);

         virtual void objectRemoved(const DtBrokerObject* brokerObject);

         virtual void initPortalNameMapper( const DtFilename& mapFile);

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

      protected:

         static void objectDiscoveredCallback(const DtBrokerObject* brokerObject,  void *usr);
         static void objectUpdatedCallback(const DtBrokerObject* brokerObject, void *usr);
         static void objectRemovedCallback(const DtBrokerObject* brokerObject, void *usr);

      private:

         DtRprBroker( const DtRprBroker& other );

         DtRprBroker& operator = ( const DtRprBroker& other );

      protected:

         static DtGlobalIdMapperCreator theGlobalIdMapperCreator;

      protected:

         typedef std::map<const DtString, DtInteractionTranslator*> NamedInteractionTranslatorMap;
         typedef std::map<const DtString, DtObjectTranslator*> NamedObjectTranslatorMap;

         int myHeartbeat;
         DtGenericUserInterface* myUi;
         NamedInteractionTranslatorMap myInteractionTranslatorMap;
         NamedObjectTranslatorMap myObjectTranslatorMap;
         DtObjectTranslatorFactory myObjectTranslatorFactory;
         DtInteractionTranslatorFactory myInteractionTranslatorFactory;
         DtU16 myNextEntityId;
         DtGlobalIdMapper* myGlobalIdMapper;
         std::vector<DtString> myGenericInteractionsToTranslateSet;
         std::vector<DtString> myGenericObjectsToTranslateSet;

         //Used for Persisting entity Ids.
         std::map<const char*,int> myNameToEntityNum;
         std::map<DtString,DtString> myPortalNameMapper;

      };

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

   }
}