queryPdu.h

Go to the documentation of this file.

/*********************************************************************
** Copyright (c) 1992-2010 VT MAK
** All rights reserved.
*********************************************************************/



#ifndef DtDataQueryPdu_H_
#define DtDataQueryPdu_H_

#if DtDIS

#include "hostStructs.h"
#include "simanPdu.h"


class DT_DLL_VL DtExerciseConn;
class DT_DLL_VL DtDataQueryPdu;

typedef DtDataQueryPdu DtDataQueryInteraction;

typedef void (*DtDataQueryPduCb)(DtDataQueryPdu *pdu, void *usr);

class DT_DLL_VL DtDataQueryPdu : public DtSimanPdu
{
public:

   enum {PduStaticSize=40 };

public:
   DtDataQueryPdu(DtBufferPtr buffer = DtUSE_INTERNAL_BUFFER);
   DtDataQueryPdu(const DtNetDataQueryPdu *initial, 
                  DtBufferPtr buffer = DtUSE_INTERNAL_BUFFER); 

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

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

   unsigned long numFixedFields() const;

   unsigned long numVarFields() const;

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

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

   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);    

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


protected:
   DtPduKind internalGetPduKind() const {return DtDataQueryPduKind;}
};

#endif
#endif