Method getEndpoint

src/csi/service_manager.cpp:688–858

Future<string> ServiceManagerProcess::getEndpoint(
    const ContainerID& containerId)
{
  if (endpoints.contains(containerId)) {
    return endpoints.at(containerId)->future();
  }

  CHECK(!daemons.contains(containerId));

  Option<CSIPluginContainerInfo> config = getContainerInfo(containerId);
  CHECK_SOME(config);

  // We checkpoint the config first to keep track of the plugin container even
  // if we fail to create its container daemon.
  const string configPath =
    paths::getContainerInfoPath(rootDir, info.type(), info.name(), containerId);

  Try<Nothing> checkpoint = slave::state::checkpoint(configPath, config.get());
  if (checkpoint.isError()) {
    return Failure(
        "Failed to checkpoint plugin container config to '" + configPath +
        "': " + checkpoint.error());
  }

  CommandInfo commandInfo;

  if (config->has_command()) {
    commandInfo = config->command();
  }

  // Set the `CSI_ENDPOINT` environment variable.
  Try<string> endpointPath = paths::getEndpointSocketPath(
      rootDir, info.type(), info.name(), containerId);

  if (endpointPath.isError()) {
    return Failure(
        "Failed to resolve endpoint path for plugin container '" +
        stringify(containerId) + "': " + endpointPath.error());
  }

  const string endpoint = "unix://" + endpointPath.get();
  Environment::Variable* endpoint_ =
    commandInfo.mutable_environment()->add_variables();

  endpoint_->set_name("CSI_ENDPOINT");
  endpoint_->set_value(endpoint);

  // For some CSI Plugins (like NFS CSI plugin), their node service need
  // a node ID specified by container orchestrator, so here we expose agent
  // ID to the plugins, they can use that as the node ID.
  if (config->services().end() != std::find(
          config->services().begin(),
          config->services().end(),
          NODE_SERVICE)) {
    Environment::Variable* nodeId =
      commandInfo.mutable_environment()->add_variables();

    nodeId->set_name("MESOS_AGENT_ID");