radioReceiverStateComponent.h

Go to the documentation of this file.

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

#pragma once

#include "vrfStateData/vrfStateDataDefines.h"
#include "vrfStateData/doubleBufferedDataStorage.h"
#include "vrfStateData/stateComponent.h"
#include "vrfutil/rwUUID.h"
#include <legionStandardOM/sets/readRadioReceiverRepository.hpp>
#include <legionStandardOM/sets/writeRadioReceiverRepository.hpp>

namespace makVrf
{
   struct DT_DLL_vrfStateData DtRadioReceiverStateComponentData
   {
      DtRadioReceiverStateComponentData()
      : myHostId(DtUUID::nullUUID())
      , myTransmitterId(DtUUID::nullUUID())
      , myReceiverState(0)
      , myReceivedPower(0)
      , myRadioId(0)
      {
      }

      DtRadioReceiverStateComponentData(const DtRadioReceiverStateComponentData& orig)
      : myHostId(orig.myHostId)
      , myTransmitterId(orig.myTransmitterId)
      , myReceiverState(orig.myReceiverState)
      , myReceivedPower(orig.myReceivedPower)
      , myRadioId(orig.myRadioId)
      {
      }

      DtRadioReceiverStateComponentData& operator=(const DtRadioReceiverStateComponentData& orig)
      {
         myHostId = orig.myHostId;
         myTransmitterId = orig.myTransmitterId;
         myReceivedPower = orig.myReceivedPower;
         myReceiverState = orig.myReceiverState;
         myRadioId = orig.myRadioId;

         return *this;
      }

      DEFINE_ACCESSOR_MUTATOR(DtUUID, hostId, HostId)
      DEFINE_ACCESSOR_MUTATOR(DtUUID, transmitterId, TransmitterId)
      DEFINE_ACCESSOR_MUTATOR(unsigned int, receiverState, ReceiverState)
      DEFINE_ACCESSOR_MUTATOR(UInt64, radioId, RadioId)
      DEFINE_ACCESSOR_MUTATOR(float, receivedPower, ReceivedPower)

   protected:
      DtUUID myHostId;
      DtUUID myTransmitterId;
      unsigned int myReceiverState;
      float myReceivedPower;
      UInt64 myRadioId;
   };

   class DT_DLL_vrfStateData DtRadioReceiverStateComponent : public DtFrameStateInterface
   {
   public:
      DEFINE_STATE_COMPONENT_TYPE(DtStateComponent::RadioReceiverStateComponent)

      DtRadioReceiverStateComponent(DtStateData* storage)
      : DtFrameStateInterface(storage)
      {
      }

      UNDEFINED_RETURNVALUE_ACCESSOR(DtUUID, hostId)
      UNDEFINED_RETURNREF_ACCESSOR_MUTATOR(DtUUID, transmitterId, TransmitterId)
      UNDEFINED_RETURNVALUE_ACCESSOR_MUTATOR(unsigned int, receiverState, ReceiverState)
      UNDEFINED_RETURNVALUE_ACCESSOR_MUTATOR(UInt64, radioId, RadioId)
      UNDEFINED_RETURNVALUE_ACCESSOR_MUTATOR(float, receivedPower, ReceivedPower)
   };

   class DT_DLL_vrfStateData DtRadioReceiverStateComponentNextFrame : public DtRadioReceiverStateComponent
   {
   public:
      DtRadioReceiverStateComponentNextFrame(DtStateData* storage);
      virtual ~DtRadioReceiverStateComponentNextFrame() override;

      const DtRadioReceiverStateComponentData& frameState() const { return myData; };
      DtRadioReceiverStateComponentData& frameState() { return myData; };

      virtual const DtUUID hostId() const override;

      virtual const DtUUID& transmitterId() const override;
      virtual void setTransmitterId(const DtUUID&) override;

      virtual const unsigned int receiverState() const override;
      virtual void setReceiverState(const unsigned int&) override;

      virtual const UInt64 radioId() const override;
      virtual void setRadioId(const UInt64&) override;

      virtual const float receivedPower() const override;
      virtual void setReceivedPower(const float&) override;

      virtual void makeWritable() override;

      virtual void makeReadOnly() override;

      virtual Legion::WriteStateInstance writeStateInstance() override;
      virtual void updateStateData(DtStateData*) override;

      void cleanupWriteState();
      void setPublishingOnLegionNetwork(bool b);

   protected:
      DtRadioReceiverStateComponentData myData;
      LOM::WriteRadioReceiverRepository myWriteRadioReceiverRepository;
      bool myPublishingOnLegionNetwork;
   };

   class DT_DLL_vrfStateData DtRadioReceiverStateComponentCurrentFrame : public DtRadioReceiverStateComponent
   {
   public:
      DtRadioReceiverStateComponentCurrentFrame(DtStateData* storage);
      virtual ~DtRadioReceiverStateComponentCurrentFrame() override;

      const DtRadioReceiverStateComponentData& frameState() const { return myData; };

      virtual const DtUUID hostId() const override;
      virtual const DtUUID& transmitterId() const override;
      virtual const unsigned int receiverState() const override;
      virtual const UInt64 radioId() const override;
      virtual const float receivedPower() const override;

      bool readComponentValid() const;
      bool findReadComponent();

      virtual void updateStateData(DtStateData*) override;

   protected:
      friend class DtRadioReceiverStateComponentImplementation;
      void advanceFrame(const DtRadioReceiverStateComponentData& data)
      {
         myData = data;
      }
      virtual void handleDataUpdated();

   protected:
      DtRadioReceiverStateComponentData myData;
      LOM::ReadRadioReceiverRepository myReadRadioReceiverRepository;
      int myCallbackHandle;
   };

   class DT_DLL_vrfStateData DtRadioReceiverStateComponentImplementation : public DtDoubleBufferedStateComponent<DtRadioReceiverStateComponent>
   {
   public:
      DtRadioReceiverStateComponentImplementation(DtStateData* sd);

      bool isDoubleBuffered() { return true; };
      virtual const DtFrameStateInterface* currentFrameState() const override { return &myCurrentFrameState; }
      virtual DtFrameStateInterface* nextFrameState() override { return &myNextFrameState; };
      virtual const DtFrameStateInterface* nextFrameState() const override { return &myNextFrameState; };

      virtual void updateDataStorage() override
      {
         if (myNextFrameState.isWritable())
         {
            myCurrentFrameState.advanceFrame(myNextFrameState.frameState());
         }
         myCurrentFrameState.emitComponentUpdated();
      }

      virtual bool forceAdvance() override;

      virtual void firstFrameAdvance() override;

      virtual void updateStateData(DtStateData* sd) override
      {
         myCurrentFrameState.updateStateData(sd);
         myNextFrameState.updateStateData(sd);
      }

      virtual void aboutToBeDeleted() override
      {
         DtDoubleBufferedStateComponent<DtRadioReceiverStateComponent>::aboutToBeDeleted();
         myCurrentFrameState.aboutToBeDeleted();
         myNextFrameState.aboutToBeDeleted();
      }

      virtual void completeSetup() override;
      virtual void removeAdditionalStateComponents() override;
      virtual void setPublishingOnLegionNetwork(bool b) override;

   protected:
      DtRadioReceiverStateComponentCurrentFrame myCurrentFrameState;
      DtRadioReceiverStateComponentNextFrame myNextFrameState;
      bool myFoundComponent;
   };

   typedef DtStateComponentCreator<DtRadioReceiverStateComponentImplementation> DtRadioReceiverStateComponentCreator;
}