From 81a2d1f550bfc91aceb4d0d5e7a7709d76548e7e Mon Sep 17 00:00:00 2001
From: chenbc <chenbc7@gmail.com>
Date: Fri, 15 May 2020 19:18:47 +0800
Subject: [PATCH] util/conn: close old connection before reconnect (#982)

---
 util/conn/manager.go | 1 +
 1 file changed, 1 insertion(+)

diff --git a/util/conn/manager.go b/util/conn/manager.go
index 725cbbc7a..b1e16c8fe 100644
--- a/util/conn/manager.go
+++ b/util/conn/manager.go
@@ -117,6 +117,7 @@ func (m *Manager) loop() {
 		case err := <-m.putc:
 			if err != nil && conn != nil {
 				m.logger.Log("err", err)
+				conn.Close()
 				conn = nil                            // connection is bad
 				reconnectc = m.after(time.Nanosecond) // trigger immediately
 			}