mcastConfigureMsg.h

Go to the documentation of this file.

/*********************************************************************
** Copyright (c) 2006 MaK Technologies, Inc.
** All rights reserved.
*********************************************************************/
/*********************************************************************
** $RCSfile: mcastConfigureMsg.h,v $ $Revision: 1.7 $ $State: Exp $
*********************************************************************/


#ifndef DtMcastConfigureMsg_H_
#define DtMcastConfigureMsg_H_

#include "rtiMsg.h"
#include "netRtiMsgHdr.h"
#include "netMcastConfigureMsg.h"
#include <vlutil/vlInetAddr.h>

class DtConnectionMgr;
class DtMcastConfigureMsg;
typedef void (*DtMcastConfigureMsgCb)(const DtMcastConfigureMsg& inter, void* usr);

enum DtMcastConfigFlags
{
   DtMcastListen,
   DtMcastDrop,
   DtMcastInvalid
};

class DT_DLL_LRC DtMcastConfigureMsg : public DtRtiMsg
{
public:

   DtMcastConfigureMsg(DtBufferPtr buffer = DtUSE_INTERNAL_BUFFER);

   DtMcastConfigureMsg(unsigned long ID, MAKRti::DtInetAddr mcastAddr, 
                       MAKRti::DtInetAddr interfaceAddr, DtMcastConfigFlags flag,
                       DtBufferPtr buffer = DtUSE_INTERNAL_BUFFER);

   DtMcastConfigureMsg(const DtNetMulticastConfigureMsg* netRepMsg,
                       DtBufferPtr buffer = DtUSE_INTERNAL_BUFFER);

   virtual ~DtMcastConfigureMsg();

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

   virtual void set(unsigned long ID, const MAKRti::DtInetAddr& mcastAddr, 
                    const MAKRti::DtInetAddr& interfaceAddr, DtMcastConfigFlags flag);

   void setSourceID( const unsigned long ID );
   const unsigned long sourceID() const;

   void setMcastAddr(const MAKRti::DtInetAddr& mcastAddr);
   MAKRti::DtInetAddr mcastAddr() const;

   void setInterfaceAddr(const MAKRti::DtInetAddr& interfaceAddr);
   MAKRti::DtInetAddr interfaceAddr() const;

   void setConfigFlag(DtMcastConfigFlags flag);
   DtMcastConfigFlags configFlag() 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,
      DtMcastConfigureMsgCb cb, void* usr);
   static void removeCallback(DtConnectionMgr* conn,
      DtMcastConfigureMsgCb cb, void* usr);

protected:

   virtual DtNetMulticastConfigureMsg* netMulticastConfigMsg();
   virtual const DtNetMulticastConfigureMsg* netMulticastConfigMsg() const;

   virtual DtRtiMsgKind internalDtRtiMsgKind();

   virtual int minSize() const;

   virtual DtMcastConfigureMsg* self() const;
};


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

#endif //! DtMcastConfigureMsg_H_