Home
last modified time | relevance | path

Searched refs:FragmentBufferedReader (Results 1 – 8 of 8) sorted by relevance

/rocksdb-6.9/db/
Dlog_reader.h159 class FragmentBufferedReader : public Reader {
161 FragmentBufferedReader(std::shared_ptr<Logger> info_log, in FragmentBufferedReader() function
168 ~FragmentBufferedReader() override {} in ~FragmentBufferedReader()
184 FragmentBufferedReader(const FragmentBufferedReader&);
185 void operator=(const FragmentBufferedReader&);
Dlog_reader.cc399 bool FragmentBufferedReader::ReadRecord(Slice* record, std::string* scratch, in ReadRecord()
501 void FragmentBufferedReader::UnmarkEOF() { in UnmarkEOF()
509 bool FragmentBufferedReader::TryReadMore(size_t* drop_size, int* error) { in TryReadMore()
544 bool FragmentBufferedReader::TryReadFragment( in TryReadFragment()
Dversion_set_test.cc983 std::unique_ptr<log::FragmentBufferedReader> manifest_reader; in TEST_F()
1004 std::unique_ptr<log::FragmentBufferedReader> manifest_reader; in TEST_F()
1048 std::unique_ptr<log::FragmentBufferedReader> manifest_reader; in TEST_F()
1086 std::unique_ptr<log::FragmentBufferedReader> manifest_reader; in TEST_F()
1131 std::unique_ptr<log::FragmentBufferedReader> manifest_reader; in TEST_F()
1149 std::unique_ptr<log::FragmentBufferedReader> manifest_reader; in TEST_F()
1182 std::unique_ptr<log::FragmentBufferedReader> manifest_reader; in TEST_F()
1200 std::unique_ptr<log::FragmentBufferedReader> manifest_reader; in TEST_F()
Dlog_test.cc182 reader_.reset(new FragmentBufferedReader( in LogTest()
732 std::unique_ptr<FragmentBufferedReader> log_reader_;
773 log_reader_.reset(new FragmentBufferedReader( in SetupTestEnv()
Dversion_set.h1233 std::unique_ptr<log::FragmentBufferedReader>* manifest_reader,
1237 std::unique_ptr<log::FragmentBufferedReader>* manifest_reader,
1258 std::unique_ptr<log::FragmentBufferedReader>* manifest_reader);
Dversion_set.cc5789 std::unique_ptr<log::FragmentBufferedReader>* manifest_reader, in Recover()
5940 std::unique_ptr<log::FragmentBufferedReader>* manifest_reader, in ReadAndApply()
6169 std::unique_ptr<log::FragmentBufferedReader>* manifest_reader) { in MaybeSwitchManifest()
6199 manifest_reader->reset(new log::FragmentBufferedReader( in MaybeSwitchManifest()
/rocksdb-6.9/db/db_impl/
Ddb_impl_secondary.h36 reader_ = new log::FragmentBufferedReader(info_log, std::move(file_reader), in LogReaderContainer()
40 log::FragmentBufferedReader* reader_;
217 log::FragmentBufferedReader** log_reader);
319 std::unique_ptr<log::FragmentBufferedReader> manifest_reader_;
Ddb_impl_secondary.cc128 uint64_t log_number, log::FragmentBufferedReader** log_reader) { in MaybeInitLogReader()
183 log::FragmentBufferedReader* reader = nullptr; in RecoverLogFiles()
193 log::FragmentBufferedReader* reader = it->second->reader_; in RecoverLogFiles()