|
@@ -2929,6 +2929,7 @@ static bool hash_push(struct work *work)
|
|
|
}
|
|
}
|
|
|
|
|
|
|
|
mutex_lock(stgd_lock);
|
|
mutex_lock(stgd_lock);
|
|
|
|
|
+ work->pool->staged++;
|
|
|
if (work_rollable(work))
|
|
if (work_rollable(work))
|
|
|
staged_rollable++;
|
|
staged_rollable++;
|
|
|
if (likely(!getq->frozen)) {
|
|
if (likely(!getq->frozen)) {
|
|
@@ -2939,8 +2940,6 @@ static bool hash_push(struct work *work)
|
|
|
pthread_cond_signal(&getq->cond);
|
|
pthread_cond_signal(&getq->cond);
|
|
|
mutex_unlock(stgd_lock);
|
|
mutex_unlock(stgd_lock);
|
|
|
|
|
|
|
|
- work->pool->staged++;
|
|
|
|
|
-
|
|
|
|
|
if (dec)
|
|
if (dec)
|
|
|
dec_queued(work->pool);
|
|
dec_queued(work->pool);
|
|
|
|
|
|