|
@@ -1955,9 +1955,11 @@ static inline struct pool *select_pool(bool lagging)
|
|
|
if (pool_strategy == POOL_BALANCE)
|
|
if (pool_strategy == POOL_BALANCE)
|
|
|
return select_balanced(cp);
|
|
return select_balanced(cp);
|
|
|
|
|
|
|
|
- if (pool_strategy != POOL_LOADBALANCE && (!lagging || opt_fail_only))
|
|
|
|
|
- pool = cp;
|
|
|
|
|
- else
|
|
|
|
|
|
|
+ if (pool_strategy != POOL_LOADBALANCE && (!lagging || opt_fail_only)) {
|
|
|
|
|
+ if (cp->prio != 0)
|
|
|
|
|
+ switch_pools(NULL);
|
|
|
|
|
+ pool = current_pool();
|
|
|
|
|
+ } else
|
|
|
pool = NULL;
|
|
pool = NULL;
|
|
|
|
|
|
|
|
while (!pool) {
|
|
while (!pool) {
|