Method addConnection

libminifi/src/core/ProcessGroup.cpp:347–361

}

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

  if (connections_.find(connection) == connections_.end()) {
    // We do not have the same connection in this process group yet
    connections_.insert(connection);
    logger_->log_debug("Add connection %s into process group %s", connection->getName(), name_);
    std::shared_ptr<Processor> source = this->findProcessorById(connection->getSourceUUID());
    if (source)
      source->addConnection(connection);
    std::shared_ptr<Processor> destination = this->findProcessorById(connection->getDestinationUUID());
    if (destination && destination != source)
      destination->addConnection(connection);
  }
}

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