--- /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) 2013 Inktank, Inc
+ *
+ * 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 <sstream>
+#include <stdlib.h>
+#include <limits.h>
+
+#include "mon/Monitor.h"
+#include "mon/ConfigKeyService.h"
+#include "mon/MonitorDBStore.h"
+#include "mon/OSDMonitor.h"
+#include "common/errno.h"
+#include "include/stringify.h"
+
+#define dout_subsys ceph_subsys_mon
+#undef dout_prefix
+#define dout_prefix _prefix(_dout, mon, this)
+static ostream& _prefix(std::ostream *_dout, const Monitor *mon,
+ const ConfigKeyService *service) {
+ return *_dout << "mon." << mon->name << "@" << mon->rank
+ << "(" << mon->get_state_name() << ")." << service->get_name()
+ << "(" << service->get_epoch() << ") ";
+}
+
+const string ConfigKeyService::STORE_PREFIX = "mon_config_key";
+
+int ConfigKeyService::store_get(const string &key, bufferlist &bl)
+{
+ return mon->store->get(STORE_PREFIX, key, bl);
+}
+
+void ConfigKeyService::get_store_prefixes(set<string>& s)
+{
+ s.insert(STORE_PREFIX);
+}
+
+void ConfigKeyService::store_put(const string &key, bufferlist &bl, Context *cb)
+{
+ MonitorDBStore::TransactionRef t = paxos->get_pending_transaction();
+ t->put(STORE_PREFIX, key, bl);
+ if (cb)
+ paxos->queue_pending_finisher(cb);
+ paxos->trigger_propose();
+}
+
+void ConfigKeyService::store_delete(const string &key, Context *cb)
+{
+ MonitorDBStore::TransactionRef t = paxos->get_pending_transaction();
+ store_delete(t, key);
+ if (cb)
+ paxos->queue_pending_finisher(cb);
+ paxos->trigger_propose();
+}
+
+void ConfigKeyService::store_delete(
+ MonitorDBStore::TransactionRef t,
+ const string &key)
+{
+ t->erase(STORE_PREFIX, key);
+}
+
+bool ConfigKeyService::store_exists(const string &key)
+{
+ return mon->store->exists(STORE_PREFIX, key);
+}
+
+void ConfigKeyService::store_list(stringstream &ss)
+{
+ KeyValueDB::Iterator iter =
+ mon->store->get_iterator(STORE_PREFIX);
+
+ JSONFormatter f(true);
+ f.open_array_section("keys");
+
+ while (iter->valid()) {
+ string key(iter->key());
+ f.dump_string("key", key);
+ iter->next();
+ }
+ f.close_section();
+ f.flush(ss);
+}
+
+bool ConfigKeyService::store_has_prefix(const string &prefix)
+{
+ KeyValueDB::Iterator iter =
+ mon->store->get_iterator(STORE_PREFIX);
+
+ while (iter->valid()) {
+ string key(iter->key());
+ size_t p = key.find(prefix);
+ if (p != string::npos && p == 0) {
+ return true;
+ }
+ iter->next();
+ }
+ return false;
+}
+
+void ConfigKeyService::store_dump(stringstream &ss)
+{
+ KeyValueDB::Iterator iter =
+ mon->store->get_iterator(STORE_PREFIX);
+
+ JSONFormatter f(true);
+ f.open_object_section("config-key store");
+
+ while (iter->valid()) {
+ f.dump_string(iter->key().c_str(), iter->value().to_str());
+ iter->next();
+ }
+ f.close_section();
+ f.flush(ss);
+}
+
+void ConfigKeyService::store_delete_prefix(
+ MonitorDBStore::TransactionRef t,
+ const string &prefix)
+{
+ KeyValueDB::Iterator iter =
+ mon->store->get_iterator(STORE_PREFIX);
+
+ while (iter->valid()) {
+ string key(iter->key());
+
+ size_t p = key.find(prefix);
+ if (p != string::npos && p == 0) {
+ store_delete(t, key);
+ }
+ iter->next();
+ }
+}
+
+bool ConfigKeyService::service_dispatch(MonOpRequestRef op)
+{
+ Message *m = op->get_req();
+ assert(m != NULL);
+ dout(10) << __func__ << " " << *m << dendl;
+
+ if (!in_quorum()) {
+ dout(1) << __func__ << " not in quorum -- waiting" << dendl;
+ paxos->wait_for_readable(op, new Monitor::C_RetryMessage(mon, op));
+ return false;
+ }
+
+ assert(m->get_type() == MSG_MON_COMMAND);
+
+ MMonCommand *cmd = static_cast<MMonCommand*>(m);
+
+ assert(!cmd->cmd.empty());
+
+ int ret = 0;
+ stringstream ss;
+ bufferlist rdata;
+
+ string prefix;
+ map<string, cmd_vartype> cmdmap;
+
+ if (!cmdmap_from_json(cmd->cmd, &cmdmap, ss)) {
+ return false;
+ }
+
+ cmd_getval(g_ceph_context, cmdmap, "prefix", prefix);
+ string key;
+ cmd_getval(g_ceph_context, cmdmap, "key", key);
+
+ if (prefix == "config-key get") {
+ ret = store_get(key, rdata);
+ if (ret < 0) {
+ assert(!rdata.length());
+ ss << "error obtaining '" << key << "': " << cpp_strerror(ret);
+ goto out;
+ }
+ ss << "obtained '" << key << "'";
+
+ } else if (prefix == "config-key put" ||
+ prefix == "config-key set") {
+ if (!mon->is_leader()) {
+ mon->forward_request_leader(op);
+ // we forward the message; so return now.
+ return true;
+ }
+
+ bufferlist data;
+ string val;
+ if (cmd_getval(g_ceph_context, cmdmap, "val", val)) {
+ // they specified a value in the command instead of a file
+ data.append(val);
+ } else if (cmd->get_data_len() > 0) {
+ // they specified '-i <file>'
+ data = cmd->get_data();
+ }
+ if (data.length() > (size_t) g_conf->mon_config_key_max_entry_size) {
+ ret = -EFBIG; // File too large
+ ss << "error: entry size limited to "
+ << g_conf->mon_config_key_max_entry_size << " bytes. "
+ << "Use 'mon config key max entry size' to manually adjust";
+ goto out;
+ }
+ // we'll reply to the message once the proposal has been handled
+ ss << "set " << key;
+ store_put(key, data,
+ new Monitor::C_Command(mon, op, 0, ss.str(), 0));
+ // return for now; we'll put the message once it's done.
+ return true;
+
+ } else if (prefix == "config-key del" ||
+ prefix == "config-key rm") {
+ if (!mon->is_leader()) {
+ mon->forward_request_leader(op);
+ return true;
+ }
+
+ if (!store_exists(key)) {
+ ret = 0;
+ ss << "no such key '" << key << "'";
+ goto out;
+ }
+ store_delete(key, new Monitor::C_Command(mon, op, 0, "key deleted", 0));
+ // return for now; we'll put the message once it's done
+ return true;
+
+ } else if (prefix == "config-key exists") {
+ bool exists = store_exists(key);
+ ss << "key '" << key << "'";
+ if (exists) {
+ ss << " exists";
+ ret = 0;
+ } else {
+ ss << " doesn't exist";
+ ret = -ENOENT;
+ }
+
+ } else if (prefix == "config-key list" ||
+ prefix == "config-key ls") {
+ stringstream tmp_ss;
+ store_list(tmp_ss);
+ rdata.append(tmp_ss);
+ ret = 0;
+
+ } else if (prefix == "config-key dump") {
+ stringstream tmp_ss;
+ store_dump(tmp_ss);
+ rdata.append(tmp_ss);
+ ret = 0;
+
+ }
+
+out:
+ if (!cmd->get_source().is_mon()) {
+ string rs = ss.str();
+ mon->reply_command(op, ret, rs, rdata, 0);
+ }
+
+ return (ret == 0);
+}
+
+string _get_dmcrypt_prefix(const uuid_d& uuid, const string k)
+{
+ return "dm-crypt/osd/" + stringify(uuid) + "/" + k;
+}
+
+int ConfigKeyService::validate_osd_destroy(
+ const int32_t id,
+ const uuid_d& uuid)
+{
+ string dmcrypt_prefix = _get_dmcrypt_prefix(uuid, "");
+ string daemon_prefix =
+ "daemon-private/osd." + stringify(id) + "/";
+
+ if (!store_has_prefix(dmcrypt_prefix) &&
+ !store_has_prefix(daemon_prefix)) {
+ return -ENOENT;
+ }
+ return 0;
+}
+
+void ConfigKeyService::do_osd_destroy(int32_t id, uuid_d& uuid)
+{
+ string dmcrypt_prefix = _get_dmcrypt_prefix(uuid, "");
+ string daemon_prefix =
+ "daemon-private/osd." + stringify(id) + "/";
+
+ MonitorDBStore::TransactionRef t = paxos->get_pending_transaction();
+ for (auto p : { dmcrypt_prefix, daemon_prefix }) {
+ store_delete_prefix(t, p);
+ }
+
+ paxos->trigger_propose();
+}
+
+int ConfigKeyService::validate_osd_new(
+ const uuid_d& uuid,
+ const string& dmcrypt_key,
+ stringstream& ss)
+{
+ string dmcrypt_prefix = _get_dmcrypt_prefix(uuid, "luks");
+ bufferlist value;
+ value.append(dmcrypt_key);
+
+ if (store_exists(dmcrypt_prefix)) {
+ bufferlist existing_value;
+ int err = store_get(dmcrypt_prefix, existing_value);
+ if (err < 0) {
+ dout(10) << __func__ << " unable to get dm-crypt key from store (r = "
+ << err << ")" << dendl;
+ return err;
+ }
+ if (existing_value.contents_equal(value)) {
+ // both values match; this will be an idempotent op.
+ return EEXIST;
+ }
+ ss << "dm-crypt key already exists and does not match";
+ return -EEXIST;
+ }
+ return 0;
+}
+
+void ConfigKeyService::do_osd_new(
+ const uuid_d& uuid,
+ const string& dmcrypt_key)
+{
+ assert(paxos->is_plugged());
+
+ string dmcrypt_key_prefix = _get_dmcrypt_prefix(uuid, "luks");
+ bufferlist dmcrypt_key_value;
+ dmcrypt_key_value.append(dmcrypt_key);
+ // store_put() will call trigger_propose
+ store_put(dmcrypt_key_prefix, dmcrypt_key_value, nullptr);
+}
Code Review / stor4nfv.git / blobdiff