Method foreach

src/launcher/default_executor.cpp:447–544

    vector<Future<Response>> responses;

    foreach (const TaskInfo& task, taskGroup.tasks()) {
      ContainerID containerId;
      containerId.set_value(id::UUID::random().toString());
      containerId.mutable_parent()->CopyFrom(executorContainerId.get());

      containerIds.push_back(containerId);

      containers[task.task_id()] = Owned<Container>(new Container{
        containerId,
        task,
        taskGroup,
        None(),
        None(),
        None(),
        None(),
        None(),
        false,
        false,
        false,
        false});

      // Send out the initial TASK_STARTING update.
      const TaskStatus status = createTaskStatus(task.task_id(), TASK_STARTING);
      forward(status);

      agent::Call call;
      call.set_type(agent::Call::LAUNCH_CONTAINER);

      agent::Call::LaunchContainer* launch = call.mutable_launch_container();
      launch->mutable_container_id()->CopyFrom(containerId);

      if (task.has_command()) {
        launch->mutable_command()->CopyFrom(task.command());
      }

      if (task.has_container()) {
        launch->mutable_container()->CopyFrom(task.container());
      }

      launch->mutable_resources()->CopyFrom(task.resources());

      if (!task.limits().empty()) {
        *launch->mutable_limits() = task.limits();
      }

      // Currently any disk resources used by the task are mounted
      // on the top level container. As a workaround, we set up the
      // volume mapping allowing child containers to share the volumes
      // from their parent containers sandbox.
      //
      // TODO(qianzhang): Mount the disk resources on the task containers
      // directly and then remove this workaround.
      foreach (const Resource& resource, task.resources()) {
        // Ignore if there are no disk resources or if the
        // disk resources did not specify a volume mapping.
        if (!resource.has_disk() || !resource.disk().has_volume()) {
          continue;
        }