Function foreachpair

src/slave/csi_server.cpp:220–293

  }

  foreachpair (const string& _name, const CSIPluginInfo& info, pluginConfigs) {
    // Default-construct the plugin struct so that we have a valid runtime
    // to pass into the service manager.
    plugins.put(_name, CSIPlugin(info, "csi_plugins/" + _name + "/"));

    CSIPlugin& plugin = plugins.at(_name);

    if (info.containers_size() > 0) {
      CHECK_SOME(agentId);

      plugin.serviceManager.reset(new ServiceManager(
          agentId.get(),
          agentUrl,
          rootDir,
          info,
          extractServices(info),
          DEFAULT_CSI_CONTAINER_PREFIX,
          authToken,
          plugin.runtime,
          &plugin.metrics));
    } else {
      CHECK(info.endpoints_size() > 0);

      plugin.serviceManager.reset(new ServiceManager(
          info,
          extractServices(info),
          plugin.runtime,
          &plugin.metrics));
    }

    plugin.initialized.associate(
        plugin.serviceManager->recover()
          .then(defer(self(), [=]() {
            CHECK(plugins.contains(_name));

            return plugins.at(_name).serviceManager->getApiVersion();
          }))
          .then(defer(self(), [=](const string& apiVersion) -> Future<Nothing> {
            CHECK(plugins.contains(_name));

            Try<Owned<VolumeManager>> volumeManager = VolumeManager::create(
                rootDir,
                info,
                extractServices(info),
                apiVersion,
                plugins.at(_name).runtime,
                plugins.at(_name).serviceManager.get(),
                &plugins.at(_name).metrics,
                secretResolver);

            if (volumeManager.isError()) {
              return Failure(
                  "CSI server failed to create volume manager for plugin"
                  " '" + info.name() + "': " + volumeManager.error());
            }

            plugins.at(_name).volumeManager = std::move(volumeManager.get());