if (!mon->is_leader())
return;
mon->key_server.start_server();
-/*
- check_rotate();
-*/
}
void AuthMonitor::create_initial()
<< " max_global_id=" << max_global_id
<< " format_version " << format_version
<< dendl;
-
- /*
- bufferlist bl;
- __u8 v = 1;
- ::encode(v, bl);
- ::encode(max_global_id, bl);
- Mutex::Locker l(mon->key_server.get_lock());
- ::encode(mon->key_server, bl);
- paxos->stash_latest(version, bl);
- */
}
void AuthMonitor::increase_max_global_id()
}
if (ret == -EIO) {
wait_for_active(new C_RetryMessage(this,m));
- //paxos->wait_for_active(new C_RetryMessage(this, m));
goto done;
}
if (caps_info.caps.length()) {
getline(ss, rs);
err = 0;
wait_for_finished_proposal(new Monitor::C_Command(mon, m, 0, rs, get_last_committed()));
- //paxos->wait_for_commit(new Monitor::C_Command(mon, m, 0, rs, get_last_committed()));
return true;
} else if (prefix == "auth add" && !entity_name.empty()) {
/* expected behavior:
ss << "added key for " << auth_inc.name;
getline(ss, rs);
wait_for_finished_proposal(new Monitor::C_Command(mon, m, 0, rs, get_last_committed()));
- //paxos->wait_for_commit(new Monitor::C_Command(mon, m, 0, rs, get_last_committed()));
return true;
} else if ((prefix == "auth get-or-create-key" ||
prefix == "auth get-or-create") &&
if (auth_inc.op == KeyServerData::AUTH_INC_ADD &&
auth_inc.name == entity) {
wait_for_finished_proposal(new Monitor::C_Command(mon, m, 0, rs, get_last_committed()));
- //paxos->wait_for_commit(new C_RetryMessage(this, m));
return true;
}
}
rdata.append(ds);
getline(ss, rs);
wait_for_finished_proposal(new Monitor::C_Command(mon, m, 0, rs, rdata, get_last_committed()));
- //paxos->wait_for_commit(new Monitor::C_Command(mon, m, 0, rs, get_last_committed()));
return true;
} else if (prefix == "auth caps" && !entity_name.empty()) {
KeyServerData::Incremental auth_inc;
ss << "updated caps for " << auth_inc.name;
getline(ss, rs);
wait_for_finished_proposal(new Monitor::C_Command(mon, m, 0, rs, get_last_committed()));
- //paxos->wait_for_commit(new Monitor::C_Command(mon, m, 0, rs, get_last_committed()));
return true;
} else if (prefix == "auth del" && !entity_name.empty()) {
KeyServerData::Incremental auth_inc;
ss << "updated";
getline(ss, rs);
wait_for_finished_proposal(new Monitor::C_Command(mon, m, 0, rs, get_last_committed()));
- //paxos->wait_for_commit(new Monitor::C_Command(mon, m, 0, rs, get_last_committed()));
return true;
}