diff --git a/srpt/src/ib_srpt.c b/srpt/src/ib_srpt.c
index 9b78a1f9f..4b378a580 100644
--- a/srpt/src/ib_srpt.c
+++ b/srpt/src/ib_srpt.c
@@ -2612,6 +2612,7 @@ reject:
 		       sizeof(*rej));
 
 	if (ch && ch->thread) {
+		srpt_drain_channel(cm_id);
 		srpt_close_ch(ch);
 		/*
 		 * Tell the caller not to free cm_id since