PaxosServiceMessage *m = static_cast<PaxosServiceMessage*>(op->get_req());
op->mark_event("psvc:dispatch");
- dout(10) << "dispatch " << m << " " << *m
+ dout(10) << __func__ << " " << m << " " << *m
<< " from " << m->get_orig_source_inst()
<< " con " << m->get_connection() << dendl;
void PaxosService::propose_pending()
{
- dout(10) << "propose_pending" << dendl;
+ dout(10) << __func__ << dendl;
assert(have_pending);
assert(!proposing);
assert(mon->is_leader());
void PaxosService::restart()
{
- dout(10) << "restart" << dendl;
+ dout(10) << __func__ << dendl;
if (proposal_timer) {
dout(10) << " canceling proposal_timer " << proposal_timer << dendl;
mon->timer.cancel_event(proposal_timer);
void PaxosService::election_finished()
{
- dout(10) << "election_finished" << dendl;
+ dout(10) << __func__ << dendl;
finish_contexts(g_ceph_context, waiting_for_finished_proposal, -EAGAIN);
void PaxosService::_active()
{
if (is_proposing()) {
- dout(10) << "_acting - proposing" << dendl;
+ dout(10) << __func__ << " - proposing" << dendl;
return;
}
if (!is_active()) {
- dout(10) << "_active - not active" << dendl;
+ dout(10) << __func__ << " - not active" << dendl;
/**
* Callback used to make sure we call the PaxosService::_active function
* whenever a condition is fulfilled.
wait_for_active_ctx(new C_Active(this));
return;
}
- dout(10) << "_active" << dendl;
+ dout(10) << __func__ << dendl;
// create pending state?
if (mon->is_leader()) {
- dout(7) << "_active creating new pending" << dendl;
+ dout(7) << __func__ << " creating new pending" << dendl;
if (!have_pending) {
create_pending();
have_pending = true;