stateObModel.h

Go to the documentation of this file.

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


#pragma once

#include "stateObserver.h"

#include <lgrCore/lgrDriver.h>
#include <lgrUtil/observe.h>
#include <set>

namespace MAKLogger
{
   class DtCommand;
   class DtLgrSystemDriver;
   class DtMessageState;
   class DtStateObject;
   class DtStateObserverController;

   class DT_DLL_STATEOBSERVER DtStateObserverModel : public MAKLogger::DtLgrCommandHandler
   {
   public:

      DtStateObserverModel(DtStateObserverController*,
         MAKLogger::DtLgrSystemDriver& driver);

      virtual ~DtStateObserverModel();

      void connect(MAKLogger::DtMessageState*);

      int totalObjects() const;

      int totalAliveObjects() const;

      int totalDeadObjects() const;

      int entityCount() const;

      int aggregateCount() const;

      int envProcCount() const;

      //DtLgrCommandHandler Interface
      // Tick the driver, cause it to do anything on a regular basis.
      virtual void tick();

      // These are no-ops since this Handler doesn't use the pipeline.
      virtual bool releasePipeline();
      virtual bool getPipeline();
      virtual bool hasPipeline() const;

      virtual DtResponse handleUpdateRequest(const DtCommand&);

      virtual void enableObservers();

      virtual void disableObservers();

   protected:

      static bool equals(const MAKLogger::DtStateObject* object,DtU64 id);

      virtual void updateState(const MAKLogger::DtMessageState&);

      virtual void activate(const MAKLogger::DtMessageState&);

      virtual void deactivate(const MAKLogger::DtMessageState&);

      virtual void endDiff(const MAKLogger::DtMessageState& state);

      typedef MAKLogger::DtObserverFunctor<DtStateObserverModel,\
         MAKLogger::DtMessageState> MessageStateObserverFunctor;

      MessageStateObserverFunctor myPostUpdateObserver;
      MessageStateObserverFunctor myActivateObserver;
      MessageStateObserverFunctor myDeactivateObserver;
      MessageStateObserverFunctor myEndDiffObserver;

      std::set<DtU64> myActiveObjects;

      int myTotalCount;
      int myTotalAliveCount;
      int myTotalDeadCount;
      int myEntityCount;
      int myAggregateCount;
      int myEnvProcCount;

      DtStateObserverController* myController;

      bool myActivateObserverFlag;
   };
}