revert

lib/gat/pool/pool.go

@@ -279,7 +279,21 @@ func (T *Pool) acquireServer(client *Client) *Server {
 		if serverID == uuid.Nil {
 			// TODO(garet) can this be run on same thread and only create a goroutine if scaling is possible?
 			go T.scaleUp()
+			done := make(chan struct{})
+			go func() {
+				start := time.Now()
+				for {
+					time.Sleep(1 * time.Second)
+					select {
+					case <-done:
+						return
+					default:
+					}
+					log.Printf("still waiting after %d in pool %p", start, T)
+				}
+			}()
 			serverID = T.options.Pooler.Acquire(client.GetID(), SyncModeBlocking)
+			close(done)
 		}
 
 		T.mu.RLock()

lib/gat/pool/pools/transaction/apply.go

@@ -3,7 +3,7 @@ package transaction
 import "pggat/lib/gat/pool"
 
 func Apply(options pool.Options) pool.Options {
-	options.Pooler = NewPooler()
+	options.Pooler = new(Pooler)
 	options.ParameterStatusSync = pool.ParameterStatusSyncDynamic
 	options.ExtendedQuerySync = true
 	options.ReleaseAfterTransaction = true

lib/gat/pool/pools/transaction/pooler.go

@@ -12,12 +12,6 @@ type Pooler struct {
 	s schedulers.Scheduler
 }
 
-func NewPooler() *Pooler {
-	p := new(Pooler)
-	schedulers.Test(&p.s)
-	return p
-}
-
 func (T *Pooler) NewClient() uuid.UUID {
 	return T.s.NewUser()
 }

lib/rob/schedulers/v2/scheduler.go

@@ -2,15 +2,12 @@ package schedulers
 
 import (
 	"github.com/google/uuid"
-	"sync"
-	"time"
-	"tuxpa.in/a/zlog/log"
-
 	"pggat/lib/rob"
 	"pggat/lib/rob/schedulers/v2/job"
 	"pggat/lib/rob/schedulers/v2/sink"
 	"pggat/lib/util/maps"
 	"pggat/lib/util/pools"
+	"sync"
 )
 
 type Scheduler struct {
@@ -26,22 +23,6 @@ type Scheduler struct {
 	mu      sync.RWMutex
 }
 
-func Test(s *Scheduler) {
-	go func() {
-		for {
-			time.Sleep(1 * time.Second)
-			func() {
-				s.mu.RLock()
-				defer s.mu.RUnlock()
-
-				s.bmu.Lock()
-				defer s.bmu.Unlock()
-				log.Printf("%d sinks | %d backlogged jobs", len(s.sinks), len(s.backlog))
-			}()
-		}
-	}()
-}
-
 func (T *Scheduler) NewWorker() uuid.UUID {
 	worker := uuid.New()