disBroker/aggTrans.h

Go to the documentation of this file.

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


#pragma once


#include <disBroker/objectTrans.h>

#include <portal/pAggregate.h>
#include <portal/pReflectedObjectManagerTypes.h>
#include <portal/pObjectPublisherTypes.h>
#include <map>

class DtReflectedAggregate;
class DtReflectedAggregateList;
class DtAggregatePublisher;
class DtAggregateStateRepository;

namespace MAKVrExchange
{

   namespace DtDisBroker
   {

      class DT_DLL_DISBROKER DtAggregateTranslator : public DtObjectTranslator
      {
      public:
         DtAggregateTranslator(DtDisBroker *broker);

         virtual ~DtAggregateTranslator();

      private:

         DtAggregateTranslator(const DtAggregateTranslator& other);

         DtAggregateTranslator& operator=(const DtAggregateTranslator& other);

      public:

         virtual void tick();


         virtual const char* virtualTranslatorName() const;

         virtual void enableTranslator(bool enabled);

         static const char* translatorName() { return "Aggregate"; };

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

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

      protected:

         virtual void discoverDisObject(DtReflectedAggregate *object);

         virtual void discoverPortalObject(const DtPortalReflectedAggregate &object);

         virtual void receiveDisUpdate( DtReflectedAggregate* object );

         virtual void receivePortalUpdate( const DtPortalReflectedAggregate& object );

         virtual void createDisPublisher(DtBrokerObject* brokerObject);

         virtual void createPortalPublisher(DtBrokerObject* brokerObject);

         static bool disDiscoveryCriteria(DtReflectedObject* obj, void *usr);

         static bool portalDiscoveryCriteria(const DtPortalReflectedObject *obj, void *usr);

         virtual void deleteDisPublisher(DtBrokerObject* brokerObject);

         virtual void deletePortalPublisher(DtBrokerObject* brokerObject);

         virtual bool isDisPublishable(const DtBrokerObject* brokerObject) const;

         virtual bool isPortalPublishable(const DtBrokerObject* brokerObject) const;

         virtual void syncDisDeadReckonedValues(DtBrokerObject* brokerObject);

         virtual void syncPortalDeadReckonedValues(DtBrokerObject* brokerObject);

      protected:

         static void disObjectAddedCb(DtReflectedAggregate *obj, void *ud);

         static void disObjectUpdatedCb(DtReflectedAggregate *obj, void *ud);

         static void disObjectDeletedCb(DtReflectedAggregate *obj, void *ud);

         static void portalObjectAddedCb(const DtPortalReflectedAggregate& obj, void *ud);

         static void portalObjectUpdatedCb(const DtPortalReflectedAggregate& obj, void *ud);


         static void portalObjectDeletedCb(const DtPortalReflectedAggregate& obj, void *ud);

      protected:
         DtReflectedAggregateList *myDisReflectedList;

         DtPortalReflectedAggregateManager *myPortalReflectedManager;

      };
   }
}