Method getNewFlowFiles

extensions/libarchive/BinFiles.cpp:361–368

}

std::unordered_set<std::shared_ptr<core::FlowFile>> BinFiles::FlowFileStore::getNewFlowFiles() {
  bool hasNewFlowFiles = true;
  if (!has_new_flow_file_.compare_exchange_strong(hasNewFlowFiles, false, std::memory_order_acquire, std::memory_order_relaxed)) {
    return {};
  }
  std::lock_guard<std::mutex> guard(flow_file_mutex_);
  return std::move(incoming_files_);
}

std::set<std::shared_ptr<core::Connectable>> BinFiles::getOutGoingConnections(const std::string &relationship) const {
  auto result = core::Connectable::getOutGoingConnections(relationship);