vrfAggregateElementProcessor.h

Go to the documentation of this file.

/******************************************************************************
** Copyright (c) 2017 MAK Technologies, Inc.
** All rights reserved.
******************************************************************************/


#pragma once

#include <vrfVrlSharedSource/vrfProtocol.h>
#include <vrvVrl/DtAggregateElementProcessor.h>
#include <vrvVrl/DtVrlinkAggregateElement.h>
#include <vrfutil/rwUUID.h>

class DtVrfRemoteController;
class DtExtAggregateStateRepository;

namespace makVrf
{
   namespace VRF_PROTOCOL_NAMESPACE
   {
      class VRF_PROTOCOL_EXPORT DtVrfAggregateElementProcessor : public makVrv::DT_PROTOCOL_NAMESPACE::DtAggregateElementProcessor
      {
      public:
         DtVrfAggregateElementProcessor(makVrv::DT_PROTOCOL_NAMESPACE::DtVrlinkConnection& sim);

         virtual ~DtVrfAggregateElementProcessor();

         virtual bool createElement(makVrv::DT_PROTOCOL_NAMESPACE::DtVrlinkAggregateStateListener&);

         virtual void slot_completeDiscovery() override;
         virtual void onAggregateDiscovered(makVrv::DT_PROTOCOL_NAMESPACE::DtVrlinkAggregateStateListener& listener) override;

         virtual void onAggregateToBeDestroyed(makVrv::DT_PROTOCOL_NAMESPACE::DtVrlinkAggregateStateListener& listener);

      protected:
         virtual void hookPublishedListener(makVrv::DT_PROTOCOL_NAMESPACE::DtVrlinkAggregateStateListener& listener);
         virtual void uuidFrom(DtExtAggregateStateRepository*, DtUUID&) const;

      protected:
         typedef boost::unordered_map<DtUUID, makVrv::DT_PROTOCOL_NAMESPACE::DtVrlinkAggregateStateListener*> ListenersByUUID;

         ListenersByUUID myPublishedListenersByUUID;
         ListenersByUUID myOrbatListenersByVrfUUID;
         int myRetryCount;
      };

      class VRF_PROTOCOL_EXPORT DtVrfVrlinkAggregateElement : public makVrv::DT_PROTOCOL_NAMESPACE::DtVrlinkAggregateElement
      {
      public:
         DtVrfVrlinkAggregateElement( makVrv::DtBaseConnection& conn, makVrv::DtStateListener& listener );

         virtual ~DtVrfVrlinkAggregateElement();

         virtual void visualize( const makVrv::DtSharedModelSetSettings::ModelSetVisualizedMap& sets ) override;
         virtual void setModelSetEnabled( int modelSet, bool enabled ) override;
      };

      using DtVrfVrlinkAggregateElementCreator = makVrv::DtElementCreatorTemplate<DtVrfVrlinkAggregateElement>;
   }
}