Skip to content
Snippets Groups Projects
Commit a5df7374 authored by AlexStocks's avatar AlexStocks
Browse files

Fix: closeErr == nil

parent 4f862952
No related branches found
No related tags found
No related merge requests found
......@@ -300,7 +300,7 @@ func (p *gettyRPCClientPool) getGettyRpcClient(protocol, addr string) (*gettyRPC
p.conns = p.conns[:len(p.conns)-1]
if d := now - conn.getActive(); d > p.ttl {
if closeErr := conn.safeClose(); closeErr != nil {
if closeErr := conn.safeClose(); closeErr == nil {
p.remove(conn)
}
continue
......@@ -331,7 +331,7 @@ func (p *gettyRPCClientPool) release(conn *gettyRPCClient, err error) {
}
if len(p.conns) >= p.size {
if closeErr := conn.safeClose(); closeErr != nil {
if closeErr := conn.safeClose(); closeErr == nil {
// delete @conn from client pool
p.remove(conn)
}
......
0% or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment