rprBroker/libRprBroker/aggTrans.h

Go to the documentation of this file.

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


#pragma once

#include "rprTrans.h"
#include <vl/reflAggList.h>
#include <vl/aggPub.h>
#include <map>

class DtReflectedAggregate;
class DtAggregateStateRepository;

#define AGGREGATE_TEMPLATE_ARGS \
   DtPortalAggregate, DtPortalReflectedAggregate, \
   DtReflectedAggregate, DtReflectedAggregateList, \
   DtAggregateStateRepository, DtAggregatePublisher

namespace MAKVrExchange
{

   class DtPortalAggregate;

   namespace DtRprBroker
   {

      template <>
      DT_DLL_RPRBROKER DtAggregatePublisher*
         DtRprObjectTranslator<AGGREGATE_TEMPLATE_ARGS>::instantiateHlaPublisher(
            const DtPortalReflectedAggregate* refObj, const DtString& name );


      class DT_DLL_RPRBROKER DtAggregateTranslator
         : public DtRprObjectTranslator<AGGREGATE_TEMPLATE_ARGS>
      {
      public:

         Dt_DEF_TRANSLATOR_NAME( "Aggregate" );

         DtAggregateTranslator( DtRprBroker* broker );

         virtual ~DtAggregateTranslator();

         virtual DtPortalAggregate* translate( DtPortalAggregate* destination,
            const DtAggregateStateRepository& source,
            const DtReflectedAggregate& refObj );

         virtual DtAggregateStateRepository* translate(
            DtAggregateStateRepository* destination,
            const DtPortalAggregate& source,
            const DtPortalReflectedAggregate& refObj );

      protected:

         virtual void updateHlaBrokerObject( DtBrokerObject* brokerObj,
            const DtAggregateStateRepository& sr );

         virtual void updatePortalBrokerObject( DtBrokerObject* brokerObj,
            const DtPortalAggregate& sr );

         virtual void updateFilteredState( DtBrokerObject* brokerObj,
            DtPortalAggregatePublisher* publisher, DtReflectedAggregate* refObj );

         virtual void createHlaPublisher( DtBrokerObject* brokerObject );

         virtual DtString hlaObjectName( const DtPortalReflectedAggregate* refObj );

         virtual void fillOutgoingIds( DtAggregatePublisher* publisher,
            const DtString& objectName );

         virtual bool isDiscoverable( const DtBrokerObject* brokerObj,
            const DtPortalReflectedAggregate* refObj ) const;

         virtual void syncHlaDeadReconedValues( DtBrokerObject* brokerObject );
         virtual void syncPortalDeadReckonedValues( DtBrokerObject* brokerObject );

      };

   }
}