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
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
|
// -*- mode:C++; tab-width:8; c-basic-offset:2; indent-tabs-mode:t -*-
// vim: ts=8 sw=2 smarttab
#pragma once
#include "crimson/os/seastore/cache.h"
#include "crimson/os/seastore/cached_extent.h"
#include "crimson/os/seastore/transaction.h"
#include "crimson/os/seastore/backref_mapping.h"
namespace crimson::os::seastore {
/**
* Abstract interface for managing back references that map paddr_t to laddr_t
*/
class BackrefManager {
public:
using base_ertr = crimson::errorator<
crimson::ct_error::input_output_error>;
using base_iertr = trans_iertr<base_ertr>;
using mkfs_iertr = base_iertr;
using mkfs_ret = mkfs_iertr::future<>;
virtual mkfs_ret mkfs(
Transaction &t) = 0;
/**
* Fetches mappings for paddr_t in range [offset, offset + len)
*
* Future will not resolve until all pins have resolved
*/
using get_mappings_iertr = base_iertr;
using get_mappings_ret = get_mappings_iertr::future<backref_pin_list_t>;
virtual get_mappings_ret get_mappings(
Transaction &t,
paddr_t offset,
paddr_t end) = 0;
/**
* Fetches the mapping for paddr_t
*
* Future will not resolve until the pin has resolved
*/
using get_mapping_iertr = base_iertr::extend<
crimson::ct_error::enoent>;
using get_mapping_ret = get_mapping_iertr::future<BackrefMappingRef>;
virtual get_mapping_ret get_mapping(
Transaction &t,
paddr_t offset) = 0;
/**
* rewrite_extent
*
* rewrite extent into passed transaction
*/
using rewrite_extent_iertr = base_iertr;
using rewrite_extent_ret = rewrite_extent_iertr::future<>;
virtual rewrite_extent_ret rewrite_extent(
Transaction &t,
CachedExtentRef extent) = 0;
/**
* Insert new paddr_t -> laddr_t mapping
*/
using new_mapping_iertr = base_iertr;
using new_mapping_ret = new_mapping_iertr::future<BackrefMappingRef>;
virtual new_mapping_ret new_mapping(
Transaction &t,
paddr_t key,
extent_len_t len,
laddr_t val,
extent_types_t type) = 0;
/**
* Check if a CachedExtent is alive, should be called
* after replay on each cached extent.
*
* @return returns whether the extent is alive
*/
using init_cached_extent_iertr = base_iertr;
using init_cached_extent_ret = init_cached_extent_iertr::future<bool>;
virtual init_cached_extent_ret init_cached_extent(
Transaction &t,
CachedExtentRef e) = 0;
virtual Cache::backref_entry_query_mset_t
get_cached_backref_entries_in_range(
paddr_t start,
paddr_t end) = 0;
using retrieve_backref_extents_in_range_iertr = base_iertr;
using retrieve_backref_extents_in_range_ret =
retrieve_backref_extents_in_range_iertr::future<std::vector<CachedExtentRef>>;
virtual retrieve_backref_extents_in_range_ret
retrieve_backref_extents_in_range(
Transaction &t,
paddr_t start,
paddr_t end) = 0;
virtual void cache_new_backref_extent(
paddr_t paddr,
paddr_t key,
extent_types_t type) = 0;
/**
* merge in-cache paddr_t -> laddr_t mappings to the on-disk backref tree
*/
using merge_cached_backrefs_iertr = base_iertr;
using merge_cached_backrefs_ret = merge_cached_backrefs_iertr::future<journal_seq_t>;
virtual merge_cached_backrefs_ret merge_cached_backrefs(
Transaction &t,
const journal_seq_t &limit,
const uint64_t max) = 0;
struct remove_mapping_result_t {
paddr_t offset = P_ADDR_NULL;
extent_len_t len = 0;
laddr_t laddr = L_ADDR_NULL;
};
/**
* delete the mapping for paddr_t offset
*/
using remove_mapping_iertr = base_iertr::extend<
crimson::ct_error::enoent>;
using remove_mapping_ret = remove_mapping_iertr::future<remove_mapping_result_t>;
virtual remove_mapping_ret remove_mapping(
Transaction &t,
paddr_t offset) = 0;
/**
* scan all extents in both tree and cache,
* including backref extents, logical extents and lba extents,
* visit them with scan_mapped_space_func_t
*/
using scan_mapped_space_iertr = base_iertr;
using scan_mapped_space_ret = scan_mapped_space_iertr::future<>;
using scan_mapped_space_func_t = std::function<
void(paddr_t, paddr_t, extent_len_t, extent_types_t, laddr_t)>;
virtual scan_mapped_space_ret scan_mapped_space(
Transaction &t,
scan_mapped_space_func_t &&f) = 0;
virtual ~BackrefManager() {}
};
using BackrefManagerRef =
std::unique_ptr<BackrefManager>;
BackrefManagerRef create_backref_manager(
Cache &cache);
} // namespace crimson::os::seastore::backref
|
