Method getContainers

src/csi/service_manager.cpp:463–512

Future<hashmap<ContainerID, Option<ContainerStatus>>>
ServiceManagerProcess::getContainers()
{
  agent::Call call;
  call.set_type(agent::Call::GET_CONTAINERS);
  call.mutable_get_containers()->set_show_nested(false);
  call.mutable_get_containers()->set_show_standalone(true);

  return http::post(
      agentUrl,
      headers,
      internal::serialize(contentType, internal::evolve(call)),
      stringify(contentType))
    .then(process::defer(self(), [this](const http::Response& httpResponse)
        -> Future<hashmap<ContainerID, Option<ContainerStatus>>> {
      if (httpResponse.status != http::OK().status) {
        return Failure(
            "Failed to get containers: Unexpected response '" +
            httpResponse.status + "' (" + httpResponse.body + ")");
      }

      Try<mesos::v1::agent::Response> v1Response =
        internal::deserialize<mesos::v1::agent::Response>(
            contentType, httpResponse.body);

      if (v1Response.isError()) {
        return Failure("Failed to get containers: " + v1Response.error());
      }

      hashmap<ContainerID, Option<ContainerStatus>> result;

      agent::Response response = internal::devolve(v1Response.get());
      foreach (const agent::Response::GetContainers::Container& container,
               response.get_containers().containers()) {
        // Container IDs of this CSI plugin must contain the given prefix. See
        // `LocalResourceProvider::principal` for details.
        if (!strings::startsWith(
                container.container_id().value(), containerPrefix)) {
          continue;
        }

        result.put(
            container.container_id(),
            container.has_container_status() ? container.container_status()
                                             : Option<ContainerStatus>::none());
      }

      return std::move(result);
    }));
}


Future<Nothing> ServiceManagerProcess::waitContainer(