disBroker.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"

#include <portal/pControlMessage.h>

#include <vl/globalObjDes.h>

#include <vlutil/vlString.h>
#include <vlutil/vlStringUtil.h>
#include <vlutil/vlTime.h>
#include <vlutil/vlDisSocket.h>

#include <list>
#include <map>

class DtExerciseConn;

namespace MAKVrExchange
{

   class DtPortalReflectedObject;

   namespace DtDisBroker
   {

      class DtBrokerObject;
      class DtEventIdMapper;
      class DtEntityIdMapper;
      class DtObjectTranslator;
      class DtDisBrokerInitializer;
      class DtGenericUserInterface;
      class DtInteractionTranslator;

      class DT_DLL_DISBROKER DtDisBroker : public DtVrlBroker
      {
      public:

         static DtDisBroker* create( DtDisBrokerInitializer* init );

         virtual ~DtDisBroker();

         virtual void initializeUi( DtGenericUserInterface* ui );

      protected:

         DtDisBroker();

         virtual void initialize( DtDisBrokerInitializer* init );

         virtual void logBrokerSettings( DtBrokerInitializer* init );

      private:

         DtDisBroker( const DtDisBroker& other );

         DtDisBroker& operator = ( const DtDisBroker& other );

      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 DtDisBrokerInitializer* disInitializer();

         virtual DtGlobalIdMapper* globalIdMapper();
         virtual DtEventIdMapper* eventIdMapper();
         virtual DtEntityIdMapper* entityIdMapper();
         virtual DtTime heartbeatInterval() const;
         virtual DtTime timeoutInterval() const;
         virtual bool remapDisIds() const;
         virtual bool usePersistentIds() const;
         virtual bool dumpGuiToText() const;

      public:

         virtual void tick();

         virtual void launchGui();

         virtual void launchInfoGui();

         virtual void reloadBrokerSettings();

         virtual DtInteractionTranslatorFactory* interactionTranslatorFactory();

         virtual DtObjectTranslatorFactory* objectTranslatorFactory();

         DtGlobalObjectDesignator convertGlobalId( const DtString& id );
         DtString convertGlobalId( const DtGlobalObjectDesignator& id );
         DtEntityIdentifier convertPortalEntIdToDisEntId( const DtEntityIdentifier& portalId );
         DtEntityIdentifier convertDisEntIdToPortalEntId( const DtEntityIdentifier& disId );

         virtual DtObjectTranslator* getObjectTranslator(const DtString& name);

         virtual DtInteractionTranslator* getInteractionTranslator(const DtString& name);

      public:

         static void setGlobalIdMapperCreator( DtGlobalIdMapperCreator func );

         static DtGlobalIdMapperCreator globalIdMapperCreator();

      protected:

         virtual void shutdownBroker();

         void initDisConnection( const DtDisBrokerInitializer &init );

         void initializeSockets( const DtDisBrokerInitializer &init );

         void initializeDisBroker();

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

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

         virtual void setupTranslators();

         virtual void shutdownTranslators();

         virtual void objectDiscovered( const DtBrokerObject* brokerObject );

         virtual void objectUpdated( const DtBrokerObject* brokerObject );

         virtual void objectRemoved( const DtBrokerObject* brokerObject );

      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 );

      protected:

         static DtGlobalIdMapperCreator theGlobalIdMapperCreator;

      protected:

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

         DtDisSocket* myDisSocket;
         DtInetDevice* myDisMcastDevice;
         DtGenericUserInterface* myUi;
         NamedInteractionTranslatorMap myInteractionTranslatorMap;
         NamedObjectTranslatorMap myObjectTranslatorMap;
         DtObjectTranslatorFactory myObjectTranslatorFactory;
         DtInteractionTranslatorFactory myInteractionTranslatorFactory;
         DtGlobalIdMapper* myGlobalIdMapper;
         DtEventIdMapper* myEventIdMapper;
         DtEntityIdMapper* myEntityIdMapper;

      };

   }
}