Method TestOpenInputFile

cpp/src/arrow/filesystem/test_util.cc:1140–1177

}

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

  std::shared_ptr<io::RandomAccessFile> file;
  std::shared_ptr<Buffer> buffer;
  ASSERT_OK_AND_ASSIGN(file, fs->OpenInputFile("AB/abc"));
  ASSERT_OK_AND_EQ(0, file->Tell());
  ASSERT_OK(file->Seek(10));
  ASSERT_OK_AND_EQ(10, file->Tell());
  ASSERT_OK_AND_ASSIGN(buffer, file->Read(6 /*Remaining + 1*/));
  AssertBufferEqual(*buffer, " data");
  ASSERT_OK_AND_ASSIGN(buffer, file->Read(1));
  AssertBufferEqual(*buffer, "");
  ASSERT_OK_AND_EQ(15, file->Tell());
  ASSERT_OK(file->Seek(5));
  ASSERT_OK_AND_EQ(5, file->Tell());
  ASSERT_OK_AND_ASSIGN(buffer, file->Read(6));
  AssertBufferEqual(*buffer, "other ");
  // Should return the same slice independent of the current position
  ASSERT_OK_AND_ASSIGN(buffer, file->ReadAt(2, 3));
  AssertBufferEqual(*buffer, "me ");
  ASSERT_OK_AND_EQ(15, file->GetSize());
  ASSERT_OK(file->Close());
  ASSERT_RAISES(Invalid, file->ReadAt(1, 1));  // Stream is closed

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

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

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

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