Function getProcessIOData

src/tests/api_tests.cpp:5454–5492

Reads `ProcessIO::Data` records from the pipe `reader` until EOF is reached and returns the merged stdout and stderr. NOTE: It ignores any `ProcessIO::Control` records.

// and returns the merged stdout and stderr.
// NOTE: It ignores any `ProcessIO::Control` records.
static Future<tuple<string, string>> getProcessIOData(
    ContentType contentType,
    http::Pipe::Reader reader)
{
  return reader.readAll()
    .then([contentType](const string& data) -> Future<tuple<string, string>> {
      string stdoutReceived;
      string stderrReceived;

      ::recordio::Decoder decoder;

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

      if (records.isError()) {
        return process::Failure(records.error());
      }

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

        Try<v1::agent::ProcessIO> processIO =
          deserialize<v1::agent::ProcessIO>(contentType, record);

        if (processIO.isError()) {
          return process::Failure(processIO.error());
        }

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

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


TEST_P(AgentAPITest, GetFlags)