objRegSetMsg.h

Go to the documentation of this file.

/*********************************************************************
** Copyright (c) 2001 MaK Technologies, Inc.
** All rights reserved.
*********************************************************************/
/*********************************************************************
** $RCSfile: objRegSetMsg.h,v $ $Revision: 1.15 $ $State: Exp $
*********************************************************************/


#ifndef DtObjRegSetMsg_H_
#define DtObjRegSetMsg_H_
#ifdef DDM

#include "rtiMsg.h"
#include "netObjRegMsg.h"
#include <vlutil/vlInetAddr.h>


class DtRegionSet;
class DtConnectionMgr;
class DtObjRegSetMsg;

enum DtObjRegSetType
{
   DtObjPubRegSet,
   DtObjSubRegSet
};

typedef void (*DtObjRegSetCb)(const DtObjRegSetMsg& msg, void* usr);

class DT_DLL_LRC DtObjRegSetMsg : public DtRtiMsg
{
public:

   DtObjRegSetMsg(DtBufferPtr buffer = DtUSE_INTERNAL_BUFFER);

   DtObjRegSetMsg(DtObjRegSetType type,
      const DtRegionSet &regionSet,
      DtBufferPtr buffer = DtUSE_INTERNAL_BUFFER);

   DtObjRegSetMsg(const DtNetObjRegSetMsg* netRepMsg,
      DtBufferPtr buffer = DtUSE_INTERNAL_BUFFER);

   virtual ~DtObjRegSetMsg();

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

   virtual void set(DtObjRegSetType type,
      const DtRegionSet &regionSet);

   virtual void setRegionSetType(DtObjRegSetType type);
   virtual DtObjRegSetType regionSetType() const;

   virtual void setRegionSetHandle(DtRegionHandle handleValue);
   virtual DtRegionHandle regionSetHandle() const;

   virtual void setAddress(const MAKRti::DtInetAddr& addressValue);
   virtual MAKRti::DtInetAddr address() const;

   virtual unsigned long numberRegions() const;      
   
   virtual const DtRegionHandle* regions() const;

   virtual void reserveRegionSlots(unsigned long numberRegions);

   virtual void addRegion(DtRegionHandle handleValue);

   virtual void printData(DtLogicalTimeFactory* logicalTimeFactory) const;

public:

   static DtRtiMsg* create(const DtNetMsgHeader* initial, 
                   DtBufferPtr buffer);

   static DtRtiMsg* create(DtBufferPtr buffer = DtUSE_INTERNAL_BUFFER);

   static void addCallback(DtConnectionMgr *conn, 
                  DtObjRegSetCb cb, void *usr);

   static void removeCallback(DtConnectionMgr *conn, 
                     DtObjRegSetCb cb, void *usr);

protected:
   
   virtual DtNetU32* netRegions();

   virtual DtNetObjRegSetMsg* netObjRegSetMsg();
   virtual const DtNetObjRegSetMsg* netObjRegSetMsg() const;

   virtual DtRtiMsgKind internalDtRtiMsgKind();

   virtual int minSize() const;

   virtual DtObjRegSetMsg* self() const;

protected:
   unsigned long myRegionCount;
   unsigned long myReservedSlotCount;
   DtRegionHandle* myRegions;
   bool myDirty;
};


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

#endif
#endif