redis/go-redis
1
0
Fork 0
mirror of https://github.com/redis/go-redis.git synced 2025-07-28 06:42:00 +03:00
Code Activity

fix(auth): check err on close conn

Browse Source
This commit is contained in:
Nedyalko Dyakov
2025-05-14 11:50:45 +03:00
parent 52286114a3
commit 3345fd1234
1 changed files with 11 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

12
redis.go
View File

@ -312,7 +312,17 @@ func (c *baseClient) onAuthenticationErr(poolCn *pool.Conn) func(err error) {
return func(err error) { return func(err error) {
if err != nil { if err != nil {
if isBadConn(err, false, c.opt.Addr) { if isBadConn(err, false, c.opt.Addr) {
c.connPool.CloseConn(poolCn) // Close the connection to force a reconnection.
err := c.connPool.CloseConn(poolCn)
if err != nil {
internal.Logger.Printf(context.Background(), "redis: failed to close connection: %v", err)
// try to close the network connection directly
// so that no resource is leaked
err := poolCn.Close()
if err != nil {
internal.Logger.Printf(context.Background(), "redis: failed to close network connection: %v", err)
}
}
} }
internal.Logger.Printf(context.Background(), "redis: re-authentication failed: %v", err) internal.Logger.Printf(context.Background(), "redis: re-authentication failed: %v", err)
} }