lgrDriver.h

Go to the documentation of this file.

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


#ifndef lgrDriver_H_
#define lgrDriver_H_

#include "lgrCore.h"
#include "lgrCommand.h"
#include "lgrCommandFunctor.h"
#include "lgrCommandDispatcher.h"
#include "lgrRuntimeCommandFactory.h"
#include <vlutil/vlSmartPointers.h>
#include <vlutil/vlMutex.h>

#include <map>

namespace MAKLogger
{

   class DtLgrSystemDriver;
   class DtCommandInterface;
   class DtRuntimeCommandFactory;

   class DT_DLL_LGRCORE DtLgrCommandHandler
   {
   public:

      DtLgrCommandHandler(const DtString& name,DtRuntimeCommandFactory*
         ,DtCommandDispatcherSP);

      virtual ~DtLgrCommandHandler();

      void lock();

      void unlock();

      virtual void tick() = 0;

      DtCommandDispatcherSP dispatcher();

      virtual const DtString& driverName() const;

      virtual const DtString& driverInfo();

      virtual void processCommand(const DtCommand& command);

      virtual bool releasePipeline() = 0;


      virtual bool getPipeline() = 0;

      virtual bool hasPipeline() const = 0;

   protected:

      typedef DtLgrCommandHandler* (*DriverCreator)(DtCommandDispatcherSP);

      void addCommandHandler(const DtCommandDefinition& commandDef,
         DtCommandFunctorSP commandFunctor);

      void removeCommandHandler(const DtCommandDefinition& commandDef);

      virtual void sendResponse(DtResponse response);

      virtual void queueResponse(DtResponse response);

      virtual void sendQueuedResponses();

      virtual void emptyResponseQueue();

      typedef std::map<DtLgrCommandId,DtCommandFunctorSP> DtLgrCommandHandlerMap;
      typedef std::map<DtString,DtLgrCommandId> DtLgrCommandNameMap;

      typedef std::list<DtResponse> DtResponseQueue;

      DtRuntimeCommandFactory* myRuntimeCommandFactory;

      DtLgrCommandHandlerMap myCommandMap;
      DtCommandDispatcherSP  myDispatcher;
      DtResponseQueue myResponseQueue;
      DtString myName;
      DtString myInfo;

      DtMutex myMutex;
   };

   typedef DtBoost::shared_ptr<DtLgrCommandHandler> DtLgrCommandHandlerSP;

}

#endif