Method waitContainer

src/slave/container_daemon.cpp:167–212

void ContainerDaemonProcess::waitContainer()
{
  const ContainerID& containerId = waitCall.wait_container().container_id();

  LOG(INFO) << "Waiting for container '" << containerId << "'";

  http::post(
      agentUrl,
      getAuthHeader(authToken),
      serialize(contentType, evolve(waitCall)),
      stringify(contentType))
    .then(defer(self(), [=](const http::Response& response) -> Future<Nothing> {
      if (response.status != http::OK().status &&
          response.status != http::NotFound().status) {
        return Failure(
            "Failed to wait for container '" +
            stringify(waitCall.wait_container().container_id()) +
            "': Unexpected response '" + response.status + "' (" +
            response.body + ")");
      }

      if (postStopHook.isSome()) {
        LOG(INFO)
          << "Invoking post-stop hook for container '" << containerId << "'";

        return postStopHook.get()();
      }

      return Nothing();
    }))
    .onReady(defer(self(), &Self::launchContainer))
    .onFailed(defer(self(), [=](const string& failure) {
      LOG(ERROR)
        << "Failed to wait for container '"
        << waitCall.wait_container().container_id() << "': " << failure;

      terminated.fail(failure);
    }))
    .onDiscarded(defer(self(), [=] {
      LOG(ERROR)
        << "Failed to wait for container '"
        << waitCall.wait_container().container_id() << "': future discarded";

      terminated.discard();
    }));
}


Try<Owned<ContainerDaemon>> ContainerDaemon::create(