Method waitEndpoint

src/csi/service_manager.cpp:567–595

Future<Nothing> ServiceManagerProcess::waitEndpoint(const string& endpoint)
{
  CHECK(strings::startsWith(endpoint, "unix://"));
  const string endpointPath =
    strings::remove(endpoint, "unix://", strings::PREFIX);

  if (os::exists(endpointPath)) {
    return Nothing();
  }

  // Wait for the endpoint socket to appear until the timeout expires.
  Timeout timeout = Timeout::in(CSI_ENDPOINT_CREATION_TIMEOUT);

  return process::loop(
      [=]() -> Future<Nothing> {
        if (timeout.expired()) {
          return Failure("Timed out waiting for endpoint '" + endpoint + "'");
        }

        return process::after(Milliseconds(10));
      },
      [=](const Nothing&) -> ControlFlow<Nothing> {
        if (os::exists(endpointPath)) {
          return Break();
        }

        return Continue();
      });
}


Future<Nothing> ServiceManagerProcess::probeEndpoint(const string& endpoint)