rprBroker/libRprBroker/objectTrans.h

Go to the documentation of this file.

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


#pragma once

#include <broker/translator.h>

#include <list>
#include <set>
#include <map>

class DtReflectedObject;
class DtStateRepository;

namespace MAKVrExchange
{

   class DtPortalObject;
   class DtPortalReflectedObject;
   class DtRequestTranslationDiagnosticMessage;

   namespace DtRprBroker
   {

      class DtRprBroker;
      class DtBrokerObject;

      class DT_DLL_RPRBROKER DtObjectTranslator : public DtTranslator
      {
      public:

         typedef enum
         {
            none = 0,
            discover = 1, 
            update = 2,   
            remove = 3    
         } UpdateType;

         typedef void (*BrokerObjectCbPtr)
            ( const DtBrokerObject *brokerObjectPointer,
            void *userData);

      public:

         DtObjectTranslator( DtRprBroker* broker, const DtString& name,
            DtPortalMessageKind kind );

         virtual ~DtObjectTranslator();

         virtual DtBrokerObject *releaseBrokerObject(
            const DtReflectedObject* reflectedObj);
         virtual DtBrokerObject *releaseBrokerObject(
            const DtPortalReflectedObject* reflectedObj);

         virtual DtBrokerObject *findBrokerObject(
            const DtReflectedObject* reflectedObj);
         virtual DtBrokerObject *findBrokerObject(
            const DtPortalReflectedObject* reflectedObj);

         virtual DtBrokerObject *createBrokerObject(
            const  DtReflectedObject* reflectedObj);
         virtual DtBrokerObject *createBrokerObject(
            const  DtPortalReflectedObject* reflectedObj);

         virtual bool isHlaDiscoverable( const DtReflectedObject* reflectedObj );

         virtual bool isPortalDiscoverable( const DtPortalReflectedObject* reflectedObj );

         virtual void removeHlaObject( const DtReflectedObject* reflectedObj );

         virtual void tick() = 0;

         virtual void printIncomingOutgoingStateReps(
            const DtPortalObject& incoming, const DtStateRepository& outgoing );

         virtual void printIncomingOutgoingStateReps(
            const DtStateRepository& incoming, const DtPortalObject& outgoing );

         virtual void performPortalDebugging( const DtPortalObject& incoming,
            const DtStateRepository& outgoing );

         virtual void performPortalDebugging( const DtStateRepository& incoming,
            const DtPortalObject& outgoing );

         virtual void addObjectDiscoveredCallback(
            BrokerObjectCbPtr funcPtr, void *userData);

         virtual void addObjectUpdatedCallback(
            BrokerObjectCbPtr funcPtr, void *userData);

         virtual void addObjectRemovedCallback(
            BrokerObjectCbPtr funcPtr, void *userData);

         virtual unsigned int numObjects() const;

      protected:

         static void requestTransDiagCb( const DtRequestTranslationDiagnosticMessage& msg, void* usr );

         virtual void requestTransDiagCb( const DtRequestTranslationDiagnosticMessage& msg );

         virtual void callObjectDiscoverCallbacks( const DtBrokerObject* brokerObject );

         virtual void callObjectUpdateCallbacks( const DtBrokerObject* brokerObject );

         virtual void callObjectRemoveCallbacks( const DtBrokerObject* brokerObject );

         virtual void createPortalPublisher( DtBrokerObject* brokerObject ) = 0;
         virtual void createHlaPublisher( DtBrokerObject* brokerObject ) = 0;

         virtual void deletePortalPublisher( DtBrokerObject* brokerObject ) = 0;
         virtual void deleteHlaPublisher( DtBrokerObject* brokerObject ) = 0;

         virtual bool isPortalPublishable( const DtBrokerObject* brokerObject ) const = 0;

         virtual bool isHlaPublishable( const DtBrokerObject* brokerObject ) const = 0;

         virtual void removePortalObject( const DtPortalReflectedObject* reflectedObj );

      private:

         DtObjectTranslator( const DtObjectTranslator& other );

         DtObjectTranslator& operator = ( const DtObjectTranslator& other );

         bool operator == ( const DtObjectTranslator& );

         bool operator != ( const DtObjectTranslator& );

      protected:

         typedef std::map<const DtReflectedObject*, DtBrokerObject *>
            HlaToPortalReflectedMap;
         typedef std::map<const DtPortalReflectedObject*, DtBrokerObject *>
            PortalToHlaReflectedMap;

         struct CallbackPair { BrokerObjectCbPtr fcn; void *userData; };
         typedef std::list<CallbackPair> CallbackPairList;

         typedef std::set<DtString> TransDebugObjectNamesSet;
         TransDebugObjectNamesSet myTransDebugNames;

         CallbackPairList myDiscoverCallbacks;
         CallbackPairList myUpdateCallbacks;
         CallbackPairList myRemoveCallbacks;

         HlaToPortalReflectedMap myPortalPublisherMap;
         PortalToHlaReflectedMap myHlaPublisherMap;

         DtRprBroker* myHlaBroker;

      };

   }
}