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
|
// -*- mode:C++; tab-width:8; c-basic-offset:2; indent-tabs-mode:t -*-
// vim: ts=8 sw=2 smarttab
#include "common/debug.h"
#include "Utils.h"
#include <set>
namespace librbd {
namespace deep_copy {
namespace util {
#define dout_subsys ceph_subsys_rbd
#undef dout_prefix
#define dout_prefix *_dout << "librbd::deep_copy::util::" << __func__ << ": "
void compute_snap_map(CephContext* cct,
librados::snap_t src_snap_id_start,
librados::snap_t src_snap_id_end,
const SnapIds& dst_snap_ids,
const SnapSeqs &snap_seqs,
SnapMap *snap_map) {
std::set<librados::snap_t> ordered_dst_snap_ids{
dst_snap_ids.begin(), dst_snap_ids.end()};
auto dst_snap_id_it = ordered_dst_snap_ids.begin();
SnapIds snap_ids;
for (auto &it : snap_seqs) {
// ensure all dst snap ids are included in the mapping table since
// deep copy will skip non-user snapshots
while (dst_snap_id_it != ordered_dst_snap_ids.end()) {
if (*dst_snap_id_it < it.second) {
snap_ids.insert(snap_ids.begin(), *dst_snap_id_it);
} else if (*dst_snap_id_it > it.second) {
break;
}
++dst_snap_id_it;
}
// we should only have the HEAD revision in the the last snap seq
ceph_assert(snap_ids.empty() || snap_ids[0] != CEPH_NOSNAP);
snap_ids.insert(snap_ids.begin(), it.second);
if (it.first < src_snap_id_start) {
continue;
} else if (it.first > src_snap_id_end) {
break;
}
(*snap_map)[it.first] = snap_ids;
}
ldout(cct, 10) << "src_snap_id_start=" << src_snap_id_start << ", "
<< "src_snap_id_end=" << src_snap_id_end << ", "
<< "dst_snap_ids=" << dst_snap_ids << ", "
<< "snap_seqs=" << snap_seqs << ", "
<< "snap_map=" << *snap_map << dendl;
}
} // namespace util
} // namespace deep_copy
} // namespace librbd
|
