vrfTDLMessageInterface.h

Go to the documentation of this file.

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

#pragma once

#include "vrfMsgTransport/vrfMsgTransportDefines.h"
#include "vrfMsgTransport/eventManager.h"

#include <vlutil/vlMachineTypes.h>

#include <vlutil/vlUtil.h>
#include <vl/dataInteraction.h>
#include <vl/interClassDesc.h>
#include <vl/rtiCompatibility.h>

class DtVrfTDLMessage;
class DtVrfTDLMessageFactory;

typedef void (*DtVrfTDLMessageCallbackFcn)(DtVrfTDLMessage*, void* usr);

class DT_DLL_vrfMsgTransport DtVrfTDLMessageInterface
{
public:
   DtVrfTDLMessageInterface(DtEventManager* eventManager, 
      bool useDefaultInterfaceFactory = true);

   virtual ~DtVrfTDLMessageInterface();

   virtual bool init();

   virtual bool createAndDeliverMessage(
      const DtSimulationAddress& recipient, 
      const DtVrfTDLMessage & content,
      bool overrideTimestampOrder = true);

   virtual const DtSimulationAddress& messageAddress() const;

   virtual bool sendMessage(DtVrfTDLMessage& message);

   DtEventManager* eventManager() const;

   virtual void clearEventManager();

   virtual void setSequence(DtU32 num);
   virtual DtU32 sequence() const;

   virtual void addVrfTDLMessageCallback(DtVrfTDLMessageCallbackFcn fcn, void* usr);
   virtual void removeVrfTDLMessageCallback(DtVrfTDLMessageCallbackFcn fcn, void* usr);

   virtual void setEventManager(DtEventManager*);

   virtual bool receiveMessage(DtVrfTDLMessage* content);

   virtual DtVrfTDLMessageFactory* factory() const;
   virtual void setFactory(DtVrfTDLMessageFactory* fact);

protected:
   virtual void removeConnections();
   virtual void initializeConnections();

   virtual bool setContentForNet(
      DtDataInteraction* dataInter, DtVrfTDLMessage& content) const;

   virtual void netMessageCallback(const DtEvent&);

   virtual void receiveMessage(DtDataInteraction* dataInter);

   virtual bool matchPattern(const DtSimulationAddress& address,
                  const DtSimulationAddress& pattern) const;

   virtual bool getContentFromNet(DtDataInteraction* dataInter,
      DtVrfTDLMessage*& content) const;

   virtual bool getContentFromNet(unsigned nBufferSize,
      const char* pContentBuffer,
      DtVrfTDLMessage*& content) const;

   virtual void invokeCallbacks(DtVrfTDLMessage*);

private:

   DtVrfTDLMessageInterface(const DtVrfTDLMessageInterface& orig);

   DtVrfTDLMessageInterface& operator=(
      const DtVrfTDLMessageInterface& orig);

   DtVrfTDLMessageInterface();

protected:
   DtU32 mySequenceNumber;
   bool myAllowReliableDataInteractions;
   bool myUseReliableTransport;
   DtVrfTDLMessageFactory* myFactory;
   bool myCreatedInterfaceFactory;
    
   typedef std::vector<std::pair<DtVrfTDLMessageCallbackFcn, void*> > CallbackData;
   CallbackData myCallbacks;

   DtVrfTDLMessage* myVrfTDLMessageTranslator;

#ifdef DtHLA
   std::set<int> myContentTypesToSendReliable;
#endif

   DtEventManager* myEventManager;
   bool myOwnsEventManager;
};

inline DtU32 DtVrfTDLMessageInterface::sequence() const
{
  return mySequenceNumber;
}

inline void DtVrfTDLMessageInterface::clearEventManager()
{
   if (myOwnsEventManager)
   {
      delete myEventManager;
   }

   myEventManager = 0;
}

inline DtEventManager* DtVrfTDLMessageInterface::eventManager() const
{
   return myEventManager;
}