Method __containers

src/slave/http.cpp:2881–3047

Future<JSON::Array> Http::__containers(
    const Owned<ObjectApprovers>& approvers,
    Option<IDAcceptor<ContainerID>> selectContainerId,
    bool showNestedContainers,
    bool showStandaloneContainers) const
{
  return slave->containerizer->containers()
    .then(defer(slave->self(), [=](const hashset<ContainerID> containerIds) {
      Owned<vector<JSON::Object>> metadata(new vector<JSON::Object>());
      vector<Future<ContainerStatus>> statusFutures;
      vector<Future<ResourceStatistics>> statsFutures;

      hashset<ContainerID> executorContainerIds;
      hashset<ContainerID> authorizedExecutorContainerIds;

      foreachvalue (const Framework* framework, slave->frameworks) {
        foreachvalue (const Executor* executor, framework->executors) {
          // No need to get statistics and status if we know that the
          // executor has already terminated.
          if (executor->state == Executor::TERMINATED) {
            continue;
          }

          const ExecutorInfo& info = executor->info;
          const ContainerID& containerId = executor->containerId;

          executorContainerIds.insert(containerId);

          if ((selectContainerId.isSome() &&
               !selectContainerId->accept(containerId)) ||
              !approvers->approved<VIEW_CONTAINER>(info, framework->info)) {
            continue;
          }

          authorizedExecutorContainerIds.insert(containerId);

          JSON::Object entry;
          entry.values["framework_id"] = info.framework_id().value();
          entry.values["executor_id"] = info.executor_id().value();
          entry.values["executor_name"] = info.name();
          entry.values["source"] = info.source();
          entry.values["container_id"] = containerId.value();

          metadata->push_back(entry);
          statusFutures.push_back(slave->containerizer->status(containerId));
          statsFutures.push_back(slave->containerizer->usage(containerId));
        }
      }

      foreach (const ContainerID& containerId, containerIds) {
        if (executorContainerIds.contains(containerId)) {
          continue;
        }

        if (selectContainerId.isSome() &&
            !selectContainerId->accept(containerId)) {
          continue;
        }