//===-- FDReader.cpp ------------------------------------------------------===//
//
// Part of the LLVM Project, under the Apache License v2.0 with LLVM Exceptions.
// See https://llvm.org/LICENSE.txt for license information.
// SPDX-License-Identifier: Apache-2.0 WITH LLVM-exception
//
//===----------------------------------------------------------------------===//

#include "FDReader.h"
#include <cassert>
#include <cstring>
#include <iostream>
#include <unistd.h>

namespace __llvm_libc {
namespace testutils {

FDReader::FDReader() {
  if (::pipe(pipefd)) {
    std::cerr << "pipe(2) failed";
    abort();
  }
}

FDReader::~FDReader() {
  ::close(pipefd[0]);
  ::close(pipefd[1]);
}

bool FDReader::matchWritten(const char *str) {

  ::close(pipefd[1]);

  constexpr ssize_t ChunkSize = 4096 * 4;

  char Buffer[ChunkSize];
  std::string PipeStr;
  std::string InputStr(str);

  for (int BytesRead; (BytesRead = ::read(pipefd[0], Buffer, ChunkSize));) {
    if (BytesRead > 0) {
      PipeStr.insert(PipeStr.size(), Buffer, BytesRead);
    } else {
      assert(0 && "Error reading from pipe");
      return false;
    }
  }

  return PipeStr == InputStr;
}

} // namespace testutils
} // namespace __llvm_libc