1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
|
// -*- mode:C++; tab-width:8; c-basic-offset:2; indent-tabs-mode:t -*-
// vim: ts=8 sw=2 smarttab
#include "seastore.h"
#include "crimson/os/seastore/onode_manager/staged-fltree/node_extent_accessor.h"
#include "crimson/os/seastore/onode_manager/staged-fltree/stages/node_stage_layout.h"
namespace {
seastar::logger& logger() {
return crimson::get_logger(ceph_subsys_filestore);
}
}
namespace crimson::os::seastore::onode {
static DeltaRecorderURef create_recorder(
node_type_t node_type, field_type_t field_type) {
if (node_type == node_type_t::LEAF) {
if (field_type == field_type_t::N0) {
return DeltaRecorderT<node_fields_0_t, node_type_t::LEAF>::create();
} else if (field_type == field_type_t::N1) {
return DeltaRecorderT<node_fields_1_t, node_type_t::LEAF>::create();
} else if (field_type == field_type_t::N2) {
return DeltaRecorderT<node_fields_2_t, node_type_t::LEAF>::create();
} else if (field_type == field_type_t::N3) {
return DeltaRecorderT<leaf_fields_3_t, node_type_t::LEAF>::create();
} else {
ceph_abort("impossible path");
}
} else if (node_type == node_type_t::INTERNAL) {
if (field_type == field_type_t::N0) {
return DeltaRecorderT<node_fields_0_t, node_type_t::INTERNAL>::create();
} else if (field_type == field_type_t::N1) {
return DeltaRecorderT<node_fields_1_t, node_type_t::INTERNAL>::create();
} else if (field_type == field_type_t::N2) {
return DeltaRecorderT<node_fields_2_t, node_type_t::INTERNAL>::create();
} else if (field_type == field_type_t::N3) {
return DeltaRecorderT<internal_fields_3_t, node_type_t::INTERNAL>::create();
} else {
ceph_abort("impossible path");
}
} else {
ceph_abort("impossible path");
}
}
void SeastoreSuper::write_root_laddr(context_t c, laddr_t addr) {
logger().info("OTree::Seastore: update root {:#x} ...", addr);
root_addr = addr;
auto nm = static_cast<SeastoreNodeExtentManager*>(&c.nm);
nm->get_tm().write_onode_root(c.t, addr);
}
NodeExtentRef SeastoreNodeExtent::mutate(
context_t c, DeltaRecorderURef&& _recorder) {
logger().debug("OTree::Seastore: mutate {:#x} ...", get_laddr());
auto nm = static_cast<SeastoreNodeExtentManager*>(&c.nm);
auto extent = nm->get_tm().get_mutable_extent(c.t, this);
auto ret = extent->cast<SeastoreNodeExtent>();
assert(!ret->recorder || ret->recorder->is_empty());
ret->recorder = std::move(_recorder);
return ret;
}
void SeastoreNodeExtent::apply_delta(const ceph::bufferlist& bl) {
logger().debug("OTree::Seastore: replay {:#x} ...", get_laddr());
if (!recorder) {
auto [node_type, field_type] = get_types();
recorder = create_recorder(node_type, field_type);
} else {
#ifndef NDEBUG
auto [node_type, field_type] = get_types();
assert(recorder->node_type() == node_type);
assert(recorder->field_type() == field_type);
#endif
}
assert(is_clean());
auto node = do_get_mutable();
auto p = bl.cbegin();
while (p != bl.end()) {
recorder->apply_delta(p, node);
}
}
}
|
