void Objecter::_kick_requests(OSDSession *session, map<uint64_t, LingerOp *>& lresend)
{
- assert(rwlock.is_locked());
+ assert(rwlock.is_wlocked());
// resend ops
map<ceph_tid_t,Op*> resend; // resend in tid order
void Objecter::_linger_ops_resend(map<uint64_t, LingerOp *>& lresend)
{
- assert(rwlock.is_locked());
+ assert(rwlock.is_wlocked());
while (!lresend.empty()) {
LingerOp *op = lresend.begin()->second;
void Objecter::_session_linger_op_remove(OSDSession *from, LingerOp *op)
{
assert(from == op->session);
- assert(from->lock.is_locked());
+ assert(from->lock.is_wlocked());
if (from->is_homeless()) {
num_homeless_ops.dec();