signalMessageTransporter.h

Go to the documentation of this file.

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

#pragma once

#include "vrfMsgTransport/vrfMsgTransportDefines.h"
#include <vlpi/disEnums.h>
#include <vrfutil/rwUUID.h>
#include "vrfmsgs/vrfObjectMessage.h"
#include <readerWriter/noArgumentCallbackList.h>
#include <boost/signals2.hpp>

namespace makVrfEvents
{
   class DtEvent;
   class DtVrfSignalEvent;
}

class DtCommunicationManager;
class DtSignalMessageHeader;

struct DtSignalMessageParams
{
   DtSignalMessageParams() : senderDesignator(DtUUID::nullUUID()), radioIndex(0), sampleRate(0.) {};

   DtString commModelName;
   DtUUID senderDesignator;
   int radioIndex;
   double sampleRate;
};

typedef std::pair<DtSignalMessageParams*, DtVrfObjectMessageConstPtr> DtSignalMessageTransporterCallbackParams;

class DT_DLL_vrfMsgTransport DtSignalMessageTransporter
{
private:

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

protected:
   DtSignalMessageTransporter(DtCommunicationManager* exConn);
   virtual bool init();

public:
   static DtSignalMessageTransporter* create(DtCommunicationManager* exConn);

   virtual ~DtSignalMessageTransporter();

   bool enabled() const;
   virtual void setEnabled(bool bEnabled);

   virtual bool processVrfObjectMessageReceived(const DtSignalMessageParams& params,
      const char *pVrfObjectMessageBuffer);

   virtual void sendInteraction(const DtSignalMessageParams& params,
      int contentSize, const char* pContent);

   virtual void sendMessage(const DtSignalMessageParams& params, 
      const DtVrfObjectMessage* message);

   typedef DtCallbackList<DtSignalMessageTransporterCallbackParams*> DtMessageReceivedCallbackList;


   virtual void addMessageReceivedCallback(DtMessageReceivedCallbackList::DtCallbackFunctionType fcn,
      void* usr);
   virtual void removeMessageReceivedCallback(DtMessageReceivedCallbackList::DtCallbackFunctionType fcn,
      void* usr);
   virtual void processSignalInteraction(const makVrfEvents::DtVrfSignalEvent* inter);

protected:
   virtual void signalInteractionCallback(const makVrfEvents::DtEvent&);

   virtual void sendSignalInteraction(const makVrfEvents::DtVrfSignalEvent& signalInteraction);

protected:
   bool myEnabled;
   DtMessageReceivedCallbackList myMessageReceivedCallbacks;
   DtCommunicationManager* myCommunicationManager;
   boost::signals2::scoped_connection mySignalForVrfSignalEventConnection;
   DtClock myClock;
};

inline bool DtSignalMessageTransporter::enabled() const
{
   return myEnabled;
}