mirrors/scst
1
0
Fork 0
mirror of https://github.com/SCST-project/scst.git synced 2026-05-21 20:51:27 +00:00
Code Issues Packages Projects Releases Wiki Activity

Follow-up for r3866

Browse Source 
git-svn-id: http://svn.code.sf.net/p/scst/svn/trunk@3867 d57e44dd-8a1f-0410-8b47-8ef2f437770f
This commit is contained in:
Bart Van Assche
2011-09-18 08:01:29 +00:00
parent 8afd4e9d4e
commit 407f5b0c64
1 changed files with 7 additions and 6 deletions
Download Patch File Download Diff File Expand all files Collapse all files

13
srpt/src/ib_srpt.c
View File

@@ -2006,17 +2006,18 @@ static int srpt_compl_thread(void *arg)
ret = wait_event_timeout(ch->state_wq, ch->state >= CH_DRAINING,
RDMA_COMPL_TIMEOUT_S * HZ);
WARN_ON(ret < 0);
if (!ret) {
PRINT_ERROR("%s: DREP message has not been received in time.",
ch->sess_name);
srpt_drain_channel(ch->cm_id);
}
ret = wait_event_timeout(ch->state_wq, ch->state == CH_RELEASING,
RDMA_COMPL_TIMEOUT_S * HZ);
WARN_ON(ret < 0);
if (!ret) {
PRINT_ERROR("%s: %s has not been received in time.",
ch->sess_name,
ch->state == CH_DISCONNECTING ? "DREP message" :
ch->state == CH_DRAINING ? "Last WQE event" :
"(?)");
srpt_drain_channel(ch->cm_id);
PRINT_ERROR("%s: Last WQE event has not been received in time.",
ch->sess_name);
srpt_test_and_set_ch_state(ch, CH_DRAINING, CH_RELEASING);
}