diff --git a/srpt/src/ib_srpt.c b/srpt/src/ib_srpt.c
index 69f9ceb5b..1168a8b96 100644
--- a/srpt/src/ib_srpt.c
+++ b/srpt/src/ib_srpt.c
@@ -2017,7 +2017,7 @@ static int srpt_compl_thread(void *arg)
 	barrier();
 	while (ch->state < CH_LIVE) {
 		srpt_process_completion(ch->cq, ch, SCST_CONTEXT_THREAD,
-					SCST_CONTEXT_DIRECT);
+					SCST_CONTEXT_THREAD);
 		schedule();
 		set_current_state(TASK_INTERRUPTIBLE);
 	}
@@ -2030,7 +2030,7 @@ static int srpt_compl_thread(void *arg)
 	barrier();
 	while (!ch->last_wqe_received) {
 		srpt_process_completion(ch->cq, ch, SCST_CONTEXT_THREAD,
-					SCST_CONTEXT_DIRECT);
+					SCST_CONTEXT_THREAD);
 		schedule();
 		set_current_state(TASK_INTERRUPTIBLE);
 	}
@@ -2043,7 +2043,7 @@ static int srpt_compl_thread(void *arg)
 	for (;;) {
 		set_current_state(TASK_INTERRUPTIBLE);
 		srpt_process_completion(ch->cq, ch, SCST_CONTEXT_THREAD,
-					SCST_CONTEXT_DIRECT);
+					SCST_CONTEXT_THREAD);
 		if (atomic_read(&ch->scst_sess->sess_cmd_count) == 0)
 			break;
 		schedule_timeout(HZ / 10);