From: Arshad Hussain Date: Thu, 2 May 2024 10:40:02 +0000 (-0400) Subject: LU-16741 osp: rename ptlrpc_req_finished for component osp X-Git-Tag: 2.15.64~204 X-Git-Url: https://git.whamcloud.com/?a=commitdiff_plain;h=b0a1007be2247b1ac9b75f491849cc202aac6783;p=fs%2Flustre-release.git LU-16741 osp: rename ptlrpc_req_finished for component osp Patch renames ptlrpc_req_finished to ptlrpc_req_put for osp component Test-Parameters: trivial Signed-off-by: Arshad Hussain Change-Id: I0da0f922be2a062459c14585f910ef2a6c425b14 Reviewed-on: https://review.whamcloud.com/c/fs/lustre-release/+/54986 Tested-by: jenkins Tested-by: Maloo Reviewed-by: Andreas Dilger Reviewed-by: Patrick Farrell Reviewed-by: Oleg Drokin --- diff --git a/lustre/osp/osp_dev.c b/lustre/osp/osp_dev.c index 69c9068..702e030 100644 --- a/lustre/osp/osp_dev.c +++ b/lustre/osp/osp_dev.c @@ -1564,7 +1564,7 @@ static int osp_obd_statfs(const struct lu_env *env, struct obd_export *exp, EXIT; out: - ptlrpc_req_finished(req); + ptlrpc_req_put(req); return rc; } diff --git a/lustre/osp/osp_md_object.c b/lustre/osp/osp_md_object.c index 453d797..089046e 100644 --- a/lustre/osp/osp_md_object.c +++ b/lustre/osp/osp_md_object.c @@ -549,7 +549,7 @@ static int osp_md_index_lookup(const struct lu_env *env, struct dt_object *dt, out: if (req != NULL) - ptlrpc_req_finished(req); + ptlrpc_req_put(req); osp_update_request_destroy(env, update); @@ -916,7 +916,7 @@ static int osp_md_xattr_list(const struct lu_env *env, struct dt_object *dt, out: if (req) - ptlrpc_req_finished(req); + ptlrpc_req_put(req); if (update && !IS_ERR(update)) osp_update_request_destroy(env, update); @@ -988,7 +988,7 @@ static int osp_md_object_lock(const struct lu_env *env, (const union ldlm_policy_data *)policy, &flags, NULL, 0, LVB_T_NONE, lh, 0); - ptlrpc_req_finished(req); + ptlrpc_req_put(req); RETURN(rc == ELDLM_OK ? 0 : -EIO); } @@ -1378,7 +1378,7 @@ static ssize_t osp_md_read(const struct lu_env *env, struct dt_object *dt, rc = orr->orr_size; *pos = orr->orr_offset; out: - ptlrpc_req_finished(req); + ptlrpc_req_put(req); out_update: osp_update_request_destroy(env, update); diff --git a/lustre/osp/osp_object.c b/lustre/osp/osp_object.c index 38910f1..0baae90 100644 --- a/lustre/osp/osp_object.c +++ b/lustre/osp/osp_object.c @@ -665,7 +665,7 @@ out: out_req: if (req != NULL) - ptlrpc_req_finished(req); + ptlrpc_req_put(req); osp_update_request_destroy(env, update); @@ -796,7 +796,7 @@ static int osp_attr_set(const struct lu_env *env, struct dt_object *dt, rc = osp_remote_sync(env, osp, update, &req); if (req != NULL) - ptlrpc_req_finished(req); + ptlrpc_req_put(req); osp_update_request_destroy(env, update); } else { @@ -1187,7 +1187,7 @@ out_req: } if (req) - ptlrpc_req_finished(req); + ptlrpc_req_put(req); if (update && !IS_ERR(update)) osp_update_request_destroy(env, update); @@ -1950,7 +1950,7 @@ static int osp_it_fetch(const struct lu_env *env, struct osp_it *it) it->ooi_next = ii->ii_hash_end; out: - ptlrpc_req_finished(req); + ptlrpc_req_put(req); return rc; } diff --git a/lustre/osp/osp_precreate.c b/lustre/osp/osp_precreate.c index 9ddef83..3c8b035 100644 --- a/lustre/osp/osp_precreate.c +++ b/lustre/osp/osp_precreate.c @@ -726,7 +726,7 @@ out_req: /* now we can wakeup all users awaiting for objects */ osp_pre_update_status(d, rc); - ptlrpc_req_finished(req); + ptlrpc_req_put(req); if (!rc) osp_update_fldb_cache(env, d, fid); @@ -828,7 +828,7 @@ static int osp_get_lastfid_from_ost(const struct lu_env *env, PFID(last_fid)); out: - ptlrpc_req_finished(req); + ptlrpc_req_put(req); RETURN(rc); } @@ -978,7 +978,7 @@ static int osp_precreate_cleanup_orphans(struct lu_env *env, PFID(&d->opd_pre_last_created_fid), PFID(&d->opd_last_used_fid)); out: if (req) - ptlrpc_req_finished(req); + ptlrpc_req_put(req); /* @@ -1756,7 +1756,7 @@ int osp_object_truncate(const struct lu_env *env, struct dt_object *dt, } } out: - ptlrpc_req_finished(req); + ptlrpc_req_put(req); if (oa) OBD_FREE_PTR(oa); RETURN(rc); diff --git a/lustre/osp/osp_sync.c b/lustre/osp/osp_sync.c index be0f901..5c5fb7a 100644 --- a/lustre/osp/osp_sync.c +++ b/lustre/osp/osp_sync.c @@ -680,7 +680,7 @@ static struct ptlrpc_request *osp_sync_new_job(struct osp_device *d, rc = ptlrpc_request_pack(req, LUSTRE_OST_VERSION, op); if (rc) { - ptlrpc_req_finished(req); + ptlrpc_req_put(req); return ERR_PTR(rc); } @@ -1071,7 +1071,7 @@ static void osp_sync_process_committed(const struct lu_env *env, DEBUG_REQ(D_OTHER, req, "imp_committed = %llu", imp->imp_peer_committed_transno); } - ptlrpc_req_finished(req); + ptlrpc_req_put(req); done++; if (arr && ((i * sizeof(int)) == arr_size || diff --git a/lustre/osp/osp_trans.c b/lustre/osp/osp_trans.c index dba32bc..ae39b81 100644 --- a/lustre/osp/osp_trans.c +++ b/lustre/osp/osp_trans.c @@ -450,7 +450,7 @@ int osp_prep_update_req(const struct lu_env *env, struct obd_import *imp, out_req: if (rc < 0) - ptlrpc_req_finished(req); + ptlrpc_req_put(req); RETURN(rc); } @@ -489,7 +489,7 @@ int osp_remote_sync(const struct lu_env *env, struct osp_device *osp, rc = ptlrpc_queue_wait(req); our->our_rc = rc; if (rc < 0 || reqp == NULL) - ptlrpc_req_finished(req); + ptlrpc_req_put(req); else *reqp = req; @@ -1220,7 +1220,7 @@ static int osp_send_update_req(const struct lu_env *env, } out: if (req != NULL) - ptlrpc_req_finished(req); + ptlrpc_req_put(req); RETURN(rc); }