bool Paxos::is_readable(version_t v)
{
- dout(1) << "is_readable now=" << g_clock.now() << " lease_expire=" << lease_expire << dendl;
- if(v > last_committed)
+ dout(1) << "is_readable now=" << g_clock.now() << " lease_expire=" << lease_expire
+ << " has v" << v << " lc " << last_committed << dendl;
+ if (v > last_committed)
return false;
return
(mon->is_peon() || mon->is_leader()) &&
// make sure our map is readable and up to date
if (!paxos->is_readable(m->version)) {
- dout(10) << " waiting for paxos -> readable" << dendl;
+ dout(10) << " waiting for paxos -> readable (v" << m->version << ")" << dendl;
paxos->wait_for_readable(new C_RetryMessage(this, m));
return true;
}
messenger(m), monc(mc), osdmap(om),
last_tid(0), client_inc(-1),
num_unacked(0), num_uncommitted(0),
+ last_seen_version(0),
client_lock(l), timer(l)
{ }
~Objecter() { }