void Objecter::_finish_op(Op *op, int r)
{
- ldout(cct, 15) << "finish_op " << op->tid << dendl;
+ ldout(cct, 15) << __func__ << " " << op->tid << dendl;
// op->session->lock is locked unique or op->session is null
op->put();
}
-void Objecter::finish_op(OSDSession *session, ceph_tid_t tid)
-{
- ldout(cct, 15) << "finish_op " << tid << dendl;
- shared_lock rl(rwlock);
-
- OSDSession::unique_lock wl(session->lock);
-
- map<ceph_tid_t, Op *>::iterator iter = session->ops.find(tid);
- if (iter == session->ops.end())
- return;
-
- Op *op = iter->second;
-
- _finish_op(op, 0);
-}
-
MOSDOp *Objecter::_prepare_osd_op(Op *op)
{
// rwlock is locked
void _send_op(Op *op);
void _send_op_account(Op *op);
void _cancel_linger_op(Op *op);
- void finish_op(OSDSession *session, ceph_tid_t tid);
void _finish_op(Op *op, int r);
static bool is_pg_changed(
int oldprimary,