syncPointQueryMsg.h

Go to the documentation of this file.

/*********************************************************************
** Copyright (c) 2004 MaK Technologies, Inc.
** All rights reserved.
*********************************************************************/
/*********************************************************************
** $RCSfile: syncPointQueryMsg.h,v $ $Revision: 1.6 $ $State: Exp $
*********************************************************************/


#ifndef DtSyncPointQueryMsg_H_
#define DtSyncPointQueryMsg_H_

#include "rtiMsg.h"
#include "netSyncPointQueryMsg.h"
#include "attrHandSet.h"
#include <vlutil/vlString.h>

class DtConnectionMgr;
class DtSyncPointQueryMsg;

enum DtSyncPointQueryKind
{
   DtSyncPointQueryPoints,
   DtSyncPointQueryStatus
};

typedef void (*DtSyncPointQueryCb)(const DtSyncPointQueryMsg& msg, void* usr);

class DT_DLL_LRC DtSyncPointQueryMsg : public DtRtiMsg
{
public:

   DtSyncPointQueryMsg(DtBufferPtr buffer = DtUSE_INTERNAL_BUFFER);

   DtSyncPointQueryMsg(
      DtSyncPointQueryKind kind,
      DtInteractionClassHandle classHandleValue,
      DtParameterHandle syncPointParameter,
      DtParameterHandle syncPointFederateParameter=0,
      DtBufferPtr buffer = DtUSE_INTERNAL_BUFFER);

   DtSyncPointQueryMsg(const DtNetSyncPointQueryMsg* netRepMsg,
      DtBufferPtr buffer = DtUSE_INTERNAL_BUFFER);

   virtual ~DtSyncPointQueryMsg();

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

   virtual void set(
      DtSyncPointQueryKind kind,
      DtInteractionClassHandle classHandleValue,
      DtParameterHandle syncPointParameter,
      DtParameterHandle syncPointFederateParameter=0);

   virtual void setQueryKind(DtSyncPointQueryKind kind);
   virtual DtSyncPointQueryKind queryKind() const;

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

   virtual void setSyncPointHandle(DtParameterHandle handle);
   virtual DtParameterHandle syncPointHandle() const;

   virtual void setSyncPointFederateHandle(DtParameterHandle handle);
   virtual DtParameterHandle syncPointFederateHandle() 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,
      DtSyncPointQueryCb cb, void *usr);
   static void removeCallback(DtConnectionMgr *conn,
      DtSyncPointQueryCb cb, void *usr);

protected:

   virtual DtNetSyncPointQueryMsg* netSyncPointQueryMsg();
   virtual const DtNetSyncPointQueryMsg* netSyncPointQueryMsg() const;

   virtual DtRtiMsgKind internalDtRtiMsgKind();

   virtual int minSize() const;

   virtual DtSyncPointQueryMsg* self() const;

protected:

};


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

#endif