lgrInterface.h

Go to the documentation of this file.

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


#ifndef lgrInterface_H_
#define lgrInterface_H_

#include <lgrCore/lgrCore.h>
#include <lgrUtil/virtualConstructor.h>
#include <lgrCmds/lgrCommand.h>
#include <lgrCore/lgrCommandDispatcher.h>
#include <lgrCmds/lgrCommandQueue.h>
#include <lgrCmds/lgrCommandFunctor.h>

#include <lgrCore/logger.h>
#include <lgrCore/lgrDriver.h>

#include <map>
#include <list>

namespace MAKLogger
{
   class DtLogger;
   class DtLgrCommandHandler;

   class DT_DLL_LGRCORE DtCommandInterface
   {
   public:
      DT_VIRTUAL_CTR(DtCommandInterface,(DtCommandDispatcherSP))

      
      virtual ~DtCommandInterface();

      virtual bool update();

      void disconnectFromDispatcher();

      void reconnectToDispatcher();

      void addResponseHandler(const DtCommand& command,DtResponseFunctorSP);

      virtual void sendCommand(const DtCommand&) const;

      bool executeResponse(DtResponse command);

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

   protected:

      typedef std::map<DtCommand,DtResponseFunctorSP,std::less<DtCommand> > DtResponseMap;
      DtResponseMap myResponseMap;

      DtResponseQueueSP    myResponseQueue;

      DtCommandDispatcherSP myDispatcher;

   };      

   template <typename CommandHandlerType>
   static typename CommandHandlerType::Interface* createInterface(DtLogger& logger)
   {
      std::shared_ptr<DtLgrCommandHandler> commandHandler = \
         logger.getCommandHandler(CommandHandlerType::Factory::theCommandType);

      if(commandHandler)
      {
         commandHandler->lock();
         std::shared_ptr<CommandHandlerType> subCommandHandler = \
            std::dynamic_pointer_cast<CommandHandlerType>(commandHandler);
         if(subCommandHandler)
         {
            typename CommandHandlerType::Interface* commandInterface = \
               CommandHandlerType::Interface::createNonThreadsafe(logger,
               *subCommandHandler);

            commandHandler->unlock();
            return commandInterface;
         }
         commandHandler->unlock();
      }
      return 0;
   }

}

#endif