influenceEventDispatcher.h

Go to the documentation of this file.

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

#pragma once
#include "vrfobjcore/vrfobjcoreDefines.h"
#include "vrfcore/influenceDispatcherServiceInterface.h"
#include <boost/signals2.hpp>
#include <unordered_map>
#include "readerWriter/noArgumentCallbackList.h"
#include "vrfMsgTransport/influenceEvent.h"
#include "vrfutil/rwUUID.h"
#include <tbb/spin_mutex.h>

class DtSimulationServices;

namespace makVrfEvents
{
   class DtEvent;
}

class DT_DLL_vrfobjcore DtInfluenceEventDispatcher : public DtInfluenceDispatcherServiceInterface
{
public:
   DtInfluenceEventDispatcher(DtSimulationServices* simServices);
   virtual ~DtInfluenceEventDispatcher();

   virtual bool init();

   virtual void registerForInfluenceEvents(const DtUUID& uuid, DtInfluenceEventFunction func, void* userData) override;
   virtual void unregisterForInfluenceEvents(const DtUUID& uuid, DtInfluenceEventFunction func, void* userData) override;

   virtual void registerForEventsByInfluenceName(const std::string& sInfluenceName, DtInfluenceEventFunction func, void* userData) override;
   virtual void unregisterForEventsByInfluenceName(const std::string& sInfluenceName, DtInfluenceEventFunction func, void* userData) override;

   virtual void processInfluence(const makVrfEvents::DtEvent& m);

protected:
   DtSimulationServices* mySimServices;
   boost::signals2::scoped_connection myInfluenceEventConnection;

   typedef DtCallbackList<std::shared_ptr<const makVrfEvents::DtInfluenceEvent> > CallbackList;
   typedef std::shared_ptr<CallbackList > CallbackListPtr;
   typedef std::unordered_map<DtUUID,  CallbackListPtr> CallbackMap;
   typedef std::map<std::string, CallbackListPtr> CallbackByInfluenceTypeMap;

   CallbackMap myRegisteredCallbacks;
   CallbackByInfluenceTypeMap myRegisteredByTypeCallbacks;

   tbb::spin_mutex myMutex;
};