reconnectMsg.h

Go to the documentation of this file.

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


#ifndef DtReconnectMsg_H_
#define DtReconnectMsg_H_

#include "rtiMsg.h"
#include "netReconnectMsg.h"

class DtConnectionMgr;
class DtReconnectMsg;
typedef void (*DtReconnectMsgCb)(const DtReconnectMsg& inter, void* usr);

class DT_DLL_LRC DtReconnectMsg : public DtRtiMsg
{
public:
   enum DtReconnectStatus {
      DtReconnectRequest = 0,
      DtReconnectAccepted,
      DtReconnectDenied
   };
     
   DtReconnectMsg(DtBufferPtr buffer = DtUSE_INTERNAL_BUFFER);

   DtReconnectMsg(const DtNetReconnectMsg* netRep,
      DtBufferPtr buffer = DtUSE_INTERNAL_BUFFER );

   DtReconnectMsg( DtHandle oldConnId, 
                   DtHandle newConnId,
                   DtFederateHandle fedId,
                   DtReconnectStatus status,
                   DtBufferPtr buffer = DtUSE_INTERNAL_BUFFER );

   virtual ~DtReconnectMsg();

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

   virtual void set( DtHandle oldConnId, DtHandle newConnId, DtFederateHandle fedId,
                     DtReconnectStatus status );

   // Set / get old connection handle
   virtual DtHandle oldConnectionHandle() const;
   virtual void setOldConnectionHandle(DtHandle handle);

   virtual DtHandle newConnectionHandle() const;
   virtual void setNewConnectionHandle(DtHandle handle);

   virtual DtReconnectStatus reconnectStatus() const;
   virtual void setReconnectStatus( DtReconnectStatus status );

   virtual DtFederateHandle federateHandle() const;
   virtual void setFederateHandle(DtFederateHandle handle);

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

protected:

   virtual DtNetReconnectMsg* netReconnectMsg();
   virtual const DtNetReconnectMsg* netReconnectMsg() const;

   virtual DtRtiMsgKind internalDtRtiMsgKind();

   virtual int minSize() const;

   virtual DtReconnectMsg* self() const;

protected:

};


inline DtReconnectMsg* DtReconnectMsg::self() const
{
   return (DtReconnectMsg*) this;
}

#endif