lgrDisSimCommandFactory.h

Go to the documentation of this file.

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



#pragma once

#include <lgrCmds/lgrCmds.h>
#include <lgrCmds/lgrCommand.h>
#include <lgrUtil/collectors.h>
#include <lgrCmds/lgrSimCommandFactory.h>

#include <utility>
#include <vlutil/vlString.h>

namespace MAKLogger
{

   class DT_DLL_LGR_CMDS DtLgrDisCommandFactory : public DtLgrSimCommandFactory
   {
   public:

      static const DtLgrCommandType theCommandType;

      static const DtLgrCommandId theBaseCommandId = DtLgrSimCommandFactory::theLastCommandId;



      DT_FACTORY_COMMAND_EXT(theBaseCommandId + 1, SetConnectionParametersDIS,
         (int port, int exerciseId, int siteId, int appNumber, bool useAsynchIO, int sendBufferSize,
            int recvBufferSize, int multicastTtl, const DtString& destAddrString,
            const DtString& netmask, const DtString& deviceAddrString,
            const std::vector<DtString>& mcastAddresses  ),
         (const DtCommand& command, int& port, int& exerciseId, int& siteId, int& appNumber,
            bool& useAsynchIO, int& sendBufferSize, int& recvBufferSize, int& multicastTtl,
            DtString& destAddrString, DtString& netmask, DtString& deviceAddrString,
            std::vector<DtString>& mcastAddresses ))

      DT_FACTORY_COMMAND_EXT(theBaseCommandId + 2, SetHeartbeatRate,( double rate ),
         ( const DtCommand& command,double& rate ))

      DT_FACTORY_COMMAND_EXT(theBaseCommandId + 3, SetTimeoutRate,
         ( double rate ),
         ( const DtCommand& command, double& rate ))

      DT_FACTORY_COMMAND_EXT(theBaseCommandId + 4, SetDisDescription,
         (const DtBase64Data& data),
         ( const DtCommand& command,DtBase64Data& data))

      DT_FACTORY_COMMAND_EXT(theBaseCommandId + 5, SetEntityTypeManager,
         ( const DtBase64Data& data),
         ( const DtCommand& command, DtBase64Data& data))

      DT_FACTORY_COMMAND_EXT(theBaseCommandId + 6, SetCommonEntityTypes,
         ( const std::vector<DtString>& types),
         ( const DtCommand& command,std::vector<DtString>& types))

      DT_FACTORY_COMMAND_EXT(theBaseCommandId + 7, AddCustomPDU,
         ( const std::vector<DtString>& pduDesc),
         ( const DtCommand& command,std::vector<DtString>& pduDesc))

      DT_FACTORY_COMMAND_EXT(theBaseCommandId + 8, SetDrainInput,
         (double maxTime, int numPdusToRead),
         (const DtCommand& command, double& maxTime, int& numPdusToRead))
         
      DT_FACTORY_COMMAND_EXT(theBaseCommandId + 9, FilterEntityTypes,
         ( const std::vector<DtString>& types),
         ( const DtCommand& command,std::vector<DtString>& types))
      
      DT_FACTORY_COMMAND_EXT(theBaseCommandId + 10, FilterEntityIds,
         ( const std::vector<DtString>& ids),
         ( const DtCommand& command,std::vector<DtString>& ids))

      DT_FACTORY_COMMAND_EXT(theBaseCommandId + 11, SetCommonEntityIds,
         ( const std::vector<DtString>& ids),
         ( const DtCommand& command,std::vector<DtString>& ids))

      DT_FACTORY_COMMAND_EXT(theBaseCommandId + 12, SetDisVersion,
         ( int version ),
         ( const DtCommand& command,int& version ))


      static const DtLgrCommandId theLastCommandId = theBaseCommandId + 100;

      static const DtLgrCommandId theBaseResponseId = DtLgrSimCommandFactory::theLastResponseId;



      DT_FACTORY_RESPONSE_EXT(theBaseResponseId - 1, HeartbeatRateChanged,
         (double rate),
         (DtResponse command,double& rate))

      DT_FACTORY_RESPONSE_EXT(theBaseResponseId - 2, TimeoutRateChanged,
         (double rate),
         (DtResponse command,double& rate))

      DT_FACTORY_RESPONSE_EXT(theBaseResponseId - 3, ConnectionParametersDISChanged,
         (int port, int exerciseId, int siteId, int appNumber, bool useAsynchIO, int sendBufferSize,
            int recvBufferSize, int multicastTtl, const DtString& destAddrString,
            const DtString& netmask, const DtString& deviceAddrString,
            const std::vector<DtString>& mcastAddresses),
         (DtResponse command, int& port, int& exerciseId, int& siteId, int& appNumber,
            bool& useAsynchIO, int& sendBufferSize, int& recvBufferSize, int& multicastTtl,
            DtString& destAddrString, DtString& netmask, DtString& deviceAddrString,
            std::vector<DtString>& mcastAddresses ))

      DT_FACTORY_RESPONSE_EXT(theBaseResponseId - 4, DisDescriptionChanged,
         (const DtBase64Data& data),
         (DtResponse command, DtBase64Data& data))

      DT_FACTORY_RESPONSE_EXT(theBaseResponseId - 5, EntityTypeManagerChanged,
         (const DtBase64Data& data),
         (DtResponse command, DtBase64Data& data))

      DT_FACTORY_RESPONSE_EXT(theBaseResponseId - 6, DrainInputSettingsChanged,
         (double maxTime, int numPdusToRead),
         (DtResponse command, double& maxTime, int& numPdusToRead))

      DT_FACTORY_RESPONSE_EXT(theBaseResponseId - 7, EntityIdFilterChanged,
         (DtBase64Data& filter),
         (DtResponse command, DtBase64Data& filter))

      DT_FACTORY_RESPONSE_EXT(theBaseResponseId - 8, DisVersionChanged,
         (int version),
         (DtResponse command, int& version))


      static const DtLgrCommandId theLastResponseId = theBaseResponseId - 100;

      static const char* commandToString(int commandId);

      static const char* responseToString(int responseId);

   };

}