|
@@ -2176,7 +2176,7 @@ static struct curl_ent *pop_curl_entry(struct pool *pool)
|
|
|
if (!pool->curls)
|
|
if (!pool->curls)
|
|
|
recruit_curl(pool);
|
|
recruit_curl(pool);
|
|
|
else if (list_empty(&pool->curlring)) {
|
|
else if (list_empty(&pool->curlring)) {
|
|
|
- if (pool->curls >= curl_limit)
|
|
|
|
|
|
|
+ if (pool->submit_fail || pool->curls >= curl_limit)
|
|
|
pthread_cond_wait(&pool->cr_cond, &pool->pool_lock);
|
|
pthread_cond_wait(&pool->cr_cond, &pool->pool_lock);
|
|
|
else
|
|
else
|
|
|
recruit_curl(pool);
|
|
recruit_curl(pool);
|