Home
last modified time | relevance | path

Searched refs:SequentialFileReader (Results 1 – 25 of 25) sorted by relevance

/rocksdb-6.9/file/
Dsequence_file_reader.h22 class SequentialFileReader {
29 explicit SequentialFileReader(std::unique_ptr<FSSequentialFile>&& _file, in SequentialFileReader() function
33 explicit SequentialFileReader(std::unique_ptr<FSSequentialFile>&& _file, in SequentialFileReader() function
39 SequentialFileReader(SequentialFileReader&& o) ROCKSDB_NOEXCEPT { in SequentialFileReader() function
43 SequentialFileReader& operator=(SequentialFileReader&& o) ROCKSDB_NOEXCEPT {
48 SequentialFileReader(const SequentialFileReader&) = delete;
49 SequentialFileReader& operator=(const SequentialFileReader&) = delete;
Dsequence_file_reader.cc25 Status SequentialFileReader::Read(size_t n, Slice* result, char* scratch) { in Read()
55 Status SequentialFileReader::Skip(uint64_t n) { in Skip()
226 SequentialFileReader::NewReadaheadSequentialFile( in NewReadaheadSequentialFile()
Dfile_util.cc24 std::unique_ptr<SequentialFileReader> src_reader; in CopyFile()
46 src_reader.reset(new SequentialFileReader(std::move(srcfile), source)); in CopyFile()
Dread_write_util.h28 bool ReadOneLine(std::istringstream* iss, SequentialFileReader* seq_file_reader,
Dread_write_util.cc25 bool ReadOneLine(std::istringstream* iss, SequentialFileReader* seq_file_reader, in ReadOneLine()
/rocksdb-6.9/db/
Dlog_reader.h53 std::unique_ptr<SequentialFileReader>&& file, Reporter* reporter,
90 SequentialFileReader* file() { return file_.get(); } in file()
102 const std::unique_ptr<SequentialFileReader> file_;
163 std::unique_ptr<SequentialFileReader>&& _file, in FragmentBufferedReader()
Dtransaction_log_impl.cc44 std::unique_ptr<SequentialFileReader>* file_reader) { in OpenLogFile()
65 file_reader->reset(new SequentialFileReader(std::move(file), fname)); in OpenLogFile()
303 std::unique_ptr<SequentialFileReader> file; in OpenLogReader()
Dlog_test.cc125 SequentialFileReader* reader) { in GetStringSourceFromLegacyReader()
163 std::unique_ptr<SequentialFileReader> source_holder_;
730 std::unique_ptr<SequentialFileReader> reader_;
770 reader_.reset(new SequentialFileReader( in SetupTestEnv()
Dwal_manager.cc471 std::unique_ptr<SequentialFileReader> file_reader( in ReadFirstLine()
472 new SequentialFileReader(std::move(file), fname)); in ReadFirstLine()
Dtransaction_log_impl.h91 std::unique_ptr<SequentialFileReader>* file);
Drepair.cc352 std::unique_ptr<SequentialFileReader> lfile_reader(new SequentialFileReader( in ConvertLogToTable()
Dversion_set.cc4458 std::unique_ptr<SequentialFileReader> manifest_file_reader; in Recover()
4468 new SequentialFileReader(std::move(manifest_file), manifest_path, in Recover()
4746 std::unique_ptr<SequentialFileReader> manifest_file_reader; in TryRecoverFromOneManifest()
4757 new SequentialFileReader(std::move(manifest_file), manifest_path, in TryRecoverFromOneManifest()
4793 std::unique_ptr<SequentialFileReader> file_reader; in ListColumnFamilies()
4800 file_reader.reset(new SequentialFileReader(std::move(file), manifest_path)); in ListColumnFamilies()
4964 std::unique_ptr<SequentialFileReader> file_reader; in DumpManifest()
4976 file_reader.reset(new SequentialFileReader( in DumpManifest()
6194 std::unique_ptr<SequentialFileReader> manifest_file_reader; in MaybeSwitchManifest()
6197 new SequentialFileReader(std::move(manifest_file), manifest_path, in MaybeSwitchManifest()
Dlog_reader.cc27 std::unique_ptr<SequentialFileReader>&& _file, in Reader()
/rocksdb-6.9/utilities/blob_db/
Dblob_log_reader.h22 class SequentialFileReader; variable
/rocksdb-6.9/test_util/
Dtestutil.cc141 SequentialFileReader* GetSequentialFileReader(SequentialFile* se, in GetSequentialFileReader()
144 return new SequentialFileReader(NewLegacySequentialFileWrapper(file), fname); in GetSequentialFileReader()
Dtestutil.h33 class SequentialFileReader; variable
193 extern SequentialFileReader* GetSequentialFileReader(SequentialFile* se,
/rocksdb-6.9/utilities/backupable/
Dbackupable_db.cc1329 std::unique_ptr<SequentialFileReader> src_reader; in CopyOrCreateFile()
1332 src_reader.reset(new SequentialFileReader( in CopyOrCreateFile()
1529 std::unique_ptr<SequentialFileReader> src_reader( in CalculateChecksum()
1530 new SequentialFileReader(NewLegacySequentialFileWrapper(src_file), src)); in CalculateChecksum()
1776 std::unique_ptr<SequentialFileReader> backup_meta_reader( in LoadFromFile()
1777 new SequentialFileReader(NewLegacySequentialFileWrapper(backup_meta_file), in LoadFromFile()
/rocksdb-6.9/util/
Dfile_reader_writer_test.cc353 test_read_holder_.reset(new SequentialFileReader( in ResetSourceStr()
360 std::unique_ptr<SequentialFileReader> test_read_holder_;
/rocksdb-6.9/db/db_impl/
Ddb_impl_secondary.cc145 std::unique_ptr<SequentialFileReader> file_reader; in MaybeInitLogReader()
155 file_reader.reset(new SequentialFileReader( in MaybeInitLogReader()
Ddb_impl_secondary.h23 std::unique_ptr<SequentialFileReader>&& file_reader, in LogReaderContainer()
Ddb_impl_open.cc785 std::unique_ptr<SequentialFileReader> file_reader; in RecoverLogFiles()
801 file_reader.reset(new SequentialFileReader( in RecoverLogFiles()
/rocksdb-6.9/tools/
Dtrace_analyzer_test.cc135 SequentialFileReader sf_reader(std::move(file), file_path, in CheckFileContent()
Dldb_cmd.cc2194 std::unique_ptr<SequentialFileReader> wal_file_reader; in DumpWalFile()
2201 wal_file_reader.reset(new SequentialFileReader( in DumpWalFile()
Dtrace_analyzer_tool.cc1067 SequentialFileReader sf_reader( in ReProcessing()
/rocksdb-6.9/options/
Doptions_parser.cc217 SequentialFileReader sf_reader(std::move(seq_file), file_name, in Parse()