No longer used.
Signed-off-by: Sage Weil <sage@redhat.com>
assert(waiting_for_cache_not_full.empty());
assert(waiting_for_unreadable_object.empty());
assert(waiting_for_degraded_object.empty());
- assert(waiting_for_ack.empty());
assert(waiting_for_ondisk.empty());
assert(waiting_for_active.empty());
map<hobject_t, list<Context*>, hobject_t::BitwiseComparator> callbacks_for_degraded_object;
map<eversion_t,
- list<pair<OpRequestRef, version_t> > > waiting_for_ack, waiting_for_ondisk;
+ list<pair<OpRequestRef, version_t> > > waiting_for_ondisk;
void split_ops(PG *child, unsigned split_bits);
}
waiting_for_ondisk.erase(repop->v);
}
-
- // clear out acks, we sent the commits above
- if (waiting_for_ack.count(repop->v)) {
- assert(waiting_for_ack.begin()->first == repop->v);
- waiting_for_ack.erase(repop->v);
- }
}
// applied?
}
waiting_for_ondisk.clear();
- waiting_for_ack.clear();
}
void PrimaryLogPG::on_flushed()