Method hasWorkToDo

libminifi/src/SchedulingAgent.cpp:34–40

namespace minifi {

bool SchedulingAgent::hasWorkToDo(const std::shared_ptr<core::Processor>& processor) {
  // Whether it has work to do
  if (processor->getTriggerWhenEmpty() || !processor->hasIncomingConnections() || processor->flowFilesQueued())
    return true;
  else
    return false;
}

std::future<utils::TaskRescheduleInfo> SchedulingAgent::enableControllerService(std::shared_ptr<core::controller::ControllerServiceNode> &serviceNode) {
  logger_->log_info("Enabling CSN in SchedulingAgent %s", serviceNode->getName());