CircularBoundedJournal::open_for_write_ret CircularBoundedJournal::open_for_write()
{
- if (init) {
+ if (initialized) {
paddr_t paddr = convert_abs_addr_to_paddr(
get_written_to(),
header.device_id);
{
return write_header(
).safe_then([this]() -> close_ertr::future<> {
- init = false;
+ initialized = false;
return device->close();
}).handle_error(
open_for_write_ertr::pass_further{},
CircularBoundedJournal::open_device_read_header(rbm_abs_addr start)
{
LOG_PREFIX(CircularBoundedJournal::open_for_write);
- ceph_assert(!init);
+ ceph_assert(!initialized);
return _open_device(path
).safe_then([this, start, FNAME]() {
return read_header(start
get_written_to(),
header.device_id);
start_dev_addr = start;
- init = true;
+ initialized = true;
return open_for_write_ret(
open_for_write_ertr::ready_future_marker{},
journal_seq_t{
* true after open_device_read_header, set to false in close().
* Indicates that device is open and in-memory header is valid.
*/
- bool init = false;
+ bool initialized = false;
segment_seq_t cur_segment_seq = 0; // segment seq to track the sequence to written records
rbm_abs_addr start_dev_addr = 0; // cbjournal start address in device
// start address where the newest record will be written