mirror
/
redis
mirror of https://github.com/go-redis/redis.git
1
0
Fork 1
Code Issues Packages Projects Releases Wiki Activity

newConn race fix

This commit is contained in:
Nikolay Vorobev 2023-11-01 16:55:42 +03:00
parent 5aa430d974
commit d8227214bc
1 changed files with 12 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

18
internal/pool/pool.go
View File

@ -164,6 +164,18 @@ func (p *ConnPool) NewConn(ctx context.Context) (*Conn, error) {
} }
func (p *ConnPool) newConn(ctx context.Context, pooled bool) (*Conn, error) { func (p *ConnPool) newConn(ctx context.Context, pooled bool) (*Conn, error) {
var poolExhausted bool
p.connsMu.Lock()
if p.cfg.MaxActiveConns > 0 {
poolExhausted = p.poolSize >= p.cfg.MaxActiveConns
}
p.connsMu.Unlock()
if poolExhausted {
return nil, ErrPoolExhausted
}
cn, err := p.dialConn(ctx, pooled) cn, err := p.dialConn(ctx, pooled)
if err != nil { if err != nil {
return nil, err return nil, err
@ -178,12 +190,6 @@ func (p *ConnPool) newConn(ctx context.Context, pooled bool) (*Conn, error) {
return nil, ErrClosed return nil, ErrClosed
} }
// It is not allowed to add new connections to the connection pool.
if p.cfg.MaxActiveConns > 0 && p.poolSize >= p.cfg.MaxActiveConns {
_ = cn.Close()
return nil, ErrPoolExhausted
}
p.conns = append(p.conns, cn) p.conns = append(p.conns, cn)
if pooled { if pooled {
// If pool is full remove the cn on next Put. // If pool is full remove the cn on next Put.