fix check pool exhausted

nvorobev · nvorobev · commit 76ee74e94456 · 2023-11-17T01:39:31.000+03:00
diff --git a/internal/pool/pool.go b/internal/pool/pool.go
@@ -165,7 +165,7 @@ func (p *ConnPool) NewConn(ctx context.Context) (*Conn, error) {
 
 func (p *ConnPool) newConn(ctx context.Context, pooled bool) (*Conn, error) {
 	p.connsMu.Lock()
-	if p.cfg.PoolSizeStrict && len(p.conns) >= p.poolSize {
+	if p.cfg.PoolSizeStrict && len(p.conns) >= p.cfg.PoolSize {
 		p.connsMu.Unlock()
 		return nil, ErrPoolExhausted
 	}

Original file line number	Diff line number	Diff line change
`@@ -165,7 +165,7 @@ func (p ConnPool) NewConn(ctx context.Context) (Conn, error) {`
`165`	`165`
`166`	`166`	`func (p ConnPool) newConn(ctx context.Context, pooled bool) (Conn, error) {`
`167`	`167`	`p.connsMu.Lock()`
`168`		`- if p.cfg.PoolSizeStrict && len(p.conns) >= p.poolSize {`
	`168`	`+ if p.cfg.PoolSizeStrict && len(p.conns) >= p.cfg.PoolSize {`
`169`	`169`	`p.connsMu.Unlock()`
`170`	`170`	`return nil, ErrPoolExhausted`
`171`	`171`	`}`