lgrModSqlExporter Example

The lgrModSqlExporter dynamic library creates a replacement for the lgrSqlExporter (found in lgrConfigDIS.xml).

//! For DIS, this replacement adds an encoder for the Data PDU. It specifically collects only the datum containing VR-Forces control messages. There is more general code available to capture other datum; however, the interpretation of the datum values must be added.

The shared library is also built for the HLA protocols, but it does not add anything as the HLA encoder uses the omtReader to automatically encode the data.

---

The Data PDU encoder:

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


#if DtDIS

#include "lgrDataPduEncoder.h"

#include <vl/dataPdu.h>

namespace MAKLogger
{

DtLgrDataPduEncoder::DtLgrDataPduEncoder()
   : myTableName("DataPdu")
   , mySenderIdColumn(0)
   , myReceiverIdColumn(0)
   , myNumberOfFixedDatumColumn(0)
   , myNumberOfVariableDatumColumn(0)
   , myFixedDatumParameterName("DataPdu_FixedDatums")
   , myFixedDatumParameterTableIndex(0)
   , myVariableDatumParameterName("DataPdu_VariableDatums")
   , myVariableDatumParameterTableIndex(0)
   , myFixedDatumIdColumn(0)
   , myFixedDatumValueColumn(0)
   , myVariableDatumIdColumn(0)
   , myVariableDatumValueColumn(0)
{
   mySenderIdColumn = new DtDatabaseColumn("SenderId",DtDatabaseColumn::Type_SqlVarString);
   myReceiverIdColumn = new DtDatabaseColumn("ReceiverId",DtDatabaseColumn::Type_SqlVarString);
   myNumberOfFixedDatumColumn = new DtDatabaseColumn("NumberOfFixedDatum",DtDatabaseColumn::Type_SqlUnsignedShort);
   myNumberOfVariableDatumColumn = new DtDatabaseColumn("NumberOfVariableDatum",DtDatabaseColumn::Type_SqlUnsignedShort);

   myFixedDatumIdColumn = new DtDatabaseColumn("FixedDatums_ID",DtDatabaseColumn::Type_SqlUnsignedLong);
   myFixedDatumValueColumn = new DtDatabaseColumn("FixeDatums_Value",DtDatabaseColumn::Type_SqlVarString);

   myVariableDatumIdColumn = new DtDatabaseColumn("VariableDatums_ID",DtDatabaseColumn::Type_SqlUnsignedLong);
   myVariableDatumValueColumn = new DtDatabaseColumn("VariableDatums_Value",DtDatabaseColumn::Type_SqlVarString);

   mySenderIdColumn->setNullAllow(false);
   myReceiverIdColumn->setNullAllow(false);
   myNumberOfFixedDatumColumn->setNullAllow(false);
   myNumberOfVariableDatumColumn->setNullAllow(false);

   myFixedDatumIdColumn->setNullAllow(false);
   myFixedDatumValueColumn->setNullAllow(false);

   myVariableDatumIdColumn->setNullAllow(false);
   myVariableDatumValueColumn->setNullAllow(false);
   // Uncomment the line below if using hex dump
   // myVariableDatumValueColumn->setDisplaySize(-1);
}

DtLgrDataPduEncoder::~DtLgrDataPduEncoder()
{
   delete mySenderIdColumn;
   delete myReceiverIdColumn;
   delete myNumberOfFixedDatumColumn;
   delete myNumberOfVariableDatumColumn;

   delete myFixedDatumIdColumn;
   delete myFixedDatumValueColumn;

   delete myVariableDatumIdColumn;
   delete myVariableDatumValueColumn;
}

DtPduKind DtLgrDataPduEncoder::pduKind()
{
   return DtDataPduKind;
}

const DtString& DtLgrDataPduEncoder::pduName() const
{
   return myTableName;
}

std::vector<DtDatabaseTableSP> DtLgrDataPduEncoder::getTableDefinitions() const
{
   std::vector<DtDatabaseTableSP> tables = DtLgrPduDatabaseEncoder::getTableDefinitions();
   DtDatabaseTableSP primary = tables.front();

   primary->addColumn(*mySenderIdColumn);
   primary->addColumn(*myReceiverIdColumn);
   primary->addColumn(*myNumberOfFixedDatumColumn);
   primary->addColumn(*myNumberOfVariableDatumColumn);

   DtDatabaseTable* secondary = createSubTable(myFixedDatumParameterName);

   secondary->addColumn(*myFixedDatumIdColumn);
   secondary->addColumn(*myFixedDatumValueColumn);

   myFixedDatumParameterTableIndex = tables.size();
   tables.push_back(DtDatabaseTableSP(secondary));

   DtDatabaseTable* tertiary = createSubTable(myVariableDatumParameterName);

   tertiary->addColumn(*myVariableDatumIdColumn);
   tertiary->addColumn(*myVariableDatumValueColumn);

   myVariableDatumParameterTableIndex = tables.size();
   tables.push_back(DtDatabaseTableSP(tertiary));

   return tables;
}

// From vrfExtProtocol\msgTypes.h in makVrfVrlinkExtentions
#define DtControlMessage 260020
enum controlMessage
{
   DtUnknownControlType = 0,
   DtPauseControlType = 1,
   DtRunControlType = 2,
   DtRunDurationControlType = 3,
   DtRunCompleteControlType = 4,
   DtRewindControlType = 5,
   DtStepControlType = 6
};

// From vrfMsgs\ifControl.h in VR-Forces
struct DtNetIfControl
{
   DtNetFloat64   myTime;              
   DtNetU16       myControlType;       
   DtNetU32       myPadding1;          
   DtNetU16       myPadding2;          
};

void getControlType(const char* data, DtString& datumValue)
{
   if (!data)
      return;

   DtNetIfControl* controlData = (DtNetIfControl*)data;

   switch ((DtU16)controlData->myControlType)
   {
   case DtPauseControlType:
      {
         datumValue = "Pause";
         break;
      }
   case DtRunControlType:
      {
         datumValue = "Run";
         break;
      }
   case DtRunDurationControlType:
      {
         datumValue = "RunDuration";
         break;
      }
   case DtRunCompleteControlType:
      {
         datumValue = "RunComplete";
         break;
      }
   case DtRewindControlType:
      {
         datumValue = "Rewind";
         break;
      }
   case DtStepControlType:
      {
         datumValue = "Step";
         break;
      }
   case  DtUnknownControlType:
   default:
      {
         datumValue = "UnknownControl";
         break;
      }
   }
}

void DtLgrDataPduEncoder::encodePdu( const DtPdu& pdu,std::vector<DtDatabaseTableSP>& tables ) const
{
   const DtDataPdu& dataPdu = static_cast<const DtDataPdu&>(pdu);
   DtDatabaseTableSP primary = tables.front();
   DtDatabaseTableSP fixedTable = tables[myFixedDatumParameterTableIndex];
   DtDatabaseTableSP varTable = tables[myVariableDatumParameterTableIndex];

#if 1

   // Export Data PDU only if it contains a VRF control message
   int recordCount = dataPdu.numVarFields();
   DtString controlType("UnknownControl");
   unsigned long datumId = 0;

   for( int recordIndex = 1; datumId != DtControlMessage && recordIndex <= recordCount; ++recordIndex)
   {
      datumId = dataPdu.varDatumId(recordIndex);
      if (datumId == DtControlMessage)
      {
         getControlType(dataPdu.datumValByteArray(DtVar, recordIndex), controlType);
      }
   }

   if (datumId == DtControlMessage)
   {
      primary->getColumn(mySenderIdColumn->columnName())->setValue(dataPdu.senderId().string());
      primary->getColumn(myReceiverIdColumn->columnName())->setValue(dataPdu.receiverId().string());
      primary->getColumn(myNumberOfFixedDatumColumn->columnName())->setValue(dataPdu.numFixedFields());
      primary->getColumn(myNumberOfVariableDatumColumn->columnName())->setValue(dataPdu.numVarFields());
      varTable->getColumn(myVariableDatumIdColumn->columnName())->addValue(DtControlMessage);
      varTable->getColumn(myVariableDatumValueColumn->columnName())->addValue(controlType.c_str());
   }

#else

   // Just do a hex dump of the contents of all datums.
   primary->getColumn(mySenderIdColumn->columnName())->setValue(dataPdu.senderId().string());
   primary->getColumn(myReceiverIdColumn->columnName())->setValue(dataPdu.receiverId().string());
   primary->getColumn(myNumberOfFixedDatumColumn->columnName())->setValue(dataPdu.numFixedFields());
   primary->getColumn(myNumberOfVariableDatumColumn->columnName())->setValue(dataPdu.numVarFields());

   int recordCount = dataPdu.numFixedFields();
   int recordIndex = 0;
   for( ; recordIndex < recordCount; ++recordIndex)
   {
      DtString valueString;
      int valueLength = dataPdu.datumSizeBytes(DtFixed, recordIndex); // Should always be 4
      bin2HexString(valueString, dataPdu.datumValByteArray(DtFixed, recordIndex), valueLength);
      fixedTable->getColumn(myFixedDatumIdColumn->columnName())->addValue(dataPdu.fixedDatumId(recordIndex));
      fixedTable->getColumn(myFixedDatumValueColumn->columnName())->addValue(valueString);
   }

   recordCount = dataPdu.numVarFields();

   for( recordIndex = 0; recordIndex < recordCount; ++recordIndex)
   {
      DtString valueString;
      int valueLength = dataPdu.datumSizeBytes(DtVar, recordIndex);
      bin2HexString(valueString, dataPdu.datumValByteArray(DtVar, recordIndex), valueLength);
      varTable->getColumn(myVariableDatumIdColumn->columnName())->addValue(dataPdu.varDatumId(recordIndex));
      varTable->getColumn(myVariableDatumValueColumn->columnName())->addValue(valueString);
}
#endif
}

}

#endif