eventManager.h

Go to the documentation of this file.

/*******************************************************************************
** Copyright (c) 2019 MAK Technologies, Inc.
** All rights reserved.
*******************************************************************************/
#pragma once

#include "vrfMsgTransport/vrfMsgTransportDefines.h"
#include <vrfMsgTransport/events.h>
#include <tbb/spin_mutex.h>
#include <map>
#include <boost/signals2.hpp>


class DtEvent;
class DtEventManager;

typedef DtEventManager* (*DtEventManagerCreatorFcn)();

class DT_DLL_vrfMsgTransport DtEventManager
{
private:
   DtEventManager(const DtEventManager&);
   DtEventManager& operator=(const DtEventManager&);

public:
   DtEventManager();
   virtual ~DtEventManager();

   virtual void tick();

   virtual void addEvent(const DtEvent&);

   static void setEventManagerCreatorFcn(DtEventManagerCreatorFcn fcn);
   static DtEventManager* createEventManager();

   virtual void setProcessEventsImmediately(bool b);
   bool processEventsImmediately() const
   {
      return myProcessEventsImmediately;
   }

   virtual void selfReflect(unsigned int i);
   virtual void doNotSelfReflect(unsigned int i);

   virtual bool selfReflecting() const;

public:

   typedef boost::signals2::signal<void (const DtEvent&)> EventSignal;


   virtual EventSignal& signalForEvent(DtEvent::EventType type);

   EventSignal& signalForFireEvent();
   EventSignal& signalForDetonationEvent();
   EventSignal& signalForSimInterfaceContentMessage();
   EventSignal& signalForDataInteraction();
   EventSignal& signalForSignalInteraction();
   EventSignal& signalForCommentInteraction();
   EventSignal& signalForSensorFieldOfViewControlEvent();
   EventSignal& signalForStartResumeInteraction();
   EventSignal& signalForStopFreezeInteraction();
   EventSignal& signalDiGuyActionEvent();

#if DtHLA
   EventSignal& signalForInfluenceInteraction();
   EventSignal& signalDiGuyEndActionEvent();
#endif

   EventSignal& signalForServiceRequestEvent();
   EventSignal& signalForResupplyOfferEvent();
   EventSignal& signalForResupplyReceivedEvent();
   EventSignal& signalForResupplyCancelEvent();

public:
   virtual void addEvent(const DtDetonationInteraction&);
   virtual void addEvent(const DtFireInteraction&);
   virtual void addEvent(const DtAcknowledgeInteraction&);
   virtual void addEvent(const DtStopFreezeInteraction&);
   virtual void addEvent(const DtStartResumeInteraction&);
   virtual void addEvent(const DtDataInteraction&);
   virtual void addEvent(const DtSignalInteraction&);
   virtual void addEvent(const DtCommentInteraction&);
   virtual void addEvent(const DtSensorFieldOfViewControlInter&);
   virtual void addevent(const DtSimInterfaceContent&);

#if DtHLA
   virtual void addEvent(const DtDataInteractionWithTransportType&);
   virtual void addEvent(const DtInfluenceInteraction&);
   virtual void addEvent(const DtEndGestureInter&);
   virtual void addEvent(const DtExecuteGestureInter&);
#else
   virtual void addEvent(const DtDIGuyCustomPdu&);
#endif
   virtual void addEvent(const DtServiceRequestInteraction&);
   virtual void addEvent(const DtResupplyOfferInteraction&);
   virtual void addEvent(const DtResupplyRecInteraction&);
   virtual void addEvent(const DtResupplyCancelInteraction&);

protected:
   virtual void postEvent(const DtEvent&);

   virtual void processEvent(const DtEvent&);

   virtual bool wantsToProcessEvent(const DtEvent&) const;

protected:
   tbb::spin_mutex myMutex;
   std::vector<DtEvent*> myEvents;

   tbb::spin_mutex myCallbackMutex;
   typedef std::map<DtEvent::EventType, EventSignal*> EventCallbackMap;
   EventCallbackMap myEventCallbackMap;

   static DtEventManagerCreatorFcn theEventManagerCreatorFcn;

   bool myProcessEventsImmediately;

   std::set<unsigned int> myDoNotSelfReflect;
};