Function TEST_F

src/tests/container_daemon_tests.cpp:75–180

TEST_F(ContainerDaemonTest, RestartOnTermination)
{
  Try<Owned<cluster::Master>> master = StartMaster();
  ASSERT_SOME(master);

  Owned<MasterDetector> detector = master.get()->createDetector();
  Owned<SecretGenerator> secretGenerator;

  slave::Flags slaveFlags = CreateSlaveFlags();

#ifdef USE_SSL_SOCKET
  ASSERT_SOME(slaveFlags.jwt_secret_key);

  Try<string> jwtSecretKey = os::read(slaveFlags.jwt_secret_key.get());
  ASSERT_SOME(jwtSecretKey);

  secretGenerator.reset(new JWTSecretGenerator(jwtSecretKey.get()));
#endif // USE_SSL_SOCKET

  Future<Nothing> recover = FUTURE_DISPATCH(_, &Slave::__recover);

  Try<Owned<cluster::Slave>> slave = StartSlave(
      detector.get(),
      secretGenerator.get(),
      slaveFlags);

  ASSERT_SOME(slave);

  PID<Slave> slavePid = slave.get()->pid;

  // Ensure slave has finished recovery.
  AWAIT_READY(recover);

  string scheme = "http";

#ifdef USE_SSL_SOCKET
  if (openssl::flags().enabled) {
    scheme = "https";
  }
#endif // USE_SSL_SOCKET

  http::URL url(
      scheme,
      slavePid.address.ip,
      slavePid.address.port,
      strings::join("/", slavePid.id, "api/v1"));

  // NOTE: The current implicit authorization for creating standalone
  // containers is to check if the container ID prefix in the claims
  // of the principal is indeed a prefix of the container ID that is
  // specified in the API call.
  string containerIdPrefix = id::UUID::random().toString();

  ContainerID containerId;
  containerId.set_value(strings::join(
        "-",
        containerIdPrefix,
        id::UUID::random().toString()));