Browse Source

Make sure to decrease queued count if we discard the work.

nfactor-troky
Con Kolivas 14 years ago
parent
commit
720032dacd
  1. 2
      main.c

2
main.c

@ -2378,6 +2378,7 @@ retry:
goto retry; goto retry;
} }
dec_queued();
if (stale_work(work_heap)) { if (stale_work(work_heap)) {
discard_work(work_heap); discard_work(work_heap);
goto retry; goto retry;
@ -2387,7 +2388,6 @@ retry:
/* If we make it here we have succeeded in getting fresh work */ /* If we make it here we have succeeded in getting fresh work */
if (pool_tclear(pool, &pool->idle)) if (pool_tclear(pool, &pool->idle))
pool_resus(pool); pool_resus(pool);
dec_queued();
memcpy(work, work_heap, sizeof(*work)); memcpy(work, work_heap, sizeof(*work));

Loading…
Cancel
Save