|
|
@ -6304,12 +6304,9 @@ static struct pool *select_longpoll_pool(struct pool *cp) |
|
|
|
*/ |
|
|
|
*/ |
|
|
|
static void wait_lpcurrent(struct pool *pool) |
|
|
|
static void wait_lpcurrent(struct pool *pool) |
|
|
|
{ |
|
|
|
{ |
|
|
|
if (cnx_needed(pool)) |
|
|
|
while (!cnx_needed(pool) && (pool->enabled == POOL_DISABLED || |
|
|
|
return; |
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
while (pool->enabled == POOL_DISABLED || |
|
|
|
|
|
|
|
(pool != current_pool() && pool_strategy != POOL_LOADBALANCE && |
|
|
|
(pool != current_pool() && pool_strategy != POOL_LOADBALANCE && |
|
|
|
pool_strategy != POOL_BALANCE)) { |
|
|
|
pool_strategy != POOL_BALANCE))) { |
|
|
|
mutex_lock(&lp_lock); |
|
|
|
mutex_lock(&lp_lock); |
|
|
|
pthread_cond_wait(&lp_cond, &lp_lock); |
|
|
|
pthread_cond_wait(&lp_cond, &lp_lock); |
|
|
|
mutex_unlock(&lp_lock); |
|
|
|
mutex_unlock(&lp_lock); |
|
|
|