|
@@ -2398,8 +2398,8 @@ static void *get_work_thread(void *userdata)
|
|
|
pool = wc->pool;
|
|
pool = wc->pool;
|
|
|
|
|
|
|
|
if (clone_available()) {
|
|
if (clone_available()) {
|
|
|
- applog(LOG_DEBUG, "dec_queued from get_work_thread due to clone available");
|
|
|
|
|
dec_queued(pool);
|
|
dec_queued(pool);
|
|
|
|
|
+ applog(LOG_DEBUG, "dec_queued from get_work_thread due to clone available");
|
|
|
goto out;
|
|
goto out;
|
|
|
}
|
|
}
|
|
|
|
|
|
|
@@ -2915,8 +2915,8 @@ static bool hash_push(struct work *work)
|
|
|
|
|
|
|
|
if (work->queued) {
|
|
if (work->queued) {
|
|
|
work->queued = false;
|
|
work->queued = false;
|
|
|
- applog(LOG_DEBUG, "dec_queued in hash_push");
|
|
|
|
|
dec_queued(work->pool);
|
|
dec_queued(work->pool);
|
|
|
|
|
+ applog(LOG_DEBUG, "dec_queued from hash_push");
|
|
|
}
|
|
}
|
|
|
|
|
|
|
|
return rc;
|
|
return rc;
|