Skip to content

Commit 32ce62c

Browse files
jtlaytonchucklever
authored andcommitted
nfsd: move cb_need_restart flag into cb_flags
Since there is now a cb_flags word, use a new NFSD4_CALLBACK_REQUEUE flag in that instead of a separate boolean. Signed-off-by: Jeff Layton <jlayton@kernel.org> Signed-off-by: Chuck Lever <chuck.lever@oracle.com>
1 parent 49bdbdb commit 32ce62c

File tree

3 files changed

+6
-8
lines changed

3 files changed

+6
-8
lines changed

fs/nfsd/nfs4callback.c

Lines changed: 4 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -1071,7 +1071,7 @@ static void nfsd4_requeue_cb(struct rpc_task *task, struct nfsd4_callback *cb)
10711071
if (!test_bit(NFSD4_CLIENT_CB_KILL, &clp->cl_flags)) {
10721072
trace_nfsd_cb_restart(clp, cb);
10731073
task->tk_status = 0;
1074-
cb->cb_need_restart = true;
1074+
set_bit(NFSD4_CALLBACK_REQUEUE, &cb->cb_flags);
10751075
}
10761076
}
10771077

@@ -1479,7 +1479,7 @@ static void nfsd4_cb_release(void *calldata)
14791479

14801480
trace_nfsd_cb_rpc_release(cb->cb_clp);
14811481

1482-
if (cb->cb_need_restart)
1482+
if (test_bit(NFSD4_CALLBACK_REQUEUE, &cb->cb_flags))
14831483
nfsd4_queue_cb(cb);
14841484
else
14851485
nfsd41_destroy_cb(cb);
@@ -1618,12 +1618,11 @@ nfsd4_run_cb_work(struct work_struct *work)
16181618
return;
16191619
}
16201620

1621-
if (cb->cb_need_restart) {
1622-
cb->cb_need_restart = false;
1623-
} else {
1621+
if (!test_and_clear_bit(NFSD4_CALLBACK_REQUEUE, &cb->cb_flags)) {
16241622
if (cb->cb_ops && cb->cb_ops->prepare)
16251623
cb->cb_ops->prepare(cb);
16261624
}
1625+
16271626
cb->cb_msg.rpc_cred = clp->cl_cb_cred;
16281627
flags = clp->cl_minorversion ? RPC_TASK_NOCONNECT : RPC_TASK_SOFTCONN;
16291628
rpc_call_async(clnt, &cb->cb_msg, RPC_TASK_SOFT | flags,
@@ -1641,7 +1640,6 @@ void nfsd4_init_cb(struct nfsd4_callback *cb, struct nfs4_client *clp,
16411640
cb->cb_ops = ops;
16421641
INIT_WORK(&cb->cb_work, nfsd4_run_cb_work);
16431642
cb->cb_status = 0;
1644-
cb->cb_need_restart = false;
16451643
cb->cb_held_slot = -1;
16461644
}
16471645

fs/nfsd/state.h

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -69,13 +69,13 @@ struct nfsd4_callback {
6969
struct rpc_message cb_msg;
7070
#define NFSD4_CALLBACK_RUNNING (0)
7171
#define NFSD4_CALLBACK_WAKE (1)
72+
#define NFSD4_CALLBACK_REQUEUE (2)
7273
unsigned long cb_flags;
7374
const struct nfsd4_callback_ops *cb_ops;
7475
struct work_struct cb_work;
7576
int cb_seq_status;
7677
int cb_status;
7778
int cb_held_slot;
78-
bool cb_need_restart;
7979
};
8080

8181
struct nfsd4_callback_ops {

fs/nfsd/trace.h

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1616,7 +1616,7 @@ DECLARE_EVENT_CLASS(nfsd_cb_lifetime_class,
16161616
__entry->cl_id = clp->cl_clientid.cl_id;
16171617
__entry->cb = cb;
16181618
__entry->opcode = cb->cb_ops ? cb->cb_ops->opcode : _CB_NULL;
1619-
__entry->need_restart = cb->cb_need_restart;
1619+
__entry->need_restart = test_bit(NFSD4_CALLBACK_REQUEUE, &cb->cb_flags);
16201620
__assign_sockaddr(addr, &clp->cl_cb_conn.cb_addr,
16211621
clp->cl_cb_conn.cb_addrlen)
16221622
),

0 commit comments

Comments
 (0)