|
@@ -2284,8 +2284,12 @@ next_submit:
|
|
|
kill_work();
|
|
kill_work();
|
|
|
break;
|
|
break;
|
|
|
}
|
|
}
|
|
|
- else if (unlikely(work->stale && opt_retries < 0)) {
|
|
|
|
|
- if (staleexpire <= time(NULL)) {
|
|
|
|
|
|
|
+ else if (work->stale) {
|
|
|
|
|
+ if (unlikely(!list_empty(&submit_waiting))) {
|
|
|
|
|
+ applog(LOG_WARNING, "Stale share failed to submit while queued submissions are waiting, discarding");
|
|
|
|
|
+ submit_discard_share(work);
|
|
|
|
|
+ break;
|
|
|
|
|
+ } else if (unlikely(opt_retries < 0 && staleexpire <= time(NULL))) {
|
|
|
applog(LOG_NOTICE, "Stale share failed to submit for 5 minutes, discarding");
|
|
applog(LOG_NOTICE, "Stale share failed to submit for 5 minutes, discarding");
|
|
|
submit_discard_share(work);
|
|
submit_discard_share(work);
|
|
|
break;
|
|
break;
|