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 <vlutil/vlUtil.h>
#include <vector>
#include <set>

class DtVrfTDLMessage;
class DtVrfTDLMessageFactory;
class DtCommunicationManager;
class DtSimulationAddress;

namespace makVrfEvents
{
   class DtEventManager;
   class DtEvent;
   class DtDataEvent;
}

class DtVrfTDLMessageInterface;

typedef void (*DtVrfTDLMessageCallbackFcn)(DtVrfTDLMessage*, void* usr);
typedef DtVrfTDLMessageInterface* (*DtVrfTDLMessageInterfaceCreatorFcn)(DtCommunicationManager* exConn, bool useDefaultInterfaceFactory);

class DT_DLL_vrfMsgTransport DtVrfTDLMessageInterface
{
public:
   DtVrfTDLMessageInterface(DtCommunicationManager* 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);

   DtCommunicationManager* communicationManager() const;
   virtual void setCommunicationManager(DtCommunicationManager*);

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

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

   virtual bool receiveMessage(DtVrfTDLMessage* content);

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

   virtual bool receiveMessage(const makVrfEvents::DtDataEvent* dataInter);

   static DtVrfTDLMessageInterface* create(DtCommunicationManager* exConn, bool useDefaultInterfaceFactory = true);
   static DtVrfTDLMessageInterfaceCreatorFcn setCreator(DtVrfTDLMessageInterfaceCreatorFcn);
   static DtVrfTDLMessageInterfaceCreatorFcn creator();

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

   virtual bool setContentForNet(
      makVrfEvents::DtDataEvent* dataInter, DtVrfTDLMessage& content) const;

   virtual void netMessageCallback(const makVrfEvents::DtEvent&);

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

   virtual bool getContentFromNet(const makVrfEvents::DtDataEvent* 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

   DtCommunicationManager* myCommunicationManager;
   static DtVrfTDLMessageInterfaceCreatorFcn theCreatorFcn;
};

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

inline DtCommunicationManager* DtVrfTDLMessageInterface::communicationManager() const
{
   return myCommunicationManager;
}