void ceph_lock_state_t::add_waiting(const ceph_filelock& fl)
{
waiting_locks.insert(pair<uint64_t, ceph_filelock>(fl.start, fl));
+ ++client_waiting_lock_counts[(client_t)fl.client];
if (type == CEPH_LOCK_FCNTL) {
global_waiting_locks.insert(pair<ceph_filelock,ceph_lock_state_t*>(fl, this));
}
if (ret) {
++client_held_lock_counts[(client_t)new_lock.client];
}
- else if (wait_on_fail && !replay)
- ++client_waiting_lock_counts[(client_t)new_lock.client];
return ret;
}