/************ MAPS ****************/
OSDMonitor::OSDMonitor(Monitor *mn, Paxos *p)
: PaxosService(mn, p),
+ delete_pool_nonce(0),
thrash_map(0), thrash_last_up_osd(-1)
{
// we need to trim this too
paxos->wait_for_commit(new Monitor::C_Command(mon, m, 0, rs, paxos->get_version()));
return true;
} else if (m->cmd[2] == "delete" && m->cmd.size() >= 4) {
- //hey, let's delete a pool!
+ // osd pool delete <poolname> <poolname again> <nonce>
+ // hey, let's delete a pool!
int64_t pool = osdmap.lookup_pg_pool_name(m->cmd[3].c_str());
if (pool < 0) {
ss << "pool '" << m->cmd[3] << "' does not exist";
err = 0;
- } else {
- int ret = _prepare_remove_pool(pool);
- if (ret == 0)
- ss << "pool '" << m->cmd[3] << "' deleted";
- getline(ss, rs);
- paxos->wait_for_commit(new Monitor::C_Command(mon, m, ret, rs, paxos->get_version()));
- return true;
+ goto out;
+ }
+ if (m->cmd.size() < 6) {
+ delete_pool_nonce = rand();
+ delete_pool_nonce_timeout = ceph_clock_now(g_ceph_context);
+ delete_pool_nonce_timeout += 30;
+ ss << "WARNING: this will efficiently **DESTROY** an entire pool of data. if you are ABSOLUTELY CERTAIN"
+ << " that this is what you want to do, retry listing the pool name twice, followed by " << delete_pool_nonce
+ << " within 30 seconds.";
+ err = -EPERM;
+ goto out;
}
+ assert(m->cmd.size() >= 6);
+ if (m->cmd[4] != m->cmd[3]) {
+ ss << "ERROR: you must list the pool name you want to **DESTROY** twice";
+ err = -EPERM;
+ goto out;
+ }
+ unsigned safety = atol(m->cmd[5].c_str());
+ if (safety != delete_pool_nonce) {
+ ss << "ERROR: did not confirm pool deletion with correct confirmation; " << safety << " != " << delete_pool_nonce << "; try again";
+ err = -EPERM;
+ goto out;
+ }
+ if (ceph_clock_now(g_ceph_context) > delete_pool_nonce_timeout) {
+ ss << "ERROR: did not confirm pool deletion within 30 seconds; try again";
+ err = -EPERM;
+ goto out;
+ }
+ assert(safety == delete_pool_nonce);
+ delete_pool_nonce = 0;
+ delete_pool_nonce_timeout = utime_t();
+ int ret = _prepare_remove_pool(pool);
+ if (ret == 0)
+ ss << "pool '" << m->cmd[3] << "' deleted";
+ getline(ss, rs);
+ paxos->wait_for_commit(new Monitor::C_Command(mon, m, ret, rs, paxos->get_version()));
+ return true;
} else if (m->cmd[2] == "rename" && m->cmd.size() == 5) {
int64_t pool = osdmap.lookup_pg_pool_name(m->cmd[3].c_str());
if (pool < 0) {