| /rocksdb-6.9/utilities/blob_db/ |
| D | blob_log_reader.h | 33 class Reader {
43 Reader(std::unique_ptr<RandomAccessFileReader>&& file_reader, Env* env,
46 Reader(const Reader&) = delete;
47 Reader& operator=(const Reader&) = delete;
49 ~Reader() = default;
|
| D | blob_log_reader.cc | 19 Reader::Reader(std::unique_ptr<RandomAccessFileReader>&& file_reader, Env* env, in Reader() function in ROCKSDB_NAMESPACE::blob_db::Reader
27 Status Reader::ReadSlice(uint64_t size, Slice* slice, char* buf) { in ReadSlice()
42 Status Reader::ReadHeader(BlobLogHeader* header) { in ReadHeader()
57 Status Reader::ReadRecord(BlobLogRecord* record, ReadLevel level, in ReadRecord()
|
| D | blob_file.cc | 64 std::shared_ptr<Reader> BlobFile::OpenRandomAccessReader( in OpenRandomAccessReader()
81 std::shared_ptr<Reader> log_reader = std::make_shared<Reader>( in OpenRandomAccessReader()
|
| D | blob_file.h | 222 std::shared_ptr<Reader> OpenRandomAccessReader(
|
| /rocksdb-6.9/db/ |
| D | log_reader.h | 31 class Reader {
51 Reader(std::shared_ptr<Logger> info_log,
56 Reader(const Reader&) = delete;
57 void operator=(const Reader&) = delete;
59 virtual ~Reader();
159 class FragmentBufferedReader : public Reader {
165 : Reader(info_log, std::move(_file), reporter, checksum, log_num), in FragmentBufferedReader()
|
| D | log_reader.cc | 23 Reader::Reporter::~Reporter() { in ~Reporter()
26 Reader::Reader(std::shared_ptr<Logger> info_log, in Reader() function in ROCKSDB_NAMESPACE::log::Reader
43 Reader::~Reader() { in ~Reader()
54 bool Reader::ReadRecord(Slice* record, std::string* scratch, in ReadRecord()
201 uint64_t Reader::LastRecordOffset() { in LastRecordOffset()
205 void Reader::UnmarkEOF() { in UnmarkEOF()
216 void Reader::UnmarkEOFInternal() { in UnmarkEOFInternal()
269 void Reader::ReportCorruption(size_t bytes, const char* reason) { in ReportCorruption()
273 void Reader::ReportDrop(size_t bytes, const Status& reason) { in ReportDrop()
279 bool Reader::ReadMore(size_t* drop_size, int *error) { in ReadMore()
[all …]
|
| D | forward_iterator_bench.cc | 72 struct Reader;
79 Reader* reader;
89 struct Reader { struct
91 explicit Reader(std::vector<ShardState>* shard_states, in Reader() function
95 thread_ = port::Thread(&Reader::run, this); in Reader()
185 ~Reader() { in ~Reader() argument
352 std::deque<Reader> readers; in main()
|
| D | version_edit_handler.h | 43 Status Iterate(log::Reader& reader, std::string* db_id);
63 virtual void CheckIterationResult(const log::Reader& reader, Status* s);
114 void CheckIterationResult(const log::Reader& reader, Status* s) override;
|
| D | transaction_log_impl.h | 88 std::unique_ptr<log::Reader> current_log_reader_;
93 struct LogReporter : public log::Reader::Reporter {
|
| D | version_edit_handler.cc | 30 Status VersionEditHandler::Iterate(log::Reader& reader, std::string* db_id) { in Iterate()
249 void VersionEditHandler::CheckIterationResult(const log::Reader& reader, in CheckIterationResult()
487 const log::Reader& reader, Status* s) { in CheckIterationResult()
|
| D | log_test.cc | 131 class ReportCollector : public Reader::Reporter {
166 std::unique_ptr<Reader> reader_;
186 reader_.reset(new Reader(nullptr, std::move(source_holder_), &report_, in LogTest()
710 class ReportCollector : public Reader::Reporter {
|
| D | version_set.h | 1093 struct LogReporter : public log::Reader::Reporter {
1127 log::Reader* reader, AtomicGroupReadBuffer* read_buffer,
1238 std::unique_ptr<log::Reader::Reporter>* manifest_reporter,
1257 log::Reader::Reporter* reporter,
|
| D | version_set_test.cc | 984 std::unique_ptr<log::Reader::Reporter> manifest_reporter; in TEST_F()
1005 std::unique_ptr<log::Reader::Reporter> manifest_reporter; in TEST_F()
1049 std::unique_ptr<log::Reader::Reporter> manifest_reporter; in TEST_F()
1087 std::unique_ptr<log::Reader::Reporter> manifest_reporter; in TEST_F()
1132 std::unique_ptr<log::Reader::Reporter> manifest_reporter; in TEST_F()
1150 std::unique_ptr<log::Reader::Reporter> manifest_reporter; in TEST_F()
1183 std::unique_ptr<log::Reader::Reporter> manifest_reporter; in TEST_F()
1201 std::unique_ptr<log::Reader::Reporter> manifest_reporter; in TEST_F()
|
| D | wal_manager.cc | 449 struct LogReporter : public log::Reader::Reporter { in ReadFirstLine()
484 log::Reader reader(db_options_.info_log, std::move(file_reader), &reporter, in ReadFirstLine()
|
| D | repair.cc | 333 struct LogReporter : public log::Reader::Reporter { in ConvertLogToTable()
364 log::Reader reader(db_options_.info_log, std::move(lfile_reader), &reporter, in ConvertLogToTable()
|
| D | transaction_log_impl.cc | 310 new log::Reader(options_->info_log, std::move(file), &reporter_, in OpenLogReader()
|
| D | version_set.cc | 4370 log::Reader* reader, AtomicGroupReadBuffer* read_buffer, in ReadAndRecover()
4496 log::Reader reader(nullptr, std::move(manifest_file_reader), &reporter, in Recover()
4763 log::Reader reader(nullptr, std::move(manifest_file_reader), &reporter, in TryRecoverFromOneManifest()
4808 log::Reader reader(nullptr, std::move(file_reader), &reporter, in ListColumnFamilies()
5004 log::Reader reader(nullptr, std::move(file_reader), &reporter, in DumpManifest()
5790 std::unique_ptr<log::Reader::Reporter>* manifest_reporter, in Recover()
5826 log::Reader* reader = manifest_reader->get(); in Recover()
5951 log::Reader* reader = manifest_reader->get(); in ReadAndApply()
6168 log::Reader::Reporter* reporter, in MaybeSwitchManifest()
|
| /rocksdb-6.9/db/db_impl/ |
| D | db_impl_secondary.h | 41 log::Reader::Reporter* reporter_;
49 struct LogReporter : public log::Reader::Reporter {
320 std::unique_ptr<log::Reader::Reporter> manifest_reporter_;
|
| D | db_impl_open.cc | 697 struct LogReporter : public log::Reader::Reporter { in RecoverLogFiles()
821 log::Reader reader(immutable_db_options_.info_log, std::move(file_reader), in RecoverLogFiles()
|
| /rocksdb-6.9/tools/ |
| D | ldb_cmd.cc | 2091 struct StdErrReporter : public log::Reader::Reporter {
2227 log::Reader reader(options.info_log, std::move(wal_file_reader), &reporter, in DumpWalFile()
|