Function decodeProcessIOData

src/checks/checker_process.cpp:169–201

Reads `ProcessIO::Data` records from a string containing "Record-IO" data encoded in protobuf messages, and returns the stdout and stderr. NOTE: This function ignores any `ProcessIO::Control` records. TODO(gkleiman): This function is very similar to one in `api_tests.cpp`, we should refactor them into a common helper when fixing MESOS-7903.

// TODO(gkleiman): This function is very similar to one in `api_tests.cpp`, we
// should refactor them into a common helper when fixing MESOS-7903.
static Try<tuple<string, string>> decodeProcessIOData(const string& data)
{
  string stdoutReceived;
  string stderrReceived;

  ::recordio::Decoder decoder;

  Try<std::deque<string>> records = decoder.decode(data);

  if (records.isError()) {
    return Error(records.error());
  }

  while (!records->empty()) {
    string record = std::move(records->front());
    records->pop_front();

    Try<v1::agent::ProcessIO> result = deserialize<v1::agent::ProcessIO>(
        ContentType::PROTOBUF, record);

    if (result.isError()) {
      return Error(result.error());
    }

    if (result->data().type() == v1::agent::ProcessIO::Data::STDOUT) {
      stdoutReceived += result->data().data();
    } else if (result->data().type() == v1::agent::ProcessIO::Data::STDERR) {
      stderrReceived += result->data().data();
    }
  }

  return std::make_tuple(stdoutReceived, stderrReceived);
}


static Variant<check::Command, check::Http, check::Tcp> checkInfoToCheck(