Lines Matching refs:fileSys_

56   hdfsFS fileSys_;  member in ROCKSDB_NAMESPACE::__anone484b1950111::HdfsReadableFile
62 : fileSys_(fileSys), filename_(fname), hfile_(nullptr) { in HdfsReadableFile()
65 hfile_ = hdfsOpenFile(fileSys_, filename_.c_str(), O_RDONLY, 0, 0, 0); in HdfsReadableFile()
74 hdfsCloseFile(fileSys_, hfile_); in ~HdfsReadableFile()
97 bytes_read = hdfsRead(fileSys_, hfile_, buffer, remaining_bytes); in Read()
127 ssize_t bytes_read = hdfsPread(fileSys_, hfile_, offset, in Read()
143 tOffset current = hdfsTell(fileSys_, hfile_); in Skip()
149 int val = hdfsSeek(fileSys_, hfile_, newoffset); in Skip()
162 if (hdfsTell(fileSys_, hfile_) == fileSize()) { in feof()
172 hdfsFileInfo* pFileInfo = hdfsGetPathInfo(fileSys_, filename_.c_str()); in fileSize()
187 hdfsFS fileSys_; member in ROCKSDB_NAMESPACE::__anone484b1950111::HdfsWritableFile
195 fileSys_(fileSys), in HdfsWritableFile()
200 hfile_ = hdfsOpenFile(fileSys_, filename_.c_str(), O_WRONLY, 0, 0, 0); in HdfsWritableFile()
209 hdfsCloseFile(fileSys_, hfile_); in ~HdfsWritableFile()
232 size_t ret = hdfsWrite(fileSys_, hfile_, src, static_cast<tSize>(left)); in Append()
249 if (hdfsFlush(fileSys_, hfile_) == -1) { in Sync()
252 if (hdfsHSync(fileSys_, hfile_) == -1) { in Sync()
262 if (hdfsWrite(fileSys_, hfile_, src, static_cast<tSize>(size)) != in Append()
272 if (hdfsCloseFile(fileSys_, hfile_) != 0) { in Close()
395 HdfsReadableFile* f = new HdfsReadableFile(fileSys_, fname); in NewSequentialFile()
410 HdfsReadableFile* f = new HdfsReadableFile(fileSys_, fname); in NewRandomAccessFile()
426 HdfsWritableFile* f = new HdfsWritableFile(fileSys_, fname, options); in NewWritableFile()
451 int value = hdfsExists(fileSys_, name.c_str()); in NewDirectory()
465 int value = hdfsExists(fileSys_, fname.c_str()); in FileExists()
480 int value = hdfsExists(fileSys_, path.c_str()); in GetChildren()
485 pHdfsFileInfo = hdfsListDirectory(fileSys_, path.c_str(), &numEntries); in GetChildren()
516 if (hdfsDelete(fileSys_, fname.c_str(), 1) == 0) { in DeleteFile()
523 if (hdfsCreateDirectory(fileSys_, name.c_str()) == 0) { in CreateDir()
530 const int value = hdfsExists(fileSys_, name.c_str()); in CreateDirIfMissing()
550 hdfsFileInfo* pFileInfo = hdfsGetPathInfo(fileSys_, fname.c_str()); in GetFileSize()
561 hdfsFileInfo* pFileInfo = hdfsGetPathInfo(fileSys_, fname.c_str()); in GetFileModificationTime()
575 hdfsDelete(fileSys_, target.c_str(), 1); in RenameFile()
576 if (hdfsRename(fileSys_, src.c_str(), target.c_str()) == 0) { in RenameFile()
598 HdfsWritableFile* f = new HdfsWritableFile(fileSys_, fname, options); in NewLogger()