LU-16741 ptlrpc: rename ptlrpc_req_finished for component ptlrpc

Patch renames ptlrpc_req_finished to ptlrpc_req_put for
ptlrpc component

Test-Parameters: trivial
Signed-off-by: Arshad Hussain <arshad.hussain@aeoncomputing.com>
Change-Id: Ic41d76ace564132a369288676398bc881048f851
Reviewed-on: https://review.whamcloud.com/c/fs/lustre-release/+/54988
Tested-by: jenkins <devops@whamcloud.com>
Tested-by: Maloo <maloo@whamcloud.com>
Reviewed-by: Andreas Dilger <adilger@whamcloud.com>
Reviewed-by: Patrick Farrell <patrick.farrell@oracle.com>
Reviewed-by: Oleg Drokin <green@whamcloud.com>

diff --git a/lustre/ptlrpc/batch.c b/lustre/ptlrpc/batch.c
index ecaa860..9fbccae 100644 (file)
--- a/lustre/ptlrpc/batch.c
+++ b/lustre/ptlrpc/batch.c
@@ -214,7 +214,7 @@ static int batch_prep_update_req(struct batch_update_head *head,
 
 out_req:
        if (rc < 0)
-               ptlrpc_req_finished(req);
+               ptlrpc_req_put(req);
 
        RETURN(rc);
 }
@@ -493,7 +493,7 @@ static int batch_send_update_req(const struct lu_env *env,
        }
 
        if (req != NULL)
-               ptlrpc_req_finished(req);
+               ptlrpc_req_put(req);
 
        lprocfs_oh_tally_log2(&obd->u.cli.cl_batch_rpc_hist,
                              head->buh_update_count);

diff --git a/lustre/ptlrpc/client.c b/lustre/ptlrpc/client.c
index bca26f9..aae522b 100644 (file)
--- a/lustre/ptlrpc/client.c
+++ b/lustre/ptlrpc/client.c
@@ -1160,7 +1160,7 @@ void ptlrpc_set_destroy(struct ptlrpc_request_set *set)
                req->rq_invalid_rqset = 0;
                spin_unlock(&req->rq_lock);
 
-               ptlrpc_req_finished(req);
+               ptlrpc_req_put(req);
        }
 
        LASSERT(atomic_read(&set->set_remaining) == 0);
@@ -2296,7 +2296,7 @@ interpret:
                        /* record rq_status to compute the final status later */
                        if (req->rq_status != 0)
                                set->set_rc = req->rq_status;
-                       ptlrpc_req_finished(req);
+                       ptlrpc_req_put(req);
                } else {
                        list_move_tail(&req->rq_set_chain, &comp_reqs);
                }
@@ -3730,7 +3730,7 @@ void ptlrpcd_destroy_work(void *handler)
        struct ptlrpc_request *req = handler;
 
        if (req)
-               ptlrpc_req_finished(req);
+               ptlrpc_req_put(req);
 }
 EXPORT_SYMBOL(ptlrpcd_destroy_work);
 

diff --git a/lustre/ptlrpc/events.c b/lustre/ptlrpc/events.c
index 789bc75..11762ba 100644 (file)
--- a/lustre/ptlrpc/events.c
+++ b/lustre/ptlrpc/events.c
@@ -83,7 +83,7 @@ void request_out_callback(struct lnet_event *ev)
 
        spin_unlock(&req->rq_lock);
 
-       ptlrpc_req_finished(req);
+       ptlrpc_req_put(req);
        EXIT;
 }
 

diff --git a/lustre/ptlrpc/gss/gss_cli_upcall.c b/lustre/ptlrpc/gss/gss_cli_upcall.c
index 073fa12..09bf063 100644 (file)
--- a/lustre/ptlrpc/gss/gss_cli_upcall.c
+++ b/lustre/ptlrpc/gss/gss_cli_upcall.c
@@ -383,7 +383,7 @@ out_copy:
                rc = 0;
 
        class_import_put(imp);
-       ptlrpc_req_finished(req);
+       ptlrpc_req_put(req);
        RETURN(rc);
 }
 
@@ -446,7 +446,7 @@ int gss_do_ctx_fini_rpc(struct gss_cli_ctx *gctx)
                       ctx->cc_vcred.vc_uid, sec2target_str(ctx->cc_sec), rc);
 
 out_ref:
-        ptlrpc_req_finished(req);
+       ptlrpc_req_put(req);
 out:
         RETURN(rc);
 }

diff --git a/lustre/ptlrpc/import.c b/lustre/ptlrpc/import.c
index e9340e9..496458c 100644 (file)
--- a/lustre/ptlrpc/import.c
+++ b/lustre/ptlrpc/import.c
@@ -1767,7 +1767,7 @@ int ptlrpc_disconnect_import(struct obd_import *imp, int noclose)
        spin_unlock(&imp->imp_lock);
 
        rc = ptlrpc_queue_wait(req);
