We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 0bc34b8 commit 5a5d911Copy full SHA for 5a5d911
internal/pool/pool.go
@@ -164,17 +164,12 @@ func (p *ConnPool) NewConn(ctx context.Context) (*Conn, error) {
164
}
165
166
func (p *ConnPool) newConn(ctx context.Context, pooled bool) (*Conn, error) {
167
- var poolExhausted bool
168
-
169
p.connsMu.Lock()
170
- if p.cfg.PoolSizeStrict {
171
- poolExhausted = len(p.conns) >= p.poolSize
172
- }
173
- p.connsMu.Unlock()
174
175
- if poolExhausted {
+ if p.cfg.PoolSizeStrict && len(p.conns) >= p.poolSize {
+ p.connsMu.Unlock()
176
return nil, ErrPoolExhausted
177
178
179
cn, err := p.dialConn(ctx, pooled)
180
if err != nil {
0 commit comments