Method subscribe

src/master/master.cpp:2657–2731

void Master::subscribe(
    StreamingHttpConnection<v1::scheduler::Event> http,
    scheduler::Call::Subscribe&& subscribe)
{
  // TODO(anand): Authenticate the framework.

  FrameworkInfo& frameworkInfo = *subscribe.mutable_framework_info();

  // Update messages_{re}register_framework accordingly.
  if (!frameworkInfo.has_id() || frameworkInfo.id() == "") {
    ++metrics->messages_register_framework;
  } else {
    ++metrics->messages_reregister_framework;
  }

  LOG(INFO) << "Received subscription request for"
            << " HTTP framework '" << frameworkInfo.name() << "'";

  Option<Error> validationError =
    validateFramework(frameworkInfo, subscribe.suppressed_roles());

  allocator::FrameworkOptions allocatorOptions;

  // TODO(asekretenko): Validate roles in offer constraints (see MESOS-10176).
  if (validationError.isNone()) {
    Try<OfferConstraintsFilter> filter = OfferConstraintsFilter::create(
        offerConstraintsFilterOptions,
        OfferConstraints(subscribe.offer_constraints()));

    if (filter.isError()) {
      validationError = Error(std::move(filter.error()));
    } else {
      allocatorOptions.offerConstraintsFilter = std::move(*filter);
    }
  }

  if (validationError.isSome()) {
    LOG(INFO) << "Refusing subscription of framework"
              << " '" << frameworkInfo.name() << "': "
              << validationError->message;

    FrameworkErrorMessage message;
    message.set_message(validationError->message);

    http.send(message);
    http.close();
    return;
  }

  allocatorOptions.suppressedRoles = set<string>(
      make_move_iterator(subscribe.mutable_suppressed_roles()->begin()),
      make_move_iterator(subscribe.mutable_suppressed_roles()->end()));

  // Need to disambiguate for the compiler.
  void (Master::*_subscribe)(
      StreamingHttpConnection<v1::scheduler::Event>,
      FrameworkInfo&&,
      OfferConstraints&&,