vrfTransporterSignalProcessor.h

Go to the documentation of this file.

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

#pragma once
#include "vrfMsgTransport/vrfSignalMessageProcessor.h"

#include "vrfMsgTransport/signalMessageTransporter.h"
#include "vrfMsgTransport/externalCommsMessageTransporter.h"

#include <boost/signals2.hpp>

class DtVrfSignalMessageParams;

class DT_DLL_vrfMsgTransport DtVrfTransporterSignalProcessor : public DtVrfSignalMessageProcessor
{
private:

   DtVrfTransporterSignalProcessor(const DtVrfTransporterSignalProcessor& orig);
   DtVrfTransporterSignalProcessor& operator=(const DtVrfTransporterSignalProcessor& orig);

protected:

   DtVrfTransporterSignalProcessor(const char* pName);

   virtual bool init();

public:

   virtual ~DtVrfTransporterSignalProcessor();

   virtual void installSelf(DtRadioMessageListener& rml);
   virtual void setEnabled(bool bIsEnabled);

   boost::signals2::signal<void (const DtVrfSignalMessageParams*, DtVrfObjectMessageConstPtr&)> signal_CommsFxMessageReceived;

   boost::signals2::signal<void (const DtVrfSignalMessageParams*, DtVrfObjectMessageConstPtr&)> signal_RadioMessageReceived;

public: 

   static DtVrfSignalMessageProcessor* create(const char* pName);

protected:

   static void newSignalMessageCallback(DtSignalMessageTransporterCallbackParams* pTransporterParams, void* usr);
   virtual void processNewSignalMessage(DtSignalMessageTransporterCallbackParams* pTransporterParams);

   static void newQualnetMessageCallback(const DtExternalCommsMessageTransporter::DtExternalCommsMessageCallbackParams& transporterParams, void* usr);
   virtual void processNewQualnetMessage(const DtExternalCommsMessageTransporter::DtExternalCommsMessageCallbackParams& transporterParams);

protected:

   DtExternalCommsMessageTransporter* pMyExternalCommsMessageTransporter;

   DtSignalMessageTransporter* pMySignalTransporter;

};