diff --git a/lib/gat/pool/pool.go b/lib/gat/pool/pool.go index d1e56823cadeee968dbe8b5b214b3d7c3f74c33c..646a4511aa7e8c71804c09cf4892f2c2437eda8c 100644 --- a/lib/gat/pool/pool.go +++ b/lib/gat/pool/pool.go @@ -3,7 +3,6 @@ package pool import ( "errors" "sync" - "sync/atomic" "time" "github.com/google/uuid" @@ -25,8 +24,6 @@ type Pool struct { closed chan struct{} - scalingUp atomic.Bool - recipes map[string]*recipe.Recipe clients map[uuid.UUID]*Client clientsByKey map[[8]byte]*Client @@ -147,12 +144,6 @@ func (T *Pool) removeRecipe(name string) { } func (T *Pool) scaleUp() { - if T.scalingUp.Swap(true) { - // another person is trying to scale up this pool already - return - } - defer T.scalingUp.Store(false) - backoff := T.options.ServerReconnectInitialTime for {