continue;
}
- // there can be no waiters here, so we don't call wake_pg_waiters
+ // there can be no waiters here, so we don't call _wake_pg_slot
pg->lock();
pg->ch = store->open_collection(pg->coll);
}
if (slot->to_process.empty()) {
- // raced with wake_pg_waiters or consume_map
+ // raced with _wake_pg_slot or consume_map
dout(20) << __func__ << " " << token
<< " nothing queued" << dendl;
if (pg) {
if (requeue_seq != slot->requeue_seq) {
dout(20) << __func__ << " " << token
<< " requeue_seq " << slot->requeue_seq << " > our "
- << requeue_seq << ", we raced with wake_pg_waiters"
+ << requeue_seq << ", we raced with _wake_pg_slot"
<< dendl;
if (pg) {
pg->unlock();