lgrCommandDispatcher.h

Go to the documentation of this file.

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


#ifndef lgrCommandDispatcher_H_
#define lgrCommandDispatcher_H_

#include <lgrCore/lgrCore.h>
#include <lgrUtil/absoluteTime.h>
#include <lgrUtil/collectors.h>
#include <lgrCmds/lgrCommandQueue.h>
#include <lgrUtil/virtualConstructor.h>

#include <vlutil/vlSmartPointers.h>
#include <vlutil/vlMutex.h>

namespace MAKLogger
{
   class DtLogger;
   class DtLgrSharedData;
   class DtLgrCmdDescriptor;
   class DtAnnotationManager;
   class DtRuntimeCommandFactory;

   class DT_DLL_LGRCORE DtCommandDispatcher
   {
   public:
      DT_VIRTUAL_CTR(DtCommandDispatcher,())

      
      virtual ~DtCommandDispatcher();

      virtual bool addResponseListener(DtResponseQueueSP listener);

      virtual void removeResponseListener(DtResponseQueueSP listener);

      virtual void sendResponse(DtResponse response);

      virtual void addCommand(const DtCommand& command);

      void moveQueuedCommands(DtCollector< DtCommand>& collector);

   private:
      DtCommandDispatcher( const DtCommandDispatcher& src );
      DtCommandDispatcher& operator=( const DtCommandDispatcher& src );

   public:
      virtual DtAbsoluteTime tick();

   protected:
      DtMutex myListenerMutex;
      DtLgrCommandQueue* myCommandQueue;
      DtResponseList myResponseList;
      DtRuntimeCommandFactory* myRuntimeCommandFactory;
   };

   typedef DtBoost::shared_ptr<DtCommandDispatcher> DtCommandDispatcherSP;

}

#endif