MCPcopy Create free account
hub / github.com/apache/nifi-minifi-cpp / getComponents

Method getComponents

libminifi/src/FlowController.cpp:450–476  ·  view source on GitHub ↗

Source from the content-addressed store, hash-verified

448 return vec;
449}
450std::vector<std::shared_ptr<state::StateController>> FlowController::getComponents(const std::string &name) {
451 std::vector<std::shared_ptr<state::StateController>> vec;
452
453 if (name == "FlowController") {
454 vec.push_back(shared_from_this());
455 } else {
456 // check processors
457 std::shared_ptr<core::Processor> processor = root_->findProcessorByName(name);
458 if (processor != nullptr) {
459 switch (processor->getSchedulingStrategy()) {
460 case core::SchedulingStrategy::TIMER_DRIVEN:
461 vec.push_back(std::make_shared<state::ProcessorController>(processor, timer_scheduler_));
462 break;
463 case core::SchedulingStrategy::EVENT_DRIVEN:
464 vec.push_back(std::make_shared<state::ProcessorController>(processor, event_scheduler_));
465 break;
466 case core::SchedulingStrategy::CRON_DRIVEN:
467 vec.push_back(std::make_shared<state::ProcessorController>(processor, cron_scheduler_));
468 break;
469 default:
470 break;
471 }
472 }
473 }
474
475 return vec;
476}
477
478uint64_t FlowController::getUptime() {
479 auto now = std::chrono::steady_clock::now();

Callers 2

initializeMethod · 0.45

Calls 2

findProcessorByNameMethod · 0.80
getSchedulingStrategyMethod · 0.80

Tested by

no test coverage detected