fomModuleRequestMsg.h

Go to the documentation of this file.

/**************************************************************************
** Copyright (c) 2024 MAK Technologies
** All rights reserved.
***************************************************************************/


#pragma once

#include "rtiMsg.h"
#include "netFomModuleRequestMsg.h"

#include <vlutil/vlString.h>

class DtConnectionMgr;
class DtFomModuleRequestMsg;
typedef void (*DtFomModuleReqCb)(const DtFomModuleRequestMsg& inter, void* usr);

class DT_DLL_LRC DtFomModuleRequestMsg : public DtRtiMsg
{
public:

   DtFomModuleRequestMsg( DtBufferPtr buffer = DtUSE_INTERNAL_BUFFER );

   DtFomModuleRequestMsg(
            unsigned long ID,
            unsigned long destID,
            const MAKRti::DtString& fedExNameVal,            
            std::vector<MAKRti::DtString> const& moduleNames,
            DtBufferPtr buffer = DtUSE_INTERNAL_BUFFER);

   DtFomModuleRequestMsg( const DtNetFomModuleReqMsg* netRepMsg,
      DtBufferPtr buffer = DtUSE_INTERNAL_BUFFER );

   virtual ~DtFomModuleRequestMsg();

   DtRtiMsg* clone(bool copy = true) const;

   // Set all fields  (adjust buffer size if not pre-allocated for this data).
   virtual void set(unsigned long ID, unsigned long destID, const MAKRti::DtString& fedExNameVal,
      std::vector<MAKRti::DtString> const& fomModuleName, bool adjustBufferSize = true );

   void setSourceID( unsigned long ID );
   unsigned long sourceID() const;

   void setDestinationID( unsigned long ID );
   unsigned long destinationID() const;

   virtual void setFullFedExName( const MAKRti::DtString& fedExNameVal, bool adjustBufferSize = true );
   virtual MAKRti::DtString fullFedExName() const;

   virtual void setFomModuleNames( std::vector<MAKRti::DtString> const& fomModuleName, bool adjustBufferSize = true);
   virtual void getFomModuleNames( std::vector<MAKRti::DtString>& modules ) const;

   virtual void printData(DtLogicalTimeFactory* logicalTimeFactory) const;

public:
   static DtRtiMsg* create( const DtNetMsgHeader* initial,
      DtBufferPtr buffer = DtUSE_INTERNAL_BUFFER );

   static DtRtiMsg* create( DtBufferPtr buffer = DtUSE_INTERNAL_BUFFER );

   static void addCallback(DtConnectionMgr* conn,
      DtFomModuleReqCb cb, void* usr);
   static void removeCallback(DtConnectionMgr* conn,
      DtFomModuleReqCb cb, void* usr);

protected:

   virtual const DtNetFomModuleReqMsg* netFomModuleReqMsg() const;
   virtual DtNetFomModuleReqMsg* netFomModuleReqMsg();

   virtual DtRtiMsgKind internalDtRtiMsgKind();

   virtual int minSize() const;

   virtual int minSize( const MAKRti::DtString& fedExNameVal, std::vector<MAKRti::DtString> const& fomModulesNamesVal);

   virtual void setFedExNameSize( unsigned long size );
   virtual unsigned int fedExNameSize() const; 

   virtual void setFomModuleNamesSize( unsigned long size );
   virtual unsigned int fomModuleNamesSize() const;

   virtual char* fedExNamePtr();
   virtual char* fomModuleNamesPtr();

   virtual const char* fedExNamePtr() const;
   virtual const char* fomModuleNamesPtr() const;

   virtual DtFomModuleRequestMsg* self() const;

};

inline DtFomModuleRequestMsg* DtFomModuleRequestMsg::self() const
{
   return const_cast<DtFomModuleRequestMsg*>( this );
}