segments.begin(),
segments.end(),
[](const auto <, const auto &rt) {
- return lt.second.journal_segment_seq <
- rt.second.journal_segment_seq;
+ return lt.second.segment_seq <
+ rt.second.segment_seq;
});
segment_seq_allocator->set_next_segment_seq(
- segments.rbegin()->second.journal_segment_seq + 1);
+ segments.rbegin()->second.segment_seq + 1);
std::for_each(
segments.begin(),
segments.end(),
auto& seg_addr = replay_from.as_seg_paddr();
return seg.first == seg_addr.get_segment_id();
});
- if (from->second.journal_segment_seq != journal_tail.segment_seq) {
+ if (from->second.segment_seq != journal_tail.segment_seq) {
ERROR("journal_tail {} does not match {}",
journal_tail, from->second);
ceph_abort();
from, segments.end(), ret.begin(),
[this](const auto &p) {
auto ret = journal_seq_t{
- p.second.journal_segment_seq,
+ p.second.segment_seq,
paddr_t::make_seg_paddr(
p.first,
journal_segment_allocator.get_block_size())
std::ostream &operator<<(std::ostream &out, const segment_header_t &header)
{
return out << "segment_header_t("
- << "segment_seq=" << segment_seq_printer_t{header.journal_segment_seq}
+ << "segment_seq=" << segment_seq_printer_t{header.segment_seq}
<< ", segment_id=" << header.physical_segment_id
<< ", journal_tail=" << header.journal_tail
<< ", segment_nonce=" << header.segment_nonce
std::ostream &operator<<(std::ostream &out, const segment_tail_t &tail)
{
return out << "segment_tail_t("
- << "segment_seq=" << tail.journal_segment_seq
+ << "segment_seq=" << tail.segment_seq
<< ", segment_id=" << tail.physical_segment_id
<< ", journal_tail=" << tail.journal_tail
<< ", segment_nonce=" << tail.segment_nonce
* 2) Replay starting at record located at that segment's journal_tail
*/
struct segment_header_t {
- segment_seq_t journal_segment_seq;
+ segment_seq_t segment_seq;
segment_id_t physical_segment_id; // debugging
journal_seq_t journal_tail;
DENC(segment_header_t, v, p) {
DENC_START(1, 1, p);
- denc(v.journal_segment_seq, p);
+ denc(v.segment_seq, p);
denc(v.physical_segment_id, p);
denc(v.journal_tail, p);
denc(v.segment_nonce, p);
std::ostream &operator<<(std::ostream &out, const segment_header_t &header);
struct segment_tail_t {
- segment_seq_t journal_segment_seq;
+ segment_seq_t segment_seq;
segment_id_t physical_segment_id; // debugging
journal_seq_t journal_tail;
DENC(segment_tail_t, v, p) {
DENC_START(1, 1, p);
- denc(v.journal_segment_seq, p);
+ denc(v.segment_seq, p);
denc(v.physical_segment_id, p);
denc(v.journal_tail, p);
denc(v.segment_nonce, p);
}
init_mark_segment_closed(
segment_id,
- header.journal_segment_seq,
+ header.segment_seq,
header.type);
return seastar::now();
}).handle_error(
}).safe_then([this, segment_id, header](auto) {
init_mark_segment_closed(
segment_id,
- header.journal_segment_seq,
+ header.segment_seq,
header.type);
return seastar::now();
});
}
init_mark_segment_closed(
segment_id,
- header.journal_segment_seq,
+ header.segment_seq,
header.type);
return seastar::now();
}