localExtendedPropertiesNetInterface.h

Go to the documentation of this file.

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



#pragma once

#ifdef DtHLA

#include "vrfobjcore/vrfobjcoreDefines.h"
#include "vrfobjcore/vrfObject.h"
#include "vrfobjcore/vrfObjectStateRepository.h"
#include "vrfobjcore/simAggregateLocalEntityNetInterface.h"
#include "vrfExtObjects/genericAttributeStateRepositoryHLA.h"
#include "vrfutil/readerWriterRegistryData.h"
#include "vrfutil/propertyInterface.h"


template <typename BaseNetInterface, typename BaseStateRepository>
class DT_DLL_vrfobjcore DtLocalExtendedPropertiesNetInterface : public BaseNetInterface
{
protected:

   DtLocalExtendedPropertiesNetInterface()
      : BaseNetInterface()
      , myLastEncodeTime(0)
   {
      myClock.init();
   }

public:

   typedef makVrfVrlinkExtToolkit::DtGenericAttributeStateRepository<BaseStateRepository> DtExtendedPropertiesStateRepository;

   DtLocalExtendedPropertiesNetInterface(const DtString & name, 
      DtVrfObject* vrfObject,  
      DtReaderWriterRegistry* parentRegistry = 0,
      bool publishObject = true)
      : BaseNetInterface(name, vrfObject, parentRegistry, publishObject)
      , myLastEncodeTime(0)
   {
      myClock.init();
   }

   DtLocalExtendedPropertiesNetInterface(const 
      DtLocalExtendedPropertiesNetInterface<BaseNetInterface, BaseStateRepository> & orig, 
      DtReaderWriterRegistry * parentRegistry = 0)
      : BaseNetInterface(orig)
      , myLastEncodeTime(0)
   {
      myClock.init();
   }

   const DtLocalExtendedPropertiesNetInterface & operator=(const 
      DtLocalExtendedPropertiesNetInterface<BaseNetInterface, BaseStateRepository> & orig)
   {
      return static_cast<const DtLocalExtendedPropertiesNetInterface&>(
         BaseNetInterface::operator=(orig));
   }

   virtual ~DtLocalExtendedPropertiesNetInterface() {}

   virtual void updatePublisher()
   {
      BaseNetInterface::updatePublisher();
      encodePropertyAttributes();
   }

   virtual bool encodePropertyAttributes()
   {
      DtVrfObjectStateRepository* localState = this->mySimObject->vrfState();

      encodeProperties(localState->parameterProperties());
      encodeProperties(localState->stateProperties());

      myLastEncodeTime = myClock.absRealTime();

      return true;
   }

   virtual void encodeProperties(const DtRwVariableBindings& properties)
   {
      DtExtendedPropertiesStateRepository* netWithProps =
         dynamic_cast<DtExtendedPropertiesStateRepository*>(this->myNetworkState);

      if (netWithProps)
      {
         std::vector<DtReaderWriterRegistryData *>::const_iterator iter =
            properties.registry().registryData().begin();
         std::vector<DtReaderWriterRegistryData *>::const_iterator endIter = 
            properties.registry().registryData().end();
         for(; iter != endIter; ++iter)
         {
            if ((*iter)->readerWriter()->wasUpdatedSince(myLastEncodeTime) &&
               netWithProps->publishesAttribute((*iter)->keyword().c_str()))
            {
               const DtPropertyInterface* pFace = (*iter)->readerWriter()->property();

               if (pFace)
               {
                  int size = pFace->getSize();

                  if (size != 0)
                  {
                     myPropertyBuffer.resize(size);
                     if(myPropertyBuffer.size())
                     {
                        pFace->encode(&myPropertyBuffer[0]);
                        netWithProps->setAttributeByName(
                           (*iter)->keyword().c_str(), &myPropertyBuffer[0], myPropertyBuffer.size());
                     }
                  }
               }
            }
         }
      }
   }

   static DtSimObjectNetInterface * creator(const DtString & name, 
      DtVrfObject* vrfObject, 
      DtReaderWriterRegistry* parentRegistry,
      bool publishObject)
   {
      return new DtLocalExtendedPropertiesNetInterface<BaseNetInterface, BaseStateRepository>(name, (DtVrfObject*)vrfObject, 
         parentRegistry, publishObject);
   }

protected:
   
   std::vector<char> myPropertyBuffer;
   DtClock myClock;
   DtTime myLastEncodeTime;
};

#endif