From e7fb59c6cc4d908a30c2313eff5ee948f637ed78 Mon Sep 17 00:00:00 2001 From: shaver Date: Mon, 8 Jul 2002 19:23:02 +0000 Subject: [PATCH] Default to an rq_level of LUSTRE_CONN_FULL. Use l_killable_pending in place of explicit lists of tests. --- lustre/mdc/mdc_request.c | 5 ----- lustre/ptlrpc/client.c | 5 ++--- 2 files changed, 2 insertions(+), 8 deletions(-) diff --git a/lustre/mdc/mdc_request.c b/lustre/mdc/mdc_request.c index 9fb9fca..d15c4a9 100644 --- a/lustre/mdc/mdc_request.c +++ b/lustre/mdc/mdc_request.c @@ -107,7 +107,6 @@ int mdc_getattr(struct lustre_handle *conn, size[1] = ea_size; } req->rq_replen = lustre_msg_size(bufcount, size); - req->rq_level = LUSTRE_CONN_FULL; rc = ptlrpc_queue_wait(req); rc = ptlrpc_check_status(req, rc); @@ -376,7 +375,6 @@ int mdc_open(struct lustre_handle *conn, obd_id ino, int type, int flags, GOTO(out, rc = -ENOMEM); req->rq_flags |= PTL_RPC_FL_REPLAY; - req->rq_level = LUSTRE_CONN_FULL; body = lustre_msg_buf(req->rq_reqmsg, 0); ll_ino2fid(&body->fid1, ino, 0, type); @@ -420,7 +418,6 @@ int mdc_close(struct lustre_handle *conn, ll_ino2fid(&body->fid1, ino, 0, type); body->extra = fh; - req->rq_level = LUSTRE_CONN_FULL; req->rq_replen = lustre_msg_size(0, NULL); rc = ptlrpc_queue_wait(req); @@ -472,7 +469,6 @@ int mdc_readpage(struct lustre_handle *conn, obd_id ino, int type, __u64 offset, body->size = offset; req->rq_replen = lustre_msg_size(1, &size); - req->rq_level = LUSTRE_CONN_FULL; rc = ptlrpc_queue_wait(req); rc = ptlrpc_check_status(req, rc); if (rc) { @@ -505,7 +501,6 @@ int mdc_statfs(struct lustre_handle *conn, struct statfs *sfs, if (!req) GOTO(out, rc = -ENOMEM); req->rq_replen = lustre_msg_size(1, &size); - req->rq_level = LUSTRE_CONN_FULL; rc = ptlrpc_queue_wait(req); rc = ptlrpc_check_status(req, rc); diff --git a/lustre/ptlrpc/client.c b/lustre/ptlrpc/client.c index 48cd95f..ce69521 100644 --- a/lustre/ptlrpc/client.c +++ b/lustre/ptlrpc/client.c @@ -176,6 +176,7 @@ struct ptlrpc_request *ptlrpc_prep_req(struct ptlrpc_client *cl, RETURN(NULL); } + request->rq_level = LUSTRE_CONN_FULL; request->rq_type = PTL_RPC_TYPE_REQUEST; request->rq_client = cl; request->rq_connection = ptlrpc_connection_addref(conn); @@ -289,9 +290,7 @@ static int ptlrpc_check_reply(struct ptlrpc_request *req) schedule_timeout(req->rq_timeout * HZ); } - if (sigismember(&(current->pending.signal), SIGKILL) || - sigismember(&(current->pending.signal), SIGTERM) || - sigismember(&(current->pending.signal), SIGINT)) { + if (l_killable_pending(current)) { req->rq_flags |= PTL_RPC_FL_INTR; GOTO(out, rc = 1); } -- 1.8.3.1