vrfEntityElementProcessor.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/DtEntityElementProcessor.h>
#include <vrvVrl/DtVrlinkEntityElement.h>
#include <vrfutil/rwUUID.h>

#include <boost/unordered_map.hpp>

class DtVrfRemoteController;
class DtExtEntityStateRepository;

namespace makVrv
{
   class DtEntityStateListener;
}

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

         virtual ~DtVrfEntityElementProcessor();

         virtual void onEntityDiscovered(makVrv::DT_PROTOCOL_NAMESPACE::DtVrlinkEntityStateListener& listener) override;

         virtual void onEntityToBeDestroyed(makVrv::DT_PROTOCOL_NAMESPACE::DtVrlinkEntityStateListener& listener) override;
         virtual bool createElement(makVrv::DT_PROTOCOL_NAMESPACE::DtVrlinkEntityStateListener& listener);

      protected:
         virtual void hookPublishedListener(makVrv::DtEntityStateListener* listener);
         virtual void hookPublishedListenerByGlobalId(DtString globalId);
         virtual void uuidFrom(DtExtEntityStateRepository*, DtUUID&) const;
         virtual void slot_completeDiscovery() override;

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

         ListenersByUUID myPublishedListenersByUUID;
         ListenersByUUID myOrbatListenersByVrfUUID;
         int myRetryCount;
         std::map<DtString, makVrv::DtEntityStateListener*> myWaitingForHook;
      };
   }
}