assistantMsg.h

Go to the documentation of this file.

/*********************************************************************
** Copyright (c) 1998 MaK Technologies, Inc.
** All rights reserved.
*********************************************************************/
/*********************************************************************
** $RCSfile: assistantMsg.h,v $ $Revision: 1.41 $ $State: Exp $
*********************************************************************/


#ifndef DtAssistantMsg_H_
#define DtAssistantMsg_H_

#include <memory>

#include <vlutil/vlBaseMsg.h>
#include <vlutil/vlString.h>
#include <vlutil/vlInetAddr.h>

#include <internalTypes.h>

#include "netAssistantMsgHdr.h"

class DtNetAssistantSrcDestInfo;

// Default port for all assistant communication
// When this is changed you must also update DtRIDParameters::verifyPortsAreUnique
#define DtASSISTANT_DEFAULT_PORT 6003

// Default multicast address for communication between assistants
#define DtASSISTANT_DEFAULT_IPV4_ADDR "229.7.7.10"
#define DtASSISTANT_DEFAULT_IPV6_ADDR "ff02::7:10"

// RTI 4.1.1  DtAssistantMessageVersion = 14
#define DtAssistantMessageVersion 14

enum DtAssistantMsgKind
{
   DtAssistantConnMsgKind                  = 0,
   DtAssistantLrcCompInfoMsgKind           = 1,
   DtAssistantRtiexecCompInfoMsgKind       = 2,
   DtAssistantNotifyMsgKind                = 3,
   DtAssistantConnQueryMsgKind             = 4,
   DtAssistantNtfyLvlUpdateMsgKind         = 5,
   DtAssistantExitMsgKind                  = 6,
   DtAssistantLicQueryMsgKind              = 7,
   DtAssistantPopupMsgKind                 = 8,
   DtAssistantShmCompInfoMsgKind           = 9,
   DtAssistantWwwCompInfoMsgKind           = 10,
   DtAssistantRtiForwarderCompInfoMsgKind  = 11,
   DtAssistantLogEnableMsgKind             = 12,
   DtAssistantChangeLatencyTestModeMsgKind = 13,
   DtAssistantLatencyReportMsgKind         = 14,
   DtAssistantTestMgrStatusMsgKind         = 15,
   DtAssistantShutdownMsgKind              = 16,
   DtAssistantStateObserveMsgKind          = 17,
   DtAssistantDeleteFederateMsgKind        = 18,
   DtAssistantDeleteFederationMsgKind      = 19,
   DtAssistantNetworkTestEnableMsgKind     = 20,
   DtAssistantFederationStateMsgKind       = 21,
   DtAssistantFederateStateMsgKind         = 22,
   DtAssistantTimeStateMsgKind             = 23,
   DtAssistantSyncPtUpdateMsgKind          = 24,
   DtAssistantCommandMsgKind               = 25,
   DtAssistantExecStateMsgKind             = 26,
   DtAssistantForwarderStateMsgKind        = 27,
   DtAssistantRidParamsMsgKind             = 28,
   DtAssistantLogRequestMsgKind            = 29,
   DtAssistantLogMsgKind                   = 30,
   DtAssistantShowDialogMsgKind            = 31,
   DtAssistantFederateSignalTickIntervalMsgKind    = 32,
   DtAssistantSignalTickedMsgKind          = 33,
   DtAssistantAwaitingForwardersMsgKind    = 34,
   DtAssistantNotifyObserveMsgKind         = 35,


   // Assistant to Assistant messages
   DtAssistantQueryMsgKind                 = 254,
   DtAssistantInfoMsgKind                  = 253,
   DtAssistantRemovalMsgKind               = 252,
   DtAssistantStartRtiexecMsgKind          = 251,
   DtAssistantExecObserveRspMsgKind        = 250,
   DtAssistantLightweightInfoMsgKind       = 249,
   DtAssistantLicServerInfoMsgKind         = 248,

