Method getFlowFileContainers

libminifi/src/core/ProcessGroup.cpp:333–345

}

void ProcessGroup::getFlowFileContainers(std::map<std::string, std::shared_ptr<Connectable>> &containers) const {
  for (auto connection : connections_) {
    containers[connection->getUUIDStr()] = connection;
    containers[connection->getName()] = connection;
  }
  for (auto processor : processors_) {
    // processors can also own FlowFiles
    containers[processor->getUUIDStr()] = processor;
  }
  for (auto processGroup : child_process_groups_) {
    processGroup->getFlowFileContainers(containers);
  }
}

void ProcessGroup::addConnection(const std::shared_ptr<Connection>& connection) {
  std::lock_guard<std::recursive_mutex> lock(mutex_);