execConnectMsg.h

Go to the documentation of this file.

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


#ifndef DtRtiExecConnectMsg_H_
#define DtRtiExecConnectMsg_H_

#include "rtiMsg.h"
#include <vlutil/vlUtil.h>
#include <vlutil/vlInetAddr.h>
#include "netExecConnectMsg.h"

class DtConnectionMgr;
class DtRtiExecConnectMsg;

typedef void (*DtRtiExecConnectCb)(const DtRtiExecConnectMsg& inter, void* usr);

class DT_DLL_LRC DtRtiExecConnectMsg : public DtRtiMsg
{
public:

   DtRtiExecConnectMsg(DtBufferPtr buffer = DtUSE_INTERNAL_BUFFER);

   DtRtiExecConnectMsg(const DtNetExecConnectMsg* netRep,
      DtBufferPtr buffer = DtUSE_INTERNAL_BUFFER);

   DtRtiExecConnectMsg(DtHandle handle, const MAKRti::DtInetAddr& rootFwAddr, 
      int rootFwPort, const MAKRti::DtString& hostName, bool fullyCompliant,
      DtBufferPtr buffer = DtUSE_INTERNAL_BUFFER);

   virtual ~DtRtiExecConnectMsg();

   virtual DtRtiMsg* clone(bool copy = true) const; 

   virtual void set(DtHandle handle, const MAKRti::DtInetAddr& rootFwAddr,
      int rootFwPort, const MAKRti::DtString& hostName, bool fullyCompliant);

   virtual DtHandle connectionHandle() const;
   virtual void setConnectionHandle(DtHandle handle);

   virtual MAKRti::DtInetAddr rootForwarderAddr() const;
   virtual void setRootForwarderAddr(const MAKRti::DtInetAddr& addr);

   virtual int rootForwarderPort() const;
   virtual void setRootForwarderPort(int port);

   virtual MAKRti::DtInetUtils::DtInetAddrFamily addressFamily() const;
   virtual void setAddressFamily(MAKRti::DtInetUtils::DtInetAddrFamily fam);

   virtual void setHostName(const MAKRti::DtString& name);
   virtual MAKRti::DtString hostName() const;

   virtual void setFullyCompliant(bool fullCompliance);
   virtual bool fullyCompliant() 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,
      DtRtiExecConnectCb cb, void* usr, bool isMomCallback=false);
   static void removeCallback(DtConnectionMgr* conn,
      DtRtiExecConnectCb cb, void* usr, bool isMomCallback=false);

protected:

   virtual DtNetExecConnectMsg* netExecConnectMsg();
   virtual const DtNetExecConnectMsg* netExecConnectMsg() const;

   virtual DtRtiMsgKind internalDtRtiMsgKind();

   virtual char* hostNamePtr();
   virtual const char* hostNamePtr() const;
   virtual int hostNameSize() const;

   virtual int minSize() const;

   virtual DtRtiExecConnectMsg* self() const;

protected:

};

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

#endif