Method received

src/examples/inverse_offer_framework.cpp:161–238

  }

  void received(std::queue<Event> events)
  {
    while (!events.empty()) {
      Event event = events.front();
      events.pop();

      LOG(INFO) << "Received " << event.type() << " event";

      switch (event.type()) {
        case Event::SUBSCRIBED: {
          framework.mutable_id()->CopyFrom(event.subscribed().framework_id());

          LOG(INFO) << "Subscribed with ID '" << framework.id();
          state = SUBSCRIBED;
          break;
        }

        case Event::OFFERS: {
          metrics.offers_received += event.offers().offers().size();

          resourceOffers(google::protobuf::convert(event.offers().offers()));
          break;
        }

        case Event::INVERSE_OFFERS: {
          metrics.inverse_offers_received +=
            event.inverse_offers().inverse_offers().size();

          inverseOffers(google::protobuf::convert(
              event.inverse_offers().inverse_offers()));
          break;
        }

        case Event::UPDATE: {
          statusUpdate(event.update().status());
          break;
        }

        // TODO(greggomann): Implement handling of operation status updates.
        case Event::UPDATE_OPERATION_STATUS:
          break;

        case Event::FAILURE: {
          const Event::Failure& failure = event.failure();

          if (failure.has_agent_id() && failure.has_executor_id()) {
            LOG(INFO)
              << "Executor '" << failure.executor_id()
              << "' lost on agent '" << failure.agent_id()
              << (failure.has_status() ?
                  "' with status: " + stringify(failure.status()) : "");
          } else {
            CHECK(failure.has_agent_id());

            LOG(INFO) << "Agent lost: " << failure.agent_id();
          }
          break;
        }