ownerMsg.h

Go to the documentation of this file.

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


#ifndef DtOwnershipMsg_H_
#define DtOwnershipMsg_H_

#include "rtiMsConfig.h"
#include "rtiMsg.h"
#include "netOwnerMsg.h"
#include "attrHandSet.h"

class DtConnectionMgr;
class DtOwnershipMsg;
typedef void (*DtOwnershipCb)(const DtOwnershipMsg& msg, void* usr);

enum DtOwnerMsgKind
{
   DtAcquire,
   DtAcquireIfAvail,
   DtCancelAcquire,
   DtCancelNegotiatedDivest,
   DtNegotiatedDivest,
   DtQueryOwner,
   DtUncondDivest,
   DtNotOwned,
   DtOwnedByRti,
   DtNotifyAcquire,
   DtOwnershipUnavail,
   DtConfirmCancelAcquire,
   DtInformOwner,
   DtGiveToLRC,
   DtResetOwner,
   DtMomTransfer,
   DtQueryAttrTransportType
};

class DT_DLL_LRC DtOwnershipMsg : public DtRtiMsg
{
public:

   DtOwnershipMsg(DtBufferPtr buffer = DtUSE_INTERNAL_BUFFER);

   DtOwnershipMsg(
      DtOwnerMsgKind kind,
      DtObjectInstanceHandle objHand, 
      const DtAttributeHandleSet& attrs,
      DtFederateHandle targetFed = 0,
#ifdef DtIFSPEC1516
      rti1516::VariableLengthData const& theTag=theDefaultTag,
#elif defined(DtIFSPEC1516E)
      rti1516e::VariableLengthData const& theTag=theDefaultTag,
#else
      char const * theTag=NULL,
#endif
      DtBufferPtr buffer = DtUSE_INTERNAL_BUFFER);

   DtOwnershipMsg(
      DtOwnerMsgKind kind,
      DtObjectInstanceHandle objHand, 
      const DtAttributeHandle attr,
      DtFederateHandle targetFed = 0,
#ifdef DtIFSPEC1516
      rti1516::VariableLengthData const& theTag=theDefaultTag,
#elif defined(DtIFSPEC1516E)
      rti1516e::VariableLengthData const& theTag=theDefaultTag,
#else
      char const * theTag=NULL,
#endif
      DtBufferPtr buffer = DtUSE_INTERNAL_BUFFER);

   DtOwnershipMsg(const DtNetOwnershipMsg* netRepMsg,
      DtBufferPtr buffer = DtUSE_INTERNAL_BUFFER);

   virtual ~DtOwnershipMsg();

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

   virtual void set(
      DtOwnerMsgKind kind,
      DtObjectInstanceHandle objHand, 
      const DtAttributeHandleSet& attrs,
      DtFederateHandle targetFed = 0,
#ifdef DtIFSPEC1516
      rti1516::VariableLengthData const& theTag=theDefaultTag);
#elif defined(DtIFSPEC1516E)
      rti1516e::VariableLengthData const& theTag=theDefaultTag);
#else
      char const * theTag=theDefaultTag);
#endif

   virtual void set (
      DtOwnerMsgKind kind,
      DtObjectInstanceHandle objHand, 
      const DtAttributeHandle attr,
      DtFederateHandle targetFed = 0,
#ifdef DtIFSPEC1516
      rti1516::VariableLengthData const& theTag=theDefaultTag);
#elif defined(DtIFSPEC1516E)
      rti1516e::VariableLengthData const& theTag=theDefaultTag);
#else
      char const * theTag=theDefaultTag);
#endif

   virtual void setOwnerMsgKind(DtOwnerMsgKind kind);
   virtual DtOwnerMsgKind ownerMsgKind() const;

   virtual void setObjHandle(DtObjectInstanceHandle id);
   virtual DtObjectInstanceHandle objHandle() const;

   virtual void setClassHandle(DtObjectClassHandle handle);
   virtual DtObjectClassHandle classHandle() const;

#ifdef DtIFSPEC1516
   virtual void setTag(rti1516::VariableLengthData const& tag);
   virtual rti1516::VariableLengthData const& tag() const;
#elif defined(DtIFSPEC1516E)
   virtual void setTag(rti1516e::VariableLengthData const& tag);
   virtual rti1516e::VariableLengthData const& tag() const;
#else
   virtual void setTag(char const * tag);
   virtual char const * tag() const;
#endif

   virtual void setRecipientFederate(DtFederateHandle hand);
   virtual DtFederateHandle recipientFederate() const;

   virtual void setAttrHandles(const DtAttributeHandleSet& attrs);
   virtual const DtAttributeHandleSet& attrHandles() 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, 
      DtOwnershipCb cb, void *usr);
   static void removeCallback(DtConnectionMgr *conn, 
      DtOwnershipCb cb, void *usr);
   
protected:
   
   virtual char* tagPtr();

   virtual int tagFieldSize() const;

   virtual DtNetOwnershipMsg* netOwnershipMsg();
   virtual const DtNetOwnershipMsg* netOwnershipMsg() const;

   virtual DtRtiMsgKind internalDtRtiMsgKind();

   virtual int minSize() const;

   virtual DtOwnershipMsg* self() const;

protected:

   int myDirty;   
   DtAttributeHandleSet* myAttrs;
#ifdef DtIFSPEC1516
   rti1516::VariableLengthData* myTag;
#elif defined(DtIFSPEC1516E)
   rti1516e::VariableLengthData* myTag;
#else
   char* myTag;
#endif
};


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

#endif