lgrDisSimDriver.h

Go to the documentation of this file.

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


#if DtDIS

#ifndef lgrDisSimDriver_H_
#define lgrDisSimDriver_H_

#include "lgrSim.h"
#include "lgrSimDriver.h"
#include "lgrCommandFunctor.h"
#include "lgrCommandDispatcher.h"
#include "lgrExceptions.h"
#include "virtualConstructor.h"

#include <map>

#include <vlutil/vlInetAddr.h>

class DtExerciseConnInitializer;

namespace MAKLogger
{

   class DtCommand;
   class DtDisDescriptor;
   class DtLgrDisEntityTypeManager;
   class DtLgrDisCommandFactory;
   class DtLgrDisSimulationManager;
   class DtLgrDisSimInterface;
   class DtLgrSimDriver;
   class DtMessagePipeline;
   class DtLgrSystemDriver;
   class DtLgrPduTypeFilter;
   class DtLgrDisEntityTypeFilter;

   class DT_DLL_LGRSIM DtLgrDisSimDriver : public DtLgrSimDriver
   {
   public:

      typedef DtLgrDisCommandFactory Factory;
      typedef DtLgrDisSimInterface Interface;

      DT_VIRTUAL_CTR(DtLgrDisSimDriver,(DtLgrSystemDriver&))

      virtual ~DtLgrDisSimDriver();
      virtual void tick();

      DtResponse setConnectionParameters(const DtCommand& command);

      DtResponse setHeartbeatRate(const DtCommand& command);

      DtResponse setTimeoutRate(const DtCommand& command);

      DtResponse setDrainInputSettings(const DtCommand& command);

      virtual DtLgrSimManager* simManager();
      virtual const DtLgrSimManager* simManager() const;

      virtual int port() const;
      virtual int exerciseId() const;
      virtual int siteId() const;
      virtual int appNumber() const;
      virtual bool useAsynchIO() const;
      virtual DtInetAddr destAddr() const;
      virtual DtInetAddr deviceAddr() const;
      virtual const DtString& netmask() const;
      virtual int sendBufferSize() const;
      virtual int recvBufferSize() const;
      virtual int multicastTtl() const;
      virtual const std::vector<DtString>& mcastAddresses() const;

      virtual double heartbeatRate() const;
      virtual double timeoutRate() const;

      virtual double drainInputMaxTime() const;
      virtual int    numPdusToReadPerTimeCheck() const;

      virtual bool isConnected() const;
      virtual const DtDisDescriptor* disDescription() const;
      virtual const DtLgrDisEntityTypeManager* entityTypeManager() const;

   protected:

      virtual DtResponse connect(const DtCommand& command);

      virtual DtResponse connectShared(const DtCommand& command);

      virtual DtResponse disconnect(const DtCommand& command);

      // Update the remote control filter based on the record remote control setting
      virtual void updateRecordRemoteControlFilter();

      virtual DtResponse setDisDescription(const DtCommand& command);

      virtual DtResponse setEntityTypeManager(const DtCommand& command);

      virtual DtResponse setCommonEntityTypes(const DtCommand& command);

      virtual DtResponse filterEntityTypes(const DtCommand& command);

      virtual DtResponse addCustomPDU(const DtCommand& command);

      virtual DtResponse addFilteredEntityName(const DtCommand& command);

      virtual bool releasePipeline();
      virtual bool getPipeline();
      virtual bool hasPipeline() const;

   protected:

      class DtFixedExerciseConnInitializer;

      DtLgrDisSimulationManager* mySimManager;
      DtLgrPduTypeFilter* myPduFilter;
      DtLgrDisEntityTypeFilter* myEntityTypeFilter;

      int myPort;
      int myExerciseId;
      int mySiteId;
      int myAppNumber;
      bool myUseAsynchIO;
      DtInetAddr myDestAddr;
      DtInetAddr myDeviceAddr;
      // Never used independently of establishing the destination address or display
      DtString myNetmask;
      int mySendBufferSize;
      int myRecvBufferSize;
      int myMulticastTtl;
      std::vector<DtString> myMcastAddresses;

   };

}

#endif
#endif