diff options
author | Bart Van Assche <bart.vanassche@wdc.com> | 2018-01-16 16:14:11 -0800 |
---|---|---|
committer | Doug Ledford <dledford@redhat.com> | 2018-01-18 14:49:25 -0500 |
commit | 940874f8beae5b954350317920170e84ce5dcbee (patch) | |
tree | 08cfbbeb97770c46ffe069c745f5309d1d1d1cac /drivers | |
parent | a11253142e6d317c25215ddb3029f9c754baefef (diff) | |
download | talos-obmc-linux-940874f8beae5b954350317920170e84ce5dcbee.tar.gz talos-obmc-linux-940874f8beae5b954350317920170e84ce5dcbee.zip |
IB/srpt: Simplify srpt_close_session()
Move a mutex lock and unlock statement from srpt_close_session()
into srpt_disconnect_ch_sync(). Since the previous patch removed
the last user of the return value of that function, change the
return value of srpt_disconnect_ch_sync() into void.
Signed-off-by: Bart Van Assche <bart.vanassche@wdc.com>
Signed-off-by: Doug Ledford <dledford@redhat.com>
Diffstat (limited to 'drivers')
-rw-r--r-- | drivers/infiniband/ulp/srpt/ib_srpt.c | 19 |
1 files changed, 4 insertions, 15 deletions
diff --git a/drivers/infiniband/ulp/srpt/ib_srpt.c b/drivers/infiniband/ulp/srpt/ib_srpt.c index de3e77df146e..b248515a4fe4 100644 --- a/drivers/infiniband/ulp/srpt/ib_srpt.c +++ b/drivers/infiniband/ulp/srpt/ib_srpt.c @@ -1868,22 +1868,16 @@ done: return res; } -/* - * Send DREQ and wait for DREP. Return true if and only if this function - * changed the state of @ch. - */ -static bool srpt_disconnect_ch_sync(struct srpt_rdma_ch *ch) - __must_hold(&sdev->mutex) +/* Send DREQ and wait for DREP. */ +static void srpt_disconnect_ch_sync(struct srpt_rdma_ch *ch) { struct srpt_port *sport = ch->sport; - int ret; - - lockdep_assert_held(&sport->mutex); pr_debug("ch %s-%d state %d\n", ch->sess_name, ch->qp->qp_num, ch->state); - ret = srpt_disconnect_ch(ch); + mutex_lock(&sport->mutex); + srpt_disconnect_ch(ch); mutex_unlock(&sport->mutex); while (wait_event_timeout(sport->ch_releaseQ, srpt_ch_closed(sport, ch), @@ -1891,8 +1885,6 @@ static bool srpt_disconnect_ch_sync(struct srpt_rdma_ch *ch) pr_info("%s(%s-%d state %d): still waiting ...\n", __func__, ch->sess_name, ch->qp->qp_num, ch->state); - mutex_lock(&sport->mutex); - return ret == 0; } static void __srpt_close_all_ch(struct srpt_port *sport) @@ -2991,11 +2983,8 @@ static void srpt_release_cmd(struct se_cmd *se_cmd) static void srpt_close_session(struct se_session *se_sess) { struct srpt_rdma_ch *ch = se_sess->fabric_sess_ptr; - struct srpt_port *sport = ch->sport; - mutex_lock(&sport->mutex); srpt_disconnect_ch_sync(ch); - mutex_unlock(&sport->mutex); } /** |