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,
   DtUnauthorized
};

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;

   void setErrorString(MAKRti::DtString const& errorStr);
   MAKRti::DtString errorString() 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);

protected:


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

   virtual DtRtiMsgKind internalDtRtiMsgKind();

   virtual int minSize() const;

   virtual DtCreateResponseMsg* self() const;


   void setErrorStringSize(unsigned long size);
   unsigned long errorStringSize() const;


   char* errorStringPtr();
   const char* errorStringPtr() const;

};


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

#endif