disBroker.h

Go to the documentation of this file.

/*********************************************************************
 ** Copyright (c) 1992-2010 VT MAK
*********************************************************************/
#pragma once


#include <broker/broker.h>
#include <vlutil/vlString.h>
#include <vlutil/vlStringUtil.h>
#include <vlutil/vlTime.h>
#include <vlutil/vlDisSocket.h>
#include <portal/pControlMessage.h>
#include <disBroker/translatorFactory.h>
#include <disBroker/globalIdMapper.h>
#include <list>
#include <map>

class DtExerciseConn;


namespace MAKVrExchange
{

   class DtPortalReflectedObject;

   namespace DtDisBroker
   {

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


      //
      class DT_DLL_DISBROKER DtDisBroker : public DtBroker
      {

      public:

         DtDisBroker(DtDisBrokerInitializer* init);

         virtual ~DtDisBroker();

         virtual void initializeUi(DtGenericUserInterface *ui);

      private:

         DtDisBroker(const DtDisBroker& other);

         DtDisBroker& operator=(const DtDisBroker& other);

      public:

         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 DtExerciseConn *disConnection() const;

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

         virtual DtObjectTranslator* getObjectTranslator(const DtString& name);

         virtual DtInteractionTranslator* getInteractionTranslator(const DtString& name);

      public:

         static DtDisBroker *create(DtDisBrokerInitializer* init);

         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;
         DtExerciseConn       *myExConn;
         NamedInteractionTranslatorMap myInteractionTranslatorMap;
         NamedObjectTranslatorMap myObjectTranslatorMap;
         DtObjectTranslatorFactory myObjectTranslatorFactory;
         DtInteractionTranslatorFactory myInteractionTranslatorFactory;
         DtGlobalIdMapper     *myGlobalIdMapper;
         DtEventIdMapper      *myEventIdMapper;
         DtEntityIdMapper     *myEntityIdMapper;
      };
   }
}