| 344 | } |
| 345 | |
| 346 | void FlowController::loadFlowRepo() { |
| 347 | if (this->flow_file_repo_ != nullptr) { |
| 348 | logger_->log_debug("Getting connection map"); |
| 349 | std::map<std::string, std::shared_ptr<core::Connectable>> connectionMap; |
| 350 | std::map<std::string, std::shared_ptr<core::Connectable>> containers; |
| 351 | if (this->root_ != nullptr) { |
| 352 | this->root_->getConnections(connectionMap); |
| 353 | this->root_->getFlowFileContainers(containers); |
| 354 | } |
| 355 | flow_file_repo_->setConnectionMap(connectionMap); |
| 356 | flow_file_repo_->setContainers(containers); |
| 357 | flow_file_repo_->loadComponent(content_repo_); |
| 358 | } else { |
| 359 | logger_->log_debug("Flow file repository is not set"); |
| 360 | } |
| 361 | } |
| 362 | |
| 363 | int16_t FlowController::start() { |
| 364 | std::lock_guard<std::recursive_mutex> flow_lock(mutex_); |
nothing calls this directly
no test coverage detected