Function FuzzIpcStream

cpp/src/arrow/ipc/reader.cc:2764–2783

}  // namespace

Status FuzzIpcStream(const uint8_t* data, int64_t size) {
  auto buffer = std::make_shared<Buffer>(data, size);
  io::BufferReader buffer_reader(buffer);

  std::shared_ptr<RecordBatchReader> batch_reader;
  ARROW_ASSIGN_OR_RAISE(batch_reader,
                        RecordBatchStreamReader::Open(&buffer_reader, FuzzingOptions()));
  Status st;

  while (true) {
    ARROW_ASSIGN_OR_RAISE(auto batch, batch_reader->ReadNext());
    if (!batch.batch && !batch.custom_metadata) {
      // EOS
      break;
    }
    st &= ValidateFuzzBatch(batch);
  }

  return st;
}

Status FuzzIpcFile(const uint8_t* data, int64_t size) {
  auto buffer = std::make_shared<Buffer>(data, size);