lgrDisDatabasePrinter.h

Go to the documentation of this file.

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


#ifndef lgrDisDatabasePrinter_H_
#define lgrDisDatabasePrinter_H_

#if DtDIS

#include "lgrSqlExporter.h"
#include "lgrDatabasePrinter.h"
#include <vlutil/vlString.h>

#include <map>
#include <vlpi/disEnums.h>

class DtDatabaseInterface;
class DtOutputStream;
class DtPduFactory;

namespace MAKLogger
{

   class DtLgrPduDatabaseEncoder;
   class DtLgrCheckpointTableFactory;
   class DtLgrDisObjectTableFactory;
   class DtPacket;
   class DtConstLgrDisMessage;

   class DT_DLL_SQLEXPORTER DtLgrDisDatabasePrinter : public DtLgrDatabasePrinter
   {
   public:


      DtLgrDisDatabasePrinter(DtOutputStream& log,
         DtDatabaseInterface& databaseInterface);

      virtual ~DtLgrDisDatabasePrinter();

   private:
      DtLgrDisDatabasePrinter(const DtLgrDisDatabasePrinter&);
      DtLgrDisDatabasePrinter& operator=(const DtLgrDisDatabasePrinter&);

   public:

      virtual void setGenerateInstanceTable( bool generate);

      virtual void setGenerateCheckpointTable( bool generate);

      virtual void createDefaultTables();

      virtual void printCheckpoint(const MAKLogger::DtPacket& packet);

      virtual void printPDU(const MAKLogger::DtPacket& packet);

   protected:

      virtual void printInstance( MAKLogger::DtConstLgrDisMessage &disMsg,
         const MAKLogger::DtPacket &packet );

      struct PduCacheEntry
      {
         DtLgrDatabasePrinter::TableList tables;
         const DtLgrPduDatabaseEncoder* encoder;
      };

      struct InstanceData
      {
         DtString id;
         DtString type;
         double lastTime;
         bool finalPduSet;
      };

      typedef std::map<DtU64,InstanceData> InstanceMap;

      typedef std::map<DtPduKind,PduCacheEntry> PduCache;

      bool myGenerateInstanceTable;
      bool myGenerateCheckpointTable;
      PduCache myPduCache;
      DtPduFactory* myPduFactory;
      DtLgrDisObjectTableFactory* myObjectTableFac;
      DtLgrCheckpointTableFactory* myCheckpointTableFac;
      InstanceMap myObjectInstances;
   };

}

#endif

#endif