   DtInvalidAssistantMsgKind               = 255
};

enum DtAssistantMsgReadStatus
{
   DtASSISTANT_READ_SUCCESS = 0,
   DtASSISTANT_READ_NO_PACKETS,
   DtASSISTANT_READ_BAD_PACKET,
   DtASSISTANT_READ_SERVER_MSG,
   DtASSISTANT_READ_SIZE_MISMATCH,
   DtASSISTANT_READ_FILTERED_PACKET,
   DtASSISTANT_QUEUED_PACKET,
   DtASSISTANT_INVALID_VERSION,
   DtASSISTANT_UNKNOWN_ERROR,
   DtASSISTANT_BUFFER_TOO_SMALL
};
class DT_DLL_ASSISTANT DtAssistantMsg : public MAKRti::DtBaseMsg
{
public:

   virtual ~DtAssistantMsg();

   virtual DtAssistantMsg* clone(bool copy = true) const=0; 

   virtual DtNetAssistantMsgHeader* netHeader() const;
           
   virtual int version() const;

   virtual bool isValidVersion() const;

   virtual DtAssistantMsgKind msgKind() const;

   virtual void print() const; 
   virtual void printHeader() const;
   virtual void printData() const;

   virtual bool isOk() const;

   bool isAssistantToAssistantMessage() const;

   virtual MAKRti::DtInetAddr sourceAddr() const;
   virtual void setSourceAddr(const MAKRti::DtInetAddr& addr);

   virtual int sourceId() const;
   virtual void setSourceId(int id);

   virtual MAKRti::DtString sourceHost() const;
   virtual void setSourceHost(const MAKRti::DtString& addr);

   virtual MAKRti::DtInetAddr destAddr() const;
   virtual void setDestAddr(const MAKRti::DtInetAddr& addr);

   virtual int destId() const;
   virtual void setDestId(int id);

   virtual int compId() const;
   virtual void setCompId( int compId );

public:

   static const char* kindToString(DtAssistantMsgKind kind);

protected:

   DtAssistantMsg();

   virtual DtAssistantMsgKind internalMsgKind() = 0;
   
   virtual void sizeChanged(int size);

   void initAssistantMsg(int size, DtAssistantMsgKind msgKindVal, DtBufferPtr buffer);
   void initAssistantMsg(const void *initial, int size, DtBufferPtr buffer);
   void initAssistantMsg(const DtNetAssistantMsgHeader *header, DtBufferPtr buffer);

   virtual void adjustBytes(int offset, int numBytes);

   virtual void adjustBytes(void *address, int numBytes);

   virtual void resizeForSrcDestInfo();

   virtual const DtNetAssistantSrcDestInfo* srcDestInfoPtr() const;
   virtual DtNetAssistantSrcDestInfo* srcDestInfoPtr();

   virtual void setSourceHostSize( unsigned long size );
   virtual unsigned long sourceHostSize() const;

   virtual const char* sourceHostPtr() const;
   virtual char* sourceHostPtr();

};

inline DtNetAssistantMsgHeader* DtAssistantMsg::netHeader() const
{
   return (DtNetAssistantMsgHeader*) netRep();
}

inline DtAssistantMsgKind DtAssistantMsg::msgKind() const
{
   return DtAssistantMsgKind((DtU32) (DtU8) netHeader()->msgKind);
}

inline bool DtAssistantMsg::isOk() const
{
   return true;
}

inline void DtAssistantMsg::adjustBytes(int offset, int numBytes)
{
   if (numBytes > 0)
   {
      insertBytes(offset, numBytes);
   }
   else if (numBytes < 0)
   {
      deleteBytes(offset, -numBytes);
   }
}

inline void DtAssistantMsg::adjustBytes(void *address, int numBytes)
{
   if (numBytes > 0)
   {
      insertBytes(address, numBytes);
   }
   else if (numBytes < 0)
   {
      deleteBytes(address, -numBytes);
   }
}

#endif