seq,
segment.get_segment_id(),
segment_provider->get_journal_tail_target()};
- ::encode(header, bl);
+ encode(header, bl);
bufferptr bp(
ceph::buffer::create_page_aligned(
record.deltas.size(),
record.extents.size()
};
- ::encode(header, metadatabl);
+ encode(header, metadatabl);
for (const auto &i: record.extents) {
- ::encode(extent_info_t(i), metadatabl);
+ encode(extent_info_t(i), metadatabl);
}
for (const auto &i: record.deltas) {
- ::encode(i, metadatabl);
+ encode(i, metadatabl);
}
bufferlist databl;
for (auto &i: record.extents) {
auto bp = bl.cbegin();
try {
- ::decode(header, bp);
+ decode(header, bp);
} catch (ceph::buffer::error &e) {
logger().debug(
"find_replay_segments: segment {} unable to decode "
auto bp = bl.cbegin();
record_header_t header;
try {
- ::decode(header, bp);
+ decode(header, bp);
} catch (ceph::buffer::error &e) {
return read_record_metadata_ret(
read_record_metadata_ertr::ready_future_marker{},
std::vector<delta_info_t> deltas(header.deltas);
for (auto &&i : deltas) {
try {
- ::decode(i, bliter);
+ decode(i, bliter);
} catch (ceph::buffer::error &e) {
return std::nullopt;
}
std::vector<extent_info_t> extent_infos(header.extents);
for (auto &&i : extent_infos) {
try {
- ::decode(i, bliter);
+ decode(i, bliter);
} catch (ceph::buffer::error &e) {
return std::nullopt;
}
ceph::bufferlist TestBlock::get_delta() {
ceph::bufferlist bl;
- ::encode(delta, bl);
+ encode(delta, bl);
return bl;
}
void TestBlock::apply_delta(const ceph::bufferlist &bl) {
auto biter = bl.begin();
decltype(delta) deltas;
- ::decode(deltas, biter);
+ decode(deltas, biter);
for (auto &&d : deltas) {
set_contents(d.val, d.offset, d.len);
}