}
int OSDMonitor::prepare_pool_crush_rule(const unsigned pool_type,
- const string &erasure_code_profile,
- const string &rule_name,
- int *crush_rule,
- ostream *ss)
+ const string &erasure_code_profile,
+ const string &rule_name,
+ int *crush_rule,
+ ostream *ss)
{
if (*crush_rule < 0) {
case pg_pool_t::TYPE_REPLICATED:
{
if (rule_name == "") {
- //Use default rule
+ // Use default rule
*crush_rule = osdmap.crush->get_osd_pool_default_crush_replicated_ruleset(g_ceph_context);
if (*crush_rule < 0) {
// Errors may happen e.g. if no valid rule is available
}
int OSDMonitor::get_crush_rule(const string &rule_name,
- int *crush_rule,
- ostream *ss)
+ int *crush_rule,
+ ostream *ss)
{
int ret;
ret = osdmap.crush->get_rule_id(rule_name);
<< " try again" << dendl;
return -EAGAIN;
} else {
- //Cannot find it , return error
+ // Cannot find it , return error
*ss << "specified rule " << rule_name << " doesn't exist";
return ret;
}
r = tester.test();
} else {
r = tester.test_with_crushtool(g_conf->crushtool.c_str(),
- osdmap.get_max_osd(),
- g_conf->mon_lease,
- crush_rule);
+ osdmap.get_max_osd(),
+ g_conf->mon_lease,
+ crush_rule);
}
if (r) {
dout(10) << " tester.test_with_crushtool returns " << r
} while (false);
} else if (prefix == "osd crush reweight-all") {
- // osd crush reweight <name> <weight>
CrushWrapper newcrush;
_get_pending_crush(newcrush);
wait_for_finished_proposal(
op,
new Monitor::C_Command(mon, op, 0, rs, rdata, get_last_committed() + 1));
- return true;
+ return true;
} else if (prefix == "osd lost") {
int64_t id;
if (!cmd_getval(g_ceph_context, cmdmap, "id", id)) {
// make sure authmon is writeable.
if (!mon->authmon()->is_writeable()) {
dout(10) << __func__ << " waiting for auth mon to be writeable for "
- << "osd destroy" << dendl;
+ << "osd new" << dendl;
mon->authmon()->wait_for_writeable(op, new C_RetryMessage(this, op));
return false;
}