diff --git a/cgminer.c b/cgminer.c index 0381b04c..67691eb4 100644 --- a/cgminer.c +++ b/cgminer.c @@ -3501,9 +3501,8 @@ static bool queue_request(struct thr_info *thr, bool needed) int rs = requests_staged(), rq = requests_queued(); struct workio_cmd *wc; - if ((rq >= mining_threads || (rq >= opt_queue && rs >= mining_threads)) && - total_queued >= opt_queue) - return true; + if (rq >= mining_threads || (rq >= opt_queue && rs >= mining_threads)) + return true; /* fill out work request message */ wc = calloc(1, sizeof(*wc)); @@ -4336,7 +4335,7 @@ static void *watchdog_thread(void __maybe_unused *userdata) struct timeval now; sleep(interval); - if (requests_queued() < opt_queue || total_queued < opt_queue) + if (requests_queued() < opt_queue) queue_request(NULL, false); age_work();