vrfEntitySimDataProcessor.h

Go to the documentation of this file.

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


#pragma once

#include <vrfVrlSharedSource/vrfProtocol.h>
#include <vrvVrl/DtVrlinkConnection.h>
#include <vrvVrl/DtEntitySimDataProcessor.h>
#include <vrfutil/rwUUID.h>

class DtVrfRemoteController;
class DtReflectedObject;

namespace makVrf
{
   namespace VRF_PROTOCOL_NAMESPACE
   {
      class VRF_PROTOCOL_EXPORT DtVrfEntitySimDataProcessor : public makVrv::DT_PROTOCOL_NAMESPACE::DtEntitySimDataProcessor
      {
      public:

         DtVrfEntitySimDataProcessor(makVrv::DT_PROTOCOL_NAMESPACE::DtVrlinkConnection& sim, DtVrfRemoteController*);

         virtual ~DtVrfEntitySimDataProcessor();

         virtual void createAndSendState(makVrv::DtEntityStateListener& listener,
            makVrv::DtEntityStateObjectAgent& objectDriver);

         virtual void postRemoteControllerInit();
         virtual void cleanup();

      protected:
         virtual void slot_postUpdateCallback(makVrv::DtEntityStateListener&);
         virtual void setState(makVrv::DT_PROTOCOL_NAMESPACE::DtVrlinkEntityStateListener& listener,
            makVrv::DtVrlinkSimulatedEntityState& state);
         virtual void removeEntityState(makVrv::DtEntityStateListener& listener);

         virtual void vrfEntityDiscovered(makVrv::DT_PROTOCOL_NAMESPACE::DtVrlinkEntityStateListener& listener);

         virtual void forceObjectUpdate(makVrv::DtUniqueID uniqueId);

         static void clearForceUpdateCheckList(void*);
         virtual void clearForceUpdateCheckList();

         static void uuidChangedCallback(DtReflectedObject* obj, const DtUUID& uuid, void* usr);
         virtual void processUUIDChanged(DtReflectedObject* obj, const DtUUID& uuid);

      protected:
         typedef std::map<makVrv::DtUniqueID, makVrv::DtVrlinkSimulatedEntityState> EntityStates;
         EntityStates myEntityStates;

         std::set<makVrv::DtUniqueID> myUpdated;

         DtVrfRemoteController* myRemoteController;

         std::set<makVrv::DtUniqueID> myForceUpdateCheck;
         std::map<makVrv::DtUniqueID, DtUUID> myUUIDMap;
         bool myReportUUIDChanges;
         bool myReportForceChanges;
      };

      class VRF_PROTOCOL_EXPORT DtVrfEntitySimDataProcessorCreator : public makVrv::DtVirtualBaseClass
      {
      public:
         DtVrfEntitySimDataProcessorCreator();

         static DtVrfEntitySimDataProcessorCreator& instance(makVrv::DT_PROTOCOL_NAMESPACE::DtVrlinkConnection& conn);

         static void registerInstance(makVrv::DT_PROTOCOL_NAMESPACE::DtVrlinkConnection& conn, 
            DtVrfEntitySimDataProcessorCreator* instance);

         virtual DtVrfEntitySimDataProcessor* create(makVrv::DT_PROTOCOL_NAMESPACE::DtVrlinkConnection& conn, DtVrfRemoteController* remote);
      };
   }
}