i <3 race detector

lib/gat/pool/conn.go

@@ -92,7 +92,7 @@ func (T *Conn) SetState(state metrics.ConnState, peer uuid.UUID) {
 
 func (T *Conn) GetState() (state metrics.ConnState, peer uuid.UUID, since time.Time) {
 	T.mu.RLock()
-	defer T.mu.Unlock()
+	defer T.mu.RUnlock()
 	state = T.state
 	peer = T.peer
 	since = T.since

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

@@ -94,12 +94,10 @@ func (T *Pooler) Acquire(_ uuid.UUID, mode pool.SyncMode) uuid.UUID {
 	}
 }
 
-func (*Pooler) ReleaseAfterTransaction() bool {
-	// servers are released when the client is removed
-	return false
-}
-
 func (T *Pooler) Release(server uuid.UUID) {
+	T.mu.Lock()
+	defer T.mu.Unlock()
+
 	// check if server was removed
 	if _, ok := T.servers[server]; !ok {
 		return

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

@@ -39,10 +39,6 @@ func (T *Pooler) Acquire(client uuid.UUID, sync pool.SyncMode) uuid.UUID {
 	}
 }
 
-func (*Pooler) ReleaseAfterTransaction() bool {
-	return true
-}
-
 func (T *Pooler) Release(server uuid.UUID) {
 	T.s.Release(server)
 }

pgbouncer.ini

@@ -4,6 +4,7 @@ auth_file = userlist.txt
 listen_addr = *
 track_extra_parameters = IntervalStyle, session_authorization, default_transaction_read_only, search_path
 auth_user = postgres
+server_idle_timeout = 10
 
 [databases]
 * = host=/tmp/ datestyle=Postgres,MDY timezone=PST8PDT