Lines Matching refs:reader

4370     log::Reader* reader, AtomicGroupReadBuffer* read_buffer,  in ReadAndRecover()  argument
4376 assert(reader != nullptr); in ReadAndRecover()
4382 while (reader->ReadRecord(&record, &scratch) && s.ok()) { in ReadAndRecover()
4496 log::Reader reader(nullptr, std::move(manifest_file_reader), &reporter, in Recover() local
4499 s = ReadAndRecover(&reader, &read_buffer, cf_name_to_options, in Recover()
4502 current_manifest_file_size = reader.GetReadOffset(); in Recover()
4763 log::Reader reader(nullptr, std::move(manifest_file_reader), &reporter, in TryRecoverFromOneManifest() local
4769 s = handler_pit.Iterate(reader, db_id); in TryRecoverFromOneManifest()
4808 log::Reader reader(nullptr, std::move(file_reader), &reporter, in ListColumnFamilies() local
4812 while (reader.ReadRecord(&record, &scratch) && s.ok()) { in ListColumnFamilies()
5004 log::Reader reader(nullptr, std::move(file_reader), &reporter, in DumpManifest() local
5008 while (reader.ReadRecord(&record, &scratch) && s.ok()) { in DumpManifest()
5826 log::Reader* reader = manifest_reader->get(); in Recover() local
5831 assert(reader != nullptr); in Recover()
5834 s = ReadAndRecover(reader, &read_buffer_, cf_name_to_options, in Recover()
5951 log::Reader* reader = manifest_reader->get(); in ReadAndApply() local
5952 std::string old_manifest_path = reader->file()->file_name(); in ReadAndApply()
5953 while (reader->ReadRecord(&record, &scratch)) { in ReadAndApply()
6010 s = MaybeSwitchManifest(reader->GetReporter(), manifest_reader); in ReadAndApply()
6011 reader = manifest_reader->get(); in ReadAndApply()
6013 if (reader->file()->file_name() == old_manifest_path) { in ReadAndApply()