Method attachContainerInput

src/slave/http.cpp:3974–4025

Future<Response> Http::attachContainerInput(
    const mesos::agent::Call& call,
    Owned<Reader<mesos::agent::Call>>&& decoder,
    const RequestMediaTypes& mediaTypes,
    const Option<Principal>& principal) const
{
  CHECK_EQ(mesos::agent::Call::ATTACH_CONTAINER_INPUT, call.type());
  CHECK(call.has_attach_container_input());

  if (call.attach_container_input().type() !=
      mesos::agent::Call::AttachContainerInput::CONTAINER_ID) {
    return BadRequest(
        "Expecting 'attach_container_input.type' to be CONTAINER_ID");
  }

  CHECK(call.attach_container_input().has_container_id());

  LOG(INFO) << "Processing ATTACH_CONTAINER_INPUT call for container '"
            << call.attach_container_input().container_id() << "'";

  return ObjectApprovers::create(
      slave->authorizer,
      principal,
      {ATTACH_CONTAINER_INPUT})
    .then(defer(
        slave->self(),
        [this, call, decoder, mediaTypes](
            const Owned<ObjectApprovers>& approvers) -> Future<Response> {
          const ContainerID& containerId =
              call.attach_container_input().container_id();

          Executor* executor = slave->getExecutor(containerId);
          if (executor == nullptr) {
            return NotFound(
                "Container " + stringify(containerId) + " cannot be found");
          }

          Framework* framework = slave->getFramework(executor->frameworkId);
          CHECK_NOTNULL(framework);

          if (!approvers->approved<ATTACH_CONTAINER_INPUT>(
                  executor->info,
                  framework->info)) {
            return Forbidden();
          }

          Owned<Reader<mesos::agent::Call>> decoder_ = decoder;

          return _attachContainerInput(
              call, std::move(decoder_), mediaTypes);
        }));
}


Future<Response> Http::addResourceProviderConfig(