| 448 | return vec; |
| 449 | } |
| 450 | std::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 | |
| 478 | uint64_t FlowController::getUptime() { |
| 479 | auto now = std::chrono::steady_clock::now(); |
no test coverage detected