Method TestOpenInputStream

cpp/src/arrow/filesystem/test_util.cc:1044–1082

}

void GenericFileSystemTest::TestOpenInputStream(FileSystem* fs) {
  ASSERT_OK(fs->CreateDir("AB"));
  CreateFile(fs, "AB/abc", "some data");

  std::shared_ptr<io::InputStream> stream;
  std::shared_ptr<Buffer> buffer;
  ASSERT_OK_AND_ASSIGN(stream, fs->OpenInputStream("AB/abc"));
  ASSERT_OK_AND_ASSIGN(auto metadata, stream->ReadMetadata());
  // XXX we cannot really test anything more about metadata...
  ASSERT_OK_AND_EQ(0, stream->Tell());
  ASSERT_OK_AND_ASSIGN(buffer, stream->Read(4));
  AssertBufferEqual(*buffer, "some");
  ASSERT_OK_AND_ASSIGN(buffer, stream->Read(6 /*Remaining + 1*/));
  AssertBufferEqual(*buffer, " data");
  ASSERT_OK_AND_ASSIGN(buffer, stream->Read(1));
  AssertBufferEqual(*buffer, "");
  ASSERT_OK_AND_EQ(9, stream->Tell());
  ASSERT_OK(stream->Close());

  ASSERT_OK_AND_ASSIGN(stream, fs->OpenInputStream("AB/abc"));
  ASSERT_OK(stream->Advance(4));
  ASSERT_OK_AND_EQ(4, stream->Tell());
  ASSERT_OK_AND_ASSIGN(buffer, stream->Read(6 /*Remaining + 1*/));
  AssertBufferEqual(*buffer, " data");
  ASSERT_OK(stream->Close());
  ASSERT_RAISES(Invalid, stream->Read(1));  // Stream is closed

  // Trailing slash rejected
  ASSERT_RAISES(IOError, fs->OpenInputStream("AB/abc/"));

  // File does not exist
  AssertRaisesWithErrno(ENOENT, fs->OpenInputStream("AB/def"));
  AssertRaisesWithErrno(ENOENT, fs->OpenInputStream("def"));

  // Cannot open directory
  if (!allow_read_dir_as_file()) {
    ASSERT_RAISES(IOError, fs->OpenInputStream("AB"));
  }
}

void GenericFileSystemTest::TestOpenInputStreamWithFileInfo(FileSystem* fs) {
  ASSERT_OK(fs->CreateDir("AB"));