creRespMsg.h

Go to the documentation of this file.

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


#ifndef DtCreateResponseMsg_H_
#define DtCreateResponseMsg_H_

#include "rtiMsg.h"
#include "netRtiMsgHdr.h"
#include "netCrRespMsg.h"

class DtConnectionMgr;
class DtCreateResponseMsg;
typedef void (*DtCreateResponseCb)(const DtCreateResponseMsg& inter, void* usr);

enum DtCreateResponseFlag
{
   DtCRExecCreated,
   DtCRExecAlreadyExists,
   DtCRExecCouldNotOpenFed,
   DtCRExecCouldNotCreateTimeFactory,
   DtCRWaiting,   
   DtCRExecCouldNotMergeFed,
   DtCRExecErrorReadingFed,
   DtCRExecCouldNotBeCreatedDueToMaxExecHandles
};

class DT_DLL_LRC DtCreateResponseMsg : public DtRtiMsg
{
public:

   DtCreateResponseMsg(DtBufferPtr buffer = DtUSE_INTERNAL_BUFFER);

   DtCreateResponseMsg(unsigned long ID,
      DtCreateResponseFlag flag,
      MAKRti::DtString const & errorString,
      DtBufferPtr buffer = DtUSE_INTERNAL_BUFFER);

   DtCreateResponseMsg(const DtNetCreateResponseMsg* netRepMsg,
      DtBufferPtr buffer = DtUSE_INTERNAL_BUFFER);

   virtual ~DtCreateResponseMsg();

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

   virtual void set(unsigned long ID,
      DtCreateResponseFlag flag, MAKRti::DtString const & errorString);

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

   void setResponseFlag(DtCreateResponseFlag flag);
   DtCreateResponseFlag responseFlag() 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,
      DtCreateResponseCb cb, void* usr);
   static void removeCallback(DtConnectionMgr* conn,
      DtCreateResponseCb cb, void* usr);

   void setErrorString( MAKRti::DtString const & errorStr );
   MAKRti::DtString errorString() const;
   char* errorStringPtr();
   const char* errorStringPtr() const;
   void setErrorStringSize( unsigned long size );
   unsigned long errorStringSize() const;

protected:

   virtual DtNetCreateResponseMsg* netCreateResponseMsg();
   virtual const DtNetCreateResponseMsg* netCreateResponseMsg() const;

   virtual DtRtiMsgKind internalDtRtiMsgKind();

   virtual int minSize() const;

   virtual DtCreateResponseMsg* self() const;
};


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

#endif