legionEventTranslator.h

Go to the documentation of this file.

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


#pragma once

#include <legionNetworkInterface/legionNetworkInterfaceDefines.h>
#include <tbb/spin_mutex.h>
#include <boost/signals2.hpp>

namespace makVrfEvents
{
   class DtEvent;
}

namespace Legion
{
   class EventManager;
   class ControlManager;
   class EventInstance;
};

namespace makVrf
{
   class DtLegionEventTranslatorManager;
   class DtLegionNetworkInterface;

   class DT_DLL_legionNetworkInterface DtLegionEventTranslator
   {
   public:
      DtLegionEventTranslator();

      virtual ~DtLegionEventTranslator();

      virtual void init(DtLegionNetworkInterface*);

      virtual bool processEvent(const makVrfEvents::DtEvent&, bool& selfReflected);
      virtual bool sendEventWithoutReflection(const makVrfEvents::DtEvent&);
   
      virtual void sendEvent(const makVrfEvents::DtEvent&, bool selfReflect) = 0;

      virtual void beginFrame();


      virtual void advanceFrame();

      virtual void setProcessSelfReflect(bool b);

      bool processSelfReflect() const
      {
         return myProcessSelfReflect;
      }

      boost::signals2::signal<void (const makVrfEvents::DtEvent&)> signal_receivedEvent;

   protected:
      virtual unsigned int addEvent(const Legion::EventInstance& inter, bool selfReflectOverride = false);

   protected:
      DtLegionNetworkInterface* myNetworkInterface;
      Legion::EventManager* myLegionEventManager;
      Legion::ControlManager* myLegionControlManager;
      bool myProcessSelfReflect;

      tbb::spin_mutex myQueuedEventsMutex;
      std::vector<std::pair<makVrfEvents::DtEvent*, bool> > myQueuedEvents;
   };
}