resupplyCancelPdu.h

Go to the documentation of this file.

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



#pragma once

#if DtDIS

#include "hostStructs.h"
#include "pdu.h"
#include <matrix/vlMath.h>
#include "packets/logisticsP.h"
#include "interaction.h"


class DT_DLL_VL DtExerciseConn;

class DT_DLL_VL DtResupplyCancelPdu;
typedef DtResupplyCancelPdu DtResupplyCancelInteraction;
typedef void (*DtResupplyCancelPduCb)(DtResupplyCancelPdu *pdu, void *usr);

class DT_DLL_VL DtResupplyCancelPdu : public DtInteraction
{
public:

   enum { PduStaticSize=24 };

public:

   DtResupplyCancelPdu(DtBufferPtr buffer = DtUSE_INTERNAL_BUFFER);
   DtResupplyCancelPdu(const DtNetResupplyCancelPdu *initial,
                       DtBufferPtr buffer = DtUSE_INTERNAL_BUFFER, DtPduFactory* pduFactory = 0);
   DtResupplyCancelPdu(const DtEntityIdentifier &receiveId,
                       const DtEntityIdentifier &supplyId,
                       DtBufferPtr buffer = DtUSE_INTERNAL_BUFFER);

   virtual ~DtResupplyCancelPdu() {};

   const DtEntityIdentifier &receivingId() const;
   void setReceivingId(const DtEntityIdentifier &id);

   const DtEntityIdentifier &supplyingId() const;
   void setSupplyingId(const DtEntityIdentifier &id);

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

protected:

   DtPduKind internalGetPduKind() const {return DtResupplyCancelPduKind;}
   DtEntityIdentifier theId;

};

/*******************************************************/
/******************* RESUPPLY OFFER PDU ****************/
/*******************************************************/

#define DtSUPPLY_VALID 1
#define DtSUPPLY_BAD_INDEX 0

class DT_DLL_VL DtResupplyOfferPdu;
typedef DtResupplyOfferPdu DtResupplyOfferInteraction;
typedef void (*DtResupplyOfferPduCb)(DtResupplyOfferPdu *pdu, void *usr);

class DT_DLL_VL DtResupplyOfferPdu : public DtInteraction
{
public:

   enum { PduStaticSize=28 };

public:


   DtResupplyOfferPdu(DtBufferPtr buffer = DtUSE_INTERNAL_BUFFER);
   DtResupplyOfferPdu(const DtNetResupplyOfferPdu *initial,
                      DtBufferPtr buffer = DtUSE_INTERNAL_BUFFER, DtPduFactory* pduFactory = 0);

   DtResupplyOfferPdu(const DtEntityIdentifier &receiver,
                      const DtEntityIdentifier &supplier,
                      const DtEntityType &supply,
                      float quantity,
                      DtBufferPtr buffer = DtUSE_INTERNAL_BUFFER);

   const DtEntityIdentifier &supplyingId() const;
   void  setSupplyingId(const DtEntityIdentifier &servicer);

   int   numSupplyTypes() const; 
   void  setNumSupplyTypes(int numTypes);

   float supplyQuantity(const DtEntityType &supply) const;

   void  setReceivingId(const DtEntityIdentifier &requester);
   const DtEntityIdentifier &receivingId() const;

   const DtEntityType &nthSupply(int supplyIndex,
                                 float *quantity = 0,
                                 int *retCode = 0) const;
   void  setNthSupply(int supplyIndex,
                         const DtEntityType &supply,
                         float quantity,
                         int *retCode = 0);

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

protected:

   DtPduKind internalGetPduKind() const {return DtResupplyOfferPduKind;}
   int indexInBounds(int ind) const;
   DtEntityIdentifier theId;
   DtEntityType supType;
};

/*******************************************************/
/******************* RESUPPLY RECEIVED PDU *************/
/*******************************************************/

class DT_DLL_VL DtResupplyReceivedPdu;
typedef DtResupplyReceivedPdu DtResupplyRecInteraction;
typedef void (*DtResupplyReceivedPduCb)(DtResupplyReceivedPdu *pdu, void *usr);

class DT_DLL_VL DtResupplyReceivedPdu : public DtInteraction
{
public:

   enum { PduStaticSize=28 };


public:


   DtResupplyReceivedPdu(DtBufferPtr buffer = DtUSE_INTERNAL_BUFFER);
   DtResupplyReceivedPdu(const DtNetResupplyReceivedPdu *initial,
                         DtBufferPtr buffer = DtUSE_INTERNAL_BUFFER, DtPduFactory* pduFactory = 0);

   DtResupplyReceivedPdu(const DtEntityIdentifier &receiver,
                         const DtEntityIdentifier &supplier,
                         const DtEntityType &supply,
                         float quantity,
                         DtBufferPtr buffer = DtUSE_INTERNAL_BUFFER);

   const DtEntityIdentifier &receivingId() const;
   void  setReceivingId(const DtEntityIdentifier &requester);

   const DtEntityIdentifier &supplyingId() const;
   void  setSupplyingId(const DtEntityIdentifier &servicer);

   int   numSupplyTypes() const; 
   void  setNumSupplyTypes(int numTypes);

   float supplyQuantity(const DtEntityType &supply) const;

   const DtEntityType &nthSupply(int supplyIndex,
                                 float *quantity = 0,
                                 int *retCode = 0) const;

   void  setNthSupply(int supplyIndex,
                      const DtEntityType &supply,
                      float quantity,
                      int *retCode = 0);

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


protected:

   DtPduKind internalGetPduKind() const {return DtResupplyReceivedPduKind;}
   int indexInBounds(int ind) const;
   DtEntityIdentifier theId;
   DtEntityType supType;
};

#endif