|
@@ -1191,7 +1191,7 @@ static void inc_queued(void)
|
|
|
static void dec_queued(void)
|
|
static void dec_queued(void)
|
|
|
{
|
|
{
|
|
|
pthread_mutex_lock(&qd_lock);
|
|
pthread_mutex_lock(&qd_lock);
|
|
|
- if (total_queued > total_staged)
|
|
|
|
|
|
|
+ if (total_queued > 0)
|
|
|
total_queued--;
|
|
total_queued--;
|
|
|
pthread_mutex_unlock(&qd_lock);
|
|
pthread_mutex_unlock(&qd_lock);
|
|
|
dec_staged(1);
|
|
dec_staged(1);
|