Method serializeGetTasks

src/slave/http.cpp:2288–2413

string Http::serializeGetTasks(
    const Owned<ObjectApprovers>& approvers) const
{
  // Construct framework list with both active and completed frameworks.
  vector<const Framework*> frameworks;
  foreachvalue (Framework* f, slave->frameworks) {
    if (approvers->approved<VIEW_FRAMEWORK>(f->info)) {
      frameworks.push_back(f);
    }
  }
  foreachvalue (const Owned<Framework>& f, slave->completedFrameworks) {
    if (approvers->approved<VIEW_FRAMEWORK>(f->info)) {
      frameworks.push_back(f.get());
    }
  }

  // Construct executor list with both active and completed executors.
  hashmap<const Executor*, const Framework*> executors;
  foreach (const Framework* f, frameworks) {
    foreachvalue (Executor* e, f->executors) {
      if (approvers->approved<VIEW_EXECUTOR>(e->info, f->info)) {
        executors.put(e, f);
      }
    }
    foreach (const Owned<Executor>& e, f->completedExecutors) {
      if (approvers->approved<VIEW_EXECUTOR>(e->info, f->info)) {
        executors.put(e.get(), f);
      }
    }
  }

  // Serialize the following message:
  //
  //   v1::agent::Response::GetTasks getTasks;
  //
  //   for each pending task:
  //     *getTasks.add_pending_tasks() = task
  //   for each queued task:
  //     *getTasks.add_queued_tasks() = *task;
  //   for each launched task:
  //     *getTasks.add_launched_tasks() = *task;
  //   for each terminated task:
  //     *getTasks.add_terminated_tasks() = *task;
  //   for each completed task:
  //     *getTasks.add_completed_tasks() = *task;

  string output;
  google::protobuf::io::StringOutputStream stream(&output);
  google::protobuf::io::CodedOutputStream writer(&stream);

  foreach (const Framework* framework, frameworks) {
    // Pending tasks.
    typedef hashmap<TaskID, TaskInfo> TaskMap;
    foreachvalue (const TaskMap& taskInfos, framework->pendingTasks) {
      foreachvalue (const TaskInfo& taskInfo, taskInfos) {
        if (approvers->approved<VIEW_TASK>(taskInfo, framework->info)) {
          // TODO(bmahler): Consider not constructing the temporary task
          // object and instead serialize directly. Since we don't expect