exerciseConnInitializerDIS.h

Go to the documentation of this file.

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

#ifndef _dExConnInit_H_
#define _dExConnInit_H_


#if DtDIS

#include <vlutil/vlUtil.h>
#include <cmdLine/cmdLine.h>
#include <vlutil/vlTimeStampType.h>
#include <vlutil/vlString.h>

#include <mtl/applicationSettings.h>

#include <mtl/configVariable.h>
#include <mtl/multiConfigVariable.h>

#include <vlutil/vlDisSocket.h>
#include <vlutil/vlInetAddr.h>

#include <vlpi/disEnums.h>

class DtMtlEnvironment;

class DT_DLL_VL DtExerciseConnInitializer
{
public:
   DtExerciseConnInitializer();

   virtual ~DtExerciseConnInitializer();

   DtExerciseConnInitializer(const DtExerciseConnInitializer& orig);

   DtExerciseConnInitializer& operator=(const DtExerciseConnInitializer& orig);

   virtual void setPort(int port);
   
   virtual int port() const;

   virtual void setExerciseId(int id);
   
   virtual int exerciseId() const;

   virtual void setSiteId(int id);
   
   virtual int siteId() const;

   virtual void setApplicationNumber(int num);
   
   virtual int applicationNumber() const;

   virtual void setUseAsynchIO(bool on);
   
   virtual bool useAsynchIO() const;

   virtual void setDestinationAddress(const DtString &addr);

   virtual DtString destinationAddress() const;
   
   virtual void setSocket(DtDisSocket* sock);
   
   virtual DtDisSocket* socket() const;
   
   virtual void setNotifyLevel(int level);

   virtual void setDisVersionToSend(int version);

   virtual void setTimeStampType(DtTimeStampType relOrAbs);
   
   virtual DtTimeStampType timeStampType() const;

   virtual void setSendBufferSize(int numBytes);
   
   virtual int sendBufferSize() const;

   virtual void setReceiveBufferSize(int numBytes);

   virtual int receiveBufferSize() const;

   virtual void setUseIpv6(bool val);
   virtual bool useIpv6() const;

   virtual void setMulticastTtl(int ttl);

   virtual int multicastTtl() const;

   virtual void setMulticastAddresses(const std::vector<DtString>& addresses);
   
   virtual const std::vector<DtString>& multicastAddresses() const;

   virtual void setDeviceAddress(const DtString& devAddr);

   virtual DtString deviceAddress() const;

   virtual void setSubnetMask(const DtString& mask);

   virtual DtString subnetMask() const;

   virtual void setSuppressSelfReflect(bool yesNo);

   virtual bool suppressSelfReflect() const;

   virtual void setAttributePduStrategy(DtAttributePduStrategy strat);

   virtual DtAttributePduStrategy attributePduStrategy() const;

public:

   static DtString vrlinkVersion();
   
private:
   int                    myPort;
   int                    myExerciseId;
   int                    mySiteId;
   int                    myApplicationNumber;
   bool                   myUseAsynchIO;
   DtTimeStampType        myTimeStampType;
   int                    mySendBufferSize;
   int                    myReceiveBufferSize;
   int                    myMulticastTtl;
   std::vector<DtString>  myMulticastAddresses;
   bool                   myUseIpv6;
   bool                   mySuppressSelfReflect;
   DtString               myDeviceAddress;
   DtString               myDestinationAddress;
   DtString               mySubnetMask;
   DtDisSocket*           mySocket;
   int myAttributePduStrategy;
};

class DT_DLL_VL DtVrlApplicationInitializer : public DtExerciseConnInitializer
{
public:
   DtVrlApplicationInitializer(int argc, char* argv[], const DtString& appName,
      const DtString& version = DtExerciseConnInitializer::vrlinkVersion());

   virtual ~DtVrlApplicationInitializer();

   virtual void parseCmdLine();

   virtual void loadFile(const DtString& fileName);

   virtual void saveFile(const DtString& filename);

   virtual void setArgc(int);
   virtual int argc() const;

   virtual void setArgv(char**);
   virtual char** argv() const;

   virtual void setPort(int port);
   virtual int port() const;

   virtual void setExerciseId(int id);
   virtual int exerciseId() const;

   virtual void setApplicationNumber(int num);
   virtual int applicationNumber() const;

   virtual void setSiteId(int id);
   virtual int siteId() const;

   virtual void setDestinationAddress(const DtString& address);
   virtual DtString destinationAddress() const;

   virtual void setNotifyLevel(int level);

   //{@
   virtual void setNotifyFileLevel(int level);
   virtual int notifyFileLevel() const;

   //{@
   virtual void setNotifyFilename(const DtString& file);
   virtual DtString notifyFilename() const;

   virtual void setSendBufferSize(int numBytes);
   virtual int sendBufferSize() const;

   virtual void setReceiveBufferSize(int numBytes);
   virtual int receiveBufferSize() const;

   virtual void setUseAsynchIO(bool on);

   virtual bool useAsynchIO() const;

   virtual void setMulticastTtl(int ttl);

   virtual int multicastTtl() const;

   virtual void setTimeStampType(DtTimeStampType relOrAbs);

   virtual DtTimeStampType timeStampType() const;

   virtual void setMulticastAddresses(const std::vector<DtString>& addresses);
   virtual const std::vector<DtString>& multicastAddresses() const;

   virtual void setUseIpv6(bool val);
   virtual bool useIpv6() const;

   virtual void setSuppressSelfReflect(bool yesNo);

   virtual bool suppressSelfReflect() const;

   virtual void setDeviceAddress(const DtString& devAddr);

   virtual DtString deviceAddress() const;

   virtual void setSubnetMask(const DtString& mask);

   virtual DtString subnetMask() const;

   virtual void setAttributePduStrategy(DtAttributePduStrategy strat);

   virtual DtAttributePduStrategy attributePduStrategy() const;

   virtual void setOutputInterval(double period);

   virtual double outputInterval() const;

protected:
   virtual void initializeFileLogging();

protected:
   int myArgc;
   char** myArgv;
   DtMtlEnvironment* myMtlEnv;

   virtual void initializeMtlParams();
   virtual void loadMtlFile(const DtString& fileName);

   DtApplicationSettings           mySettings;
   DtConfigVariable<int>           myNotifyLevel;
   DtVariableGroup                 myDisConnection;
   DtConfigVariable<int>           myConfigVarPort;
   DtConfigVariable<int>           myConfigVarExerciseId;
   DtConfigVariable<int>           myConfigVarSiteNumber;
   DtConfigVariable<int>           myConfigVarApplicationNumber;
   DtConfigVariable<int>           myConfigVarDisVersion;
   DtConfigVariable<DtString>      myConfigVarDestinationAddress;
   DtConfigVariable<int>           myConfigVarSendBufferSize;
   DtConfigVariable<int>           myConfigVarReceiveBufferSize;
   DtConfigVariable<bool>          myConfigVarUseAsyncIo;
   DtConfigVariable<bool>          myConfigVarUseIpv6;
   DtConfigVariable<bool>          myConfigVarSuppressSelfReflect;
   DtConfigVariable<bool>          myConfigVarUseAbsoluteTimestamps;
   DtConfigVariable<int>           myConfigVarMulticastTtl;
   DtMultiConfigVariable<DtString> myConfigVarMulticastAddresses;
   DtConfigVariable<DtString>      myConfigVarDeviceAddress;
   DtConfigVariable<DtString>      myConfigVarSubnetMask;
   DtConfigVariable<int>           myConfigVarNotifyFileLevel;
   DtConfigVariable<DtString>      myConfigVarNotifyFilename;
   DtConfigVariable<int>           myConfigVarAttributeStrategy;
   DtConfigVariable<double>        myConfigVarOutputInterval;

   // If logging is turned on, this printer will remain in memory
   // even after this class is destroyed. Otherwise we would 
   // have to stop logging prematurely.
   DtFilePrinter*                  myLogFilePrinter;

   mutable DtInetAddr myCachedDestAddr;
   int myMtlUseAsynchronousIO;
   int myMtlUseAbsoluteTimeStamps;
   int myMtlUseIpv6;
   int myMtlSuppressSelfReflect;
};

#endif 
#endif