|
|
@@ -2915,6 +2915,9 @@ static bool queue_request(struct thr_info *thr, bool needed)
|
|
|
if (rq >= maxq || rs >= maxq)
|
|
|
return true;
|
|
|
|
|
|
+ if (rs > rq)
|
|
|
+ goto out;
|
|
|
+
|
|
|
/* fill out work request message */
|
|
|
wc = calloc(1, sizeof(*wc));
|
|
|
if (unlikely(!wc)) {
|
|
|
@@ -2943,6 +2946,7 @@ static bool queue_request(struct thr_info *thr, bool needed)
|
|
|
workio_cmd_free(wc);
|
|
|
return false;
|
|
|
}
|
|
|
+out:
|
|
|
inc_queued();
|
|
|
return true;
|
|
|
}
|