-       ptlrpc_req_finished(req);
+       ptlrpc_req_put(req);
 
 set_state:
        spin_lock(&imp->imp_lock);

diff --git a/lustre/ptlrpc/llog_client.c b/lustre/ptlrpc/llog_client.c
index 42be66a..349bc57 100644 (file)
--- a/lustre/ptlrpc/llog_client.c
+++ b/lustre/ptlrpc/llog_client.c
@@ -143,7 +143,7 @@ static int llog_client_open(const struct lu_env *env,
        EXIT;
 out:
        llog_client_exit(ctxt, imp);
-       ptlrpc_req_finished(req);
+       ptlrpc_req_put(req);
        return rc;
 }
 
@@ -217,7 +217,7 @@ static int llog_client_next_block(const struct lu_env *env,
        memcpy(buf, ptr, len);
        EXIT;
 out:
-       ptlrpc_req_finished(req);
+       ptlrpc_req_put(req);
 err_exit:
        llog_client_exit(loghandle->lgh_ctxt, imp);
        return rc;
@@ -270,7 +270,7 @@ static int llog_client_prev_block(const struct lu_env *env,
        memcpy(buf, ptr, len);
        EXIT;
 out:
-       ptlrpc_req_finished(req);
+       ptlrpc_req_put(req);
 err_exit:
        llog_client_exit(loghandle->lgh_ctxt, imp);
        return rc;
@@ -338,7 +338,7 @@ static int llog_client_read_header(const struct lu_env *env,
        }
        EXIT;
 out:
-       ptlrpc_req_finished(req);
+       ptlrpc_req_put(req);
 err_exit:
        llog_client_exit(handle->lgh_ctxt, imp);
        return rc;

diff --git a/lustre/ptlrpc/lproc_ptlrpc.c b/lustre/ptlrpc/lproc_ptlrpc.c
index ce27a97..ae29ac3 100644 (file)
--- a/lustre/ptlrpc/lproc_ptlrpc.c
+++ b/lustre/ptlrpc/lproc_ptlrpc.c
@@ -1350,7 +1350,7 @@ ssize_t ping_show(struct kobject *kobj, struct attribute *attr,
        req->rq_send_state = LUSTRE_IMP_FULL;
 
        rc = ptlrpc_queue_wait(req);
-       ptlrpc_req_finished(req);
+       ptlrpc_req_put(req);
 
        RETURN(rc);
 }

diff --git a/lustre/ptlrpc/niobuf.c b/lustre/ptlrpc/niobuf.c
index 0c72605..0d5687f 100644 (file)
--- a/lustre/ptlrpc/niobuf.c
+++ b/lustre/ptlrpc/niobuf.c
@@ -978,7 +978,7 @@ int ptl_send_rpc(struct ptlrpc_request *request, int noreply)
 
 skip_send:
        request->rq_req_unlinked = 1;
-       ptlrpc_req_finished(request);
+       ptlrpc_req_put(request);
        if (noreply)
                GOTO(out, rc);
 

diff --git a/lustre/ptlrpc/pack_generic.c b/lustre/ptlrpc/pack_generic.c
index babc190..c8f082d 100644 (file)
--- a/lustre/ptlrpc/pack_generic.c
+++ b/lustre/ptlrpc/pack_generic.c
@@ -1755,7 +1755,7 @@ int do_set_info_async(struct obd_import *imp,
                ptlrpc_check_set(NULL, set);
        } else {
                rc = ptlrpc_queue_wait(req);
-               ptlrpc_req_finished(req);
+               ptlrpc_req_put(req);
        }
 
        RETURN(rc);

diff --git a/lustre/ptlrpc/pinger.c b/lustre/ptlrpc/pinger.c
index 0abc772..431b9a1 100644 (file)
--- a/lustre/ptlrpc/pinger.c
+++ b/lustre/ptlrpc/pinger.c
@@ -86,7 +86,7 @@ int ptlrpc_obd_ping(struct obd_device *obd)
                }
                req->rq_send_state = LUSTRE_IMP_FULL;
                rc = ptlrpc_queue_wait(req);
-               ptlrpc_req_finished(req);
+               ptlrpc_req_put(req);
        }
        RETURN(rc);
 }

diff --git a/lustre/ptlrpc/ptlrpcd.c b/lustre/ptlrpc/ptlrpcd.c
index 3b90bce..2186372 100644 (file)
--- a/lustre/ptlrpc/ptlrpcd.c
+++ b/lustre/ptlrpc/ptlrpcd.c
@@ -373,7 +373,7 @@ static int ptlrpcd_check(struct lu_env *env, struct ptlrpcd_ctl *pc)
 
                list_del_init(&req->rq_set_chain);
                req->rq_set = NULL;
-               ptlrpc_req_finished(req);
+               ptlrpc_req_put(req);
        }
 
        if (rc == 0) {