DRCETaskRequestSetExecuteExecutor.hpp

Go to the documentation of this file.

#ifndef DRCE_TASK_REQUEST_SET_EXECUTE_EXECUTOR_HPP
#define DRCE_TASK_REQUEST_SET_EXECUTE_EXECUTOR_HPP

#include "DRCETaskRequestExecutor.hpp"
#include "DRCECommonTask.hpp"

namespace HCE
{
namespace drce
{
//-----------------------------------------------------------------------------
class DRCETaskRequestSetExecuteExecutor : public DRCETaskRequestExecutor
{
public:
  DRCETaskRequestSetExecuteExecutor(DRCEAsyncTasksQueue& asyncTaskQueue_, DRCENodeOptions& nodeOptions_, CustomMessage& message_, DRCEResourceMonitor& resourceMonitor_);
  virtual ~DRCETaskRequestSetExecuteExecutor(void) {}

  DRCEResultDataItem execute(DRCETaskRequest* pTaskRequest, DRCEInputJsonMessage& inputJsonMessage);
private:
  DRCEResultDataItem executeTask(SessionOptions::ThreadMode threadMode, DRCECommonTask* pCommonTask,
      DRCETaskRequestSetExecute* pTaskReqiestSetExecute, DRCEInputJsonMessage& inputJsonMessage) throw (Poco::Exception);

  typedef DRCETaskRequestExecutor inherited;
};
//-----------------------------------------------------------------------------
//-----------------------------------------------------------------------------
} // end namespace drce 
} // end namespace HCE 

#endif // DRCE_TASK_REQUEST_SET_EXECUTE_EXECUTOR_HPP