if (unlikely(instant_cancel)) {
rc = ptl_send_rpc(req, 1);
- ptlrpc_req_finished(req);
+ ptlrpc_req_put(req);
if (rc == 0)
atomic_inc(&arg->restart);
} else {
if (ldlm_is_destroyed(lock)) {
/* What's the point? */
unlock_res_and_lock(lock);
- ptlrpc_req_finished(req);
+ ptlrpc_req_put(req);
RETURN(0);
}
ldlm_set_waited(lock);
unlock_res_and_lock(lock);
- ptlrpc_req_finished(req);
+ ptlrpc_req_put(req);
LDLM_DEBUG(lock, "lock not granted, not sending blocking AST");
RETURN(0);
}
failed_lock_cleanup(ns, lock, einfo->ei_mode);
LDLM_LOCK_RELEASE(lock);
if (!req_passed_in)
- ptlrpc_req_finished(req);
+ ptlrpc_req_put(req);
GOTO(out, rc);
}
}
out:
if (!req_passed_in && req != NULL) {
- ptlrpc_req_finished(req);
+ ptlrpc_req_put(req);
if (reqp)
*reqp = NULL;
}
rc = _ldlm_cancel_pack(req, lock, head, count);
if (rc == 0) {
- ptlrpc_req_finished(req);
+ ptlrpc_req_put(req);
sent = count;
GOTO(out, rc);
}
rc = 0;
} else if (rc == -ETIMEDOUT && /* check there was no reconnect*/
req->rq_import_generation == imp->imp_generation) {
- ptlrpc_req_finished(req);
+ ptlrpc_req_put(req);
continue;
} else if (rc != ELDLM_OK) {
/* -ESHUTDOWN is common on umount */
break;
}
- ptlrpc_req_finished(req);
+ ptlrpc_req_put(req);
EXIT;
out:
return sent ? sent : rc;