ddsBroker.h

Go to the documentation of this file.

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


#pragma once

#include <broker/broker.h>
#include <ddsBroker/throttle.h>
#include <ddsBroker/globalIdMapper.h>
#include <broker/translatorFactory.h>

#include <vlutil/vlStringUtil.h>
#include <vlutil/vlTime.h>
#include <list>
#include <map>

namespace MAKVrExchange
{

   class DtBrokerObject;
   class DtPortalReflectedObject;
   class DtGenericUserInterface;

   namespace DtDdsBroker
   {

      class DtEntityIdMapper;
      class DtDdsDomainConnection;
      class DtDdsBrokerInitializer;

      enum DdsBrokerObjectDataField {
         ThrottleRateData = 0
      };

      class DT_DLL_DDSBROKER DtDdsBroker : public DtBroker
      {
      public:

         static DtBroker* create( DtBrokerInitializer* init );

         virtual ~DtDdsBroker();

      protected:

         DtDdsBroker();

         virtual void logBrokerSettings( DtDdsBrokerInitializer* init );

      public:

         virtual void tick();

         virtual DtDdsDomainConnection* ddsConnection() const;

         virtual DtDdsBrokerInitializer* ddsInitializer();

         virtual DtGlobalIdMapper* globalIdMapper();
         virtual DtEntityIdMapper* entityIdMapper();
         virtual bool usePersistentIds() const;
         virtual bool fillOutgoingIds() const;
         virtual bool useDdsObjectIdForMarkingText() const;
         virtual bool useMarkingTextForDdsObjectId() const;
         virtual bool guiseIsEntityType() const;
         virtual bool forceUpdateFlag() const;
         virtual bool debugGlobalIdMapping() const;
         virtual bool dumpGuiToText() const;

         virtual DtThrottle* throttle();

         virtual void reloadBrokerSettings();

         virtual DtString portalNameFind( const DtString& name ) const;

         static void setGlobalIdMapperCreator( DtGlobalIdMapperCreator func );

         static DtGlobalIdMapperCreator globalIdMapperCreator();

      protected:

         virtual void initialize( DtDdsBrokerInitializer* init );

         virtual void shutdownBroker();

         virtual void initDdsConnection( const DtDdsBrokerInitializer& init );

         virtual void initPortalNameMapper( const DtFilename& mapFile );

         virtual void initializeDdsBroker();

         virtual void setupTranslators();

      private:

         DtDdsBroker( const DtDdsBroker& other );

         DtDdsBroker& operator = ( const DtDdsBroker& other );

      protected:

         static DtGlobalIdMapperCreator theGlobalIdMapperCreator;

         DtDdsDomainConnection* myDdsConn;

         DtThrottle myThrottle;

         DtGlobalIdMapper* myGlobalIdMapper;
         DtEntityIdMapper* myEntityIdMapper;
         DtU16 myNextEntityId;
         std::map<DtString,DtString> myPortalNameMapper;

      };


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

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

      inline DtThrottle* DtDdsBroker::throttle()
      {
         return &myThrottle;
      }

   }
}