for (auto& i : pending_inc.new_removed_snaps) {
{
// all snaps removed this epoch
- string k = make_snap_epoch_key(i.first, pending_inc.epoch);
+ string k = make_removed_snap_epoch_key(i.first, pending_inc.epoch);
bufferlist v;
encode(i.second, v);
t->put(OSD_SNAP_PREFIX, k, v);
for (auto& p : osdmap.get_pools()) {
auto& t = (*gap_removed_snaps)[p.first];
for (epoch_t epoch = start; epoch < end; ++epoch) {
- string k = make_snap_epoch_key(p.first, epoch);
+ string k = make_removed_snap_epoch_key(p.first, epoch);
bufferlist v;
mon->store->get(OSD_SNAP_PREFIX, k, v);
if (v.length()) {
pool->unset_flag(flags);
}
-string OSDMonitor::make_snap_epoch_key(int64_t pool, epoch_t epoch)
+string OSDMonitor::make_removed_snap_epoch_key(int64_t pool, epoch_t epoch)
{
char k[80];
snprintf(k, sizeof(k), "removed_epoch_%llu_%08lx",
bool _is_removed_snap(int64_t pool_id, snapid_t snapid);
bool _is_pending_removed_snap(int64_t pool_id, snapid_t snapid);
- string make_snap_epoch_key(int64_t pool, epoch_t epoch);
+ string make_removed_snap_epoch_key(int64_t pool, epoch_t epoch);
string _make_snap_key(bool purged, int64_t pool, snapid_t snap);
string _make_snap_key_value(bool purged,
int64_t pool, snapid_t snap, snapid_t num,