FileReader *log_reader = new FileReader(
log_file, cct->_conf->bluefs_max_prefetch,
- false, // !random
true); // ignore eof
bool seen_recs = false;
File::wal_flush_t flush;
bool envelope_good;
uint64_t file_size = file->fnode.size;
- FileReader *h = new FileReader(file, 4096, false, true);
+ FileReader *h = new FileReader(file, 4096, true);
ceph_assert(h);
while(scan_ofs < file->fnode.allocated) {
envelope_good = _read_wal_flush(h, scan_ofs, wal_ofs, &flush);
_wal_index_file(file);
}
*h = new FileReader(file, random ? 4096 : cct->_conf->bluefs_max_prefetch,
- random, file->is_new_wal());
+ file->is_new_wal());
dout(10) << __func__ << " h " << *h << " on " << file->fnode << dendl;
return 0;
}
FileRef file;
FileReaderBuffer buf;
- bool random;
bool ignore_eof; ///< used when reading our log file
-
ceph::shared_mutex lock {
ceph::make_shared_mutex(std::string(), false, false, false)
};
- FileReader(FileRef f, uint64_t mpf, bool rand, bool ie)
+ FileReader(FileRef f, uint64_t mpf, bool ie)
: file(f),
buf(mpf),
- random(rand),
ignore_eof(ie) {
++file->num_readers;
}