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 <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 void createVisualizer(makVrv::DT_PROTOCOL_NAMESPACE::DtVrlinkAggregateStateListener&);

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

         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;
      };
   }
}