Function foreach

src/slave/csi_server.cpp:168–212

  hashmap<string, CSIPluginInfo> pluginConfigs;

  foreach (const string& entry, entries.get()) {
    const string path = path::join(pluginConfigDir, entry);

    // Ignore directory entries.
    if (os::stat::isdir(path)) {
      continue;
    }

    Try<string> read = os::read(path);
    if (read.isError()) {
      // In case of an error we log and skip to the next entry.
      LOG(ERROR) << "Failed to read CSI plugin configuration file '"
                 << path << "': " << read.error();

      continue;
    }

    Try<JSON::Object> json = JSON::parse<JSON::Object>(read.get());
    if (json.isError()) {
      return Error("JSON parse of '" + path + "' failed: " + json.error());
    }

    Try<CSIPluginInfo> parse = ::protobuf::parse<CSIPluginInfo>(json.get());
    if (parse.isError()) {
      return Error("Protobuf parse of '" + path + "' failed: " + parse.error());
    }

    const CSIPluginInfo& csiPluginConfig = parse.get();
    const string& type = csiPluginConfig.type();

    if (pluginConfigs.contains(type)) {
      LOG(ERROR) << "Multiple configurations for a CSI plugin are not allowed. "
                 << "Skipping configuration file '" << path << "' since CSI "
                 << "plugin '" << type << "' already exists";
      continue;
    }

    if (name.isNone() || name.get() == type) {
      pluginConfigs[type] = csiPluginConfig;

      if (name.isSome()) {
        break;
      }
    }
  }

  if (pluginConfigs.empty()) {
    return Error(