recordQueryPdu.h

Go to the documentation of this file.

/*********************************************************************
** Copyright (c) 1992-2013 MAK Technologies, Inc
** All rights reserved.
*********************************************************************/



#pragma once

#if DtDIS

#include <vlutil/vlMachineTypes.h>
#include "hostStructs.h"
#include "interactionDIS.h"
#include "exerciseConn.h"

#include "packets/recQueryP.h"


class DT_DLL_VL DtRecordQueryPdu;

typedef void (*DtRecordQueryPduCb)(DtRecordQueryPdu* pdu, void* usr);


class DT_DLL_VL DtRecordQueryPdu : public DtInteraction
{

public:

   DtRecordQueryPdu(DtBufferPtr buffer = DtUSE_INTERNAL_BUFFER);
   DtRecordQueryPdu(const DtNetRecordQueryPdu* initial,
      DtBufferPtr buffer = DtUSE_INTERNAL_BUFFER, DtPduFactory* pduFactory = 0);
   DtRecordQueryPdu(const DtRecordQueryPdu& orig);

   virtual ~DtRecordQueryPdu();

   DtRecordQueryPdu& operator=(const DtRecordQueryPdu& orig);

   virtual void setOriginatingEntityID(const DtEntityIdentifier& entity);
   virtual const DtEntityIdentifier& originatingEntityID() const;

   virtual void setReceivingEntityID(const DtEntityIdentifier& entity);
   virtual const DtEntityIdentifier& receivingEntityID() const;

   virtual void setRequestID(DtU32 id);
   virtual DtU32 requestID() const;

   virtual void setReqRelService(enum DtRequiredReliabilityService service);
   virtual DtRequiredReliabilityService reqRelService() const;

   virtual void setEventType(DtEventType type);
   virtual DtEventType eventType() const;

   virtual void setTime(DtU32 value);
   virtual DtU32 time() const;

   virtual bool setNumRecords(DtU32 num);
   virtual DtU32 numRecords() const;

   virtual bool setRecordID(int index, DtDatumParam value);
   virtual bool getRecordID(int index, DtDatumParam& value) const;

   virtual void printData() const;

   virtual void printDataToStream(std::ostream &stream) const;

public:

   static DtPdu* create(const DtNetPacket* initial,
      DtBufferPtr buffer = DtUSE_INTERNAL_BUFFER, DtPduFactory* pduFactory = 0);

   static void addCallback(DtExerciseConn* conn,
      DtRecordQueryPduCb cb, void* usr);
   static void removeCallback(DtExerciseConn* conn,
      DtRecordQueryPduCb cb, void* usr);

protected:

   virtual DtPduKind internalGetPduKind() const;

   virtual DtNetRecordQueryPdu* netPduStruct()  const; 

   DtRecordQueryPdu* self() const;

   virtual char* var() const;

protected:

   static const int theStaticSize;

protected:

   DtEntityIdentifier myEntityID;

};

#endif