+++ /dev/null
-// -*- mode:C++; tab-width:8; c-basic-offset:2; indent-tabs-mode:t -*-
-// vim: ts=8 sw=2 smarttab
-/*
- * Ceph - scalable distributed file system
- *
- * Copyright (C) 2004-2006 Sage Weil <sage@newdream.net>
- *
- * This is free software; you can redistribute it and/or
- * modify it under the terms of the GNU Lesser General Public
- * License version 2.1, as published by the Free Software
- * Foundation. See file COPYING.
- *
- */
-
-#include "SnapMapper.h"
-
-#define dout_context cct
-#define dout_subsys ceph_subsys_osd
-#undef dout_prefix
-#define dout_prefix *_dout << "snap_mapper."
-
-using std::string;
-
-const string SnapMapper::MAPPING_PREFIX = "MAP_";
-const string SnapMapper::OBJECT_PREFIX = "OBJ_";
-
-int OSDriver::get_keys(
- const std::set<std::string> &keys,
- std::map<std::string, bufferlist> *out)
-{
- return os->omap_get_values(cid, hoid, keys, out);
-}
-
-int OSDriver::get_next(
- const std::string &key,
- pair<std::string, bufferlist> *next)
-{
- ObjectMap::ObjectMapIterator iter =
- os->get_omap_iterator(cid, hoid);
- if (!iter) {
- ceph_abort();
- return -EINVAL;
- }
- iter->upper_bound(key);
- if (iter->valid()) {
- if (next)
- *next = make_pair(iter->key(), iter->value());
- return 0;
- } else {
- return -ENOENT;
- }
-}
-
-struct Mapping {
- snapid_t snap;
- hobject_t hoid;
- explicit Mapping(const pair<snapid_t, hobject_t> &in)
- : snap(in.first), hoid(in.second) {}
- Mapping() : snap(0) {}
- void encode(bufferlist &bl) const {
- ENCODE_START(1, 1, bl);
- ::encode(snap, bl);
- ::encode(hoid, bl);
- ENCODE_FINISH(bl);
- }
- void decode(bufferlist::iterator &bl) {
- DECODE_START(1, bl);
- ::decode(snap, bl);
- ::decode(hoid, bl);
- DECODE_FINISH(bl);
- }
-};
-WRITE_CLASS_ENCODER(Mapping)
-
-string SnapMapper::get_prefix(snapid_t snap)
-{
- char buf[100];
- int len = snprintf(
- buf, sizeof(buf),
- "%.*X_", (int)(sizeof(snap)*2),
- static_cast<unsigned>(snap));
- return MAPPING_PREFIX + string(buf, len);
-}
-
-string SnapMapper::to_raw_key(
- const pair<snapid_t, hobject_t> &in)
-{
- return get_prefix(in.first) + shard_prefix + in.second.to_str();
-}
-
-pair<string, bufferlist> SnapMapper::to_raw(
- const pair<snapid_t, hobject_t> &in)
-{
- bufferlist bl;
- ::encode(Mapping(in), bl);
- return make_pair(
- to_raw_key(in),
- bl);
-}
-
-pair<snapid_t, hobject_t> SnapMapper::from_raw(
- const pair<std::string, bufferlist> &image)
-{
- Mapping map;
- bufferlist bl(image.second);
- bufferlist::iterator bp(bl.begin());
- ::decode(map, bp);
- return make_pair(map.snap, map.hoid);
-}
-
-bool SnapMapper::is_mapping(const string &to_test)
-{
- return to_test.substr(0, MAPPING_PREFIX.size()) == MAPPING_PREFIX;
-}
-
-string SnapMapper::to_object_key(const hobject_t &hoid)
-{
- return OBJECT_PREFIX + shard_prefix + hoid.to_str();
-}
-
-void SnapMapper::object_snaps::encode(bufferlist &bl) const
-{
- ENCODE_START(1, 1, bl);
- ::encode(oid, bl);
- ::encode(snaps, bl);
- ENCODE_FINISH(bl);
-}
-
-void SnapMapper::object_snaps::decode(bufferlist::iterator &bl)
-{
- DECODE_START(1, bl);
- ::decode(oid, bl);
- ::decode(snaps, bl);
- DECODE_FINISH(bl);
-}
-
-int SnapMapper::get_snaps(
- const hobject_t &oid,
- object_snaps *out)
-{
- assert(check(oid));
- set<string> keys;
- map<string, bufferlist> got;
- keys.insert(to_object_key(oid));
- int r = backend.get_keys(keys, &got);
- if (r < 0)
- return r;
- if (got.empty())
- return -ENOENT;
- if (out) {
- bufferlist::iterator bp = got.begin()->second.begin();
- ::decode(*out, bp);
- dout(20) << __func__ << " " << oid << " " << out->snaps << dendl;
- assert(!out->snaps.empty());
- } else {
- dout(20) << __func__ << " " << oid << " (out == NULL)" << dendl;
- }
- return 0;
-}
-
-void SnapMapper::clear_snaps(
- const hobject_t &oid,
- MapCacher::Transaction<std::string, bufferlist> *t)
-{
- dout(20) << __func__ << " " << oid << dendl;
- assert(check(oid));
- set<string> to_remove;
- to_remove.insert(to_object_key(oid));
- if (g_conf->subsys.should_gather(ceph_subsys_osd, 20)) {
- for (auto& i : to_remove) {
- dout(20) << __func__ << " rm " << i << dendl;
- }
- }
- backend.remove_keys(to_remove, t);
-}
-
-void SnapMapper::set_snaps(
- const hobject_t &oid,
- const object_snaps &in,
- MapCacher::Transaction<std::string, bufferlist> *t)
-{
- assert(check(oid));
- map<string, bufferlist> to_set;
- bufferlist bl;
- ::encode(in, bl);
- to_set[to_object_key(oid)] = bl;
- dout(20) << __func__ << " " << oid << " " << in.snaps << dendl;
- if (g_conf->subsys.should_gather(ceph_subsys_osd, 20)) {
- for (auto& i : to_set) {
- dout(20) << __func__ << " set " << i.first << dendl;
- }
- }
- backend.set_keys(to_set, t);
-}
-
-int SnapMapper::update_snaps(
- const hobject_t &oid,
- const set<snapid_t> &new_snaps,
- const set<snapid_t> *old_snaps_check,
- MapCacher::Transaction<std::string, bufferlist> *t)
-{
- dout(20) << __func__ << " " << oid << " " << new_snaps
- << " was " << (old_snaps_check ? *old_snaps_check : set<snapid_t>())
- << dendl;
- assert(check(oid));
- if (new_snaps.empty())
- return remove_oid(oid, t);
-
- object_snaps out;
- int r = get_snaps(oid, &out);
- if (r < 0)
- return r;
- if (old_snaps_check)
- assert(out.snaps == *old_snaps_check);
-
- object_snaps in(oid, new_snaps);
- set_snaps(oid, in, t);
-
- set<string> to_remove;
- for (set<snapid_t>::iterator i = out.snaps.begin();
- i != out.snaps.end();
- ++i) {
- if (!new_snaps.count(*i)) {
- to_remove.insert(to_raw_key(make_pair(*i, oid)));
- }
- }
- if (g_conf->subsys.should_gather(ceph_subsys_osd, 20)) {
- for (auto& i : to_remove) {
- dout(20) << __func__ << " rm " << i << dendl;
- }
- }
- backend.remove_keys(to_remove, t);
- return 0;
-}
-
-void SnapMapper::add_oid(
- const hobject_t &oid,
- const set<snapid_t>& snaps,
- MapCacher::Transaction<std::string, bufferlist> *t)
-{
- dout(20) << __func__ << " " << oid << " " << snaps << dendl;
- assert(check(oid));
- {
- object_snaps out;
- int r = get_snaps(oid, &out);
- assert(r == -ENOENT);
- }
-
- object_snaps _snaps(oid, snaps);
- set_snaps(oid, _snaps, t);
-
- map<string, bufferlist> to_add;
- for (set<snapid_t>::iterator i = snaps.begin();
- i != snaps.end();
- ++i) {
- to_add.insert(to_raw(make_pair(*i, oid)));
- }
- if (g_conf->subsys.should_gather(ceph_subsys_osd, 20)) {
- for (auto& i : to_add) {
- dout(20) << __func__ << " set " << i.first << dendl;
- }
- }
- backend.set_keys(to_add, t);
-}
-
-int SnapMapper::get_next_objects_to_trim(
- snapid_t snap,
- unsigned max,
- vector<hobject_t> *out)
-{
- assert(out);
- assert(out->empty());
- int r = 0;
- for (set<string>::iterator i = prefixes.begin();
- i != prefixes.end() && out->size() < max && r == 0;
- ++i) {
- string prefix(get_prefix(snap) + *i);
- string pos = prefix;
- while (out->size() < max) {
- pair<string, bufferlist> next;
- r = backend.get_next(pos, &next);
- dout(20) << __func__ << " get_next(" << pos << ") returns " << r
- << " " << next << dendl;
- if (r != 0) {
- break; // Done
- }
-
- if (next.first.substr(0, prefix.size()) !=
- prefix) {
- break; // Done with this prefix
- }
-
- assert(is_mapping(next.first));
-
- dout(20) << __func__ << " " << next.first << dendl;
- pair<snapid_t, hobject_t> next_decoded(from_raw(next));
- assert(next_decoded.first == snap);
- assert(check(next_decoded.second));
-
- out->push_back(next_decoded.second);
- pos = next.first;
- }
- }
- if (out->size() == 0) {
- return -ENOENT;
- } else {
- return 0;
- }
-}
-
-
-int SnapMapper::remove_oid(
- const hobject_t &oid,
- MapCacher::Transaction<std::string, bufferlist> *t)
-{
- dout(20) << __func__ << " " << oid << dendl;
- assert(check(oid));
- return _remove_oid(oid, t);
-}
-
-int SnapMapper::_remove_oid(
- const hobject_t &oid,
- MapCacher::Transaction<std::string, bufferlist> *t)
-{
- dout(20) << __func__ << " " << oid << dendl;
- object_snaps out;
- int r = get_snaps(oid, &out);
- if (r < 0)
- return r;
-
- clear_snaps(oid, t);
-
- set<string> to_remove;
- for (set<snapid_t>::iterator i = out.snaps.begin();
- i != out.snaps.end();
- ++i) {
- to_remove.insert(to_raw_key(make_pair(*i, oid)));
- }
- if (g_conf->subsys.should_gather(ceph_subsys_osd, 20)) {
- for (auto& i : to_remove) {
- dout(20) << __func__ << " rm " << i << dendl;
- }
- }
- backend.remove_keys(to_remove, t);
- return 0;
-}
-
-int SnapMapper::get_snaps(
- const hobject_t &oid,
- std::set<snapid_t> *snaps)
-{
- assert(check(oid));
- object_snaps out;
- int r = get_snaps(oid, &out);
- if (r < 0)
- return r;
- if (snaps)
- snaps->swap(out.snaps);
- return 0;
-}
Code Review / stor4nfv.git / blobdiff