disBroker.h

Go to the documentation of this file.

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


#pragma once

#include <broker/vrlBroker.h>
#include <broker/translatorFactory.h>
#include <disBroker/globalIdMapper.h>
#include <disBroker/underwaterAcousticsPublisherManager.h>
#include <vl/globalObjectDesignator.h>
#include <vlutil/vlStringUtil.h>
#include <vlutil/vlDisSocket.h>
#include <vlutil/vlString.h>
#include <vlutil/vlTime.h>
#include <list>
#include <map>

class DtExerciseConn;

namespace MAKVrExchange
{

   class DtBrokerObject;
   class DtPortalReflectedObject;

   namespace DtDisBroker
   {

      class DtEventIdMapper;
      class DtEntityIdMapper;
      class DtDisBrokerInitializer;

      class DT_DLL_DISBROKER DtDisBroker : public DtVrlBroker
      {
      public:

         static DtBroker* create( DtBrokerInitializer* init );

         virtual ~DtDisBroker();

      protected:

         DtDisBroker();

      public:

         virtual void tick();

         virtual void reloadBrokerSettings();

         virtual void updateSimTime() const;

         virtual DtDisBrokerInitializer* disInitializer();


         virtual DtUnderwaterAcousticsPublisherManager*
            underwaterAcousticsPublisherManager();
         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;

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

         static void setUnderwaterAcousticsPublisherManagerCreator(
            DtUnderwaterAcousticsPublisherManagerCreator func );

         static DtUnderwaterAcousticsPublisherManagerCreator
            underwaterAcousticsPublisherManagerCreator();

         static void setGlobalIdMapperCreator( DtGlobalIdMapperCreator func );

         static DtGlobalIdMapperCreator globalIdMapperCreator();

      protected:

         virtual void initialize( DtDisBrokerInitializer* init );

         virtual void setupTranslators( DtDisBrokerInitializer* init );

         virtual void logBrokerSettings( DtDisBrokerInitializer* init );

         virtual void shutdownBroker();

         virtual void initDisConnection( DtDisBrokerInitializer& init );

         virtual DtString chooseNewDeviceAddress() const;

         virtual void initializeDisBroker();

      private:

         DtDisBroker( const DtDisBroker& other );

         DtDisBroker& operator = ( const DtDisBroker& other );

      protected:

         static DtUnderwaterAcousticsPublisherManagerCreator
            theUnderwaterAcousticsPublisherManagerCreator;

         static DtGlobalIdMapperCreator theGlobalIdMapperCreator;

         DtInetDevice* myDisMcastDevice;

         DtUnderwaterAcousticsPublisherManager* myUndwaAcPublisherManager;
         DtGlobalIdMapper* myGlobalIdMapper;
         DtEventIdMapper* myEventIdMapper;
         DtEntityIdMapper* myEntityIdMapper;

      };


      inline DtUnderwaterAcousticsPublisherManager*
         DtDisBroker::underwaterAcousticsPublisherManager()
      {
         return myUndwaAcPublisherManager;
      }

      inline DtGlobalIdMapper* DtDisBroker::globalIdMapper()
      {
         return myGlobalIdMapper;
      }

      inline DtEntityIdMapper* DtDisBroker::entityIdMapper()
      {
         return myEntityIdMapper;
      }

      inline DtEventIdMapper* DtDisBroker::eventIdMapper()
      {
         return myEventIdMapper;
      }

   }
}