dataQueryRPdu.h

Go to the documentation of this file.

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



#pragma once

#if DtDIS

#include "hostStructs.h"
#include "simanPdu.h"
#include "packets/dataQueryRP.h"
#include "exerciseConn.h"



class DT_DLL_VL DtDataQueryRPdu;

typedef void (*DtDataQueryRPduCb)(DtDataQueryRPdu* pdu, void* usr);

class DT_DLL_VL DtDataQueryRPdu : public DtSimanPdu
{
public:
   DtDataQueryRPdu(DtBufferPtr buffer = DtUSE_INTERNAL_BUFFER);
   DtDataQueryRPdu(const DtNetDataQueryRPdu* initial, 
      DtBufferPtr buffer = DtUSE_INTERNAL_BUFFER, DtPduFactory* pduFactory = 0);
   DtDataQueryRPdu(const DtDataQueryRPdu& orig);

   virtual ~DtDataQueryRPdu();

   DtDataQueryRPdu& operator=(const DtDataQueryRPdu& orig);

   virtual void setRequestId(unsigned long id);    
   virtual unsigned long requestId() const;

   virtual void setTimeInterval(DtTime seconds);   
   virtual DtTime timeInterval() const;

   virtual unsigned long numFixedFields() const;

   virtual unsigned long numVarFields() const;

   virtual int setFixedDatumId(int index, DtDatumParam id);
   virtual DtDatumParam fixedDatumId(int index) const;

   virtual int setVarDatumId(int index, DtDatumParam id); 
   virtual DtDatumParam varDatumId(int index) const;

   virtual void setReqRelService(DtRequiredReliabilityService value);
   virtual DtRequiredReliabilityService reqRelService() const;

   virtual void initDatumIds(unsigned long numFixedFields, 
      unsigned long numVarFields);

   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, 
      DtDataQueryRPduCb cb, void* usr);
   static void removeCallback(DtExerciseConn* conn, 
      DtDataQueryRPduCb cb, void* usr);

protected:

   virtual DtPduKind internalGetPduKind() const;

protected:

   static const int theStaticSize;

};

inline DtPduKind DtDataQueryRPdu::internalGetPduKind() const
{
   return DtDataQueryRPduKind;
}

#endif