From 55373958341b43fb8bbed58146a4f261e2372646 Mon Sep 17 00:00:00 2001
From: chikaku <chenbc7@gmail.com>
Date: Fri, 15 May 2020 18:15:38 +0800
Subject: [PATCH] util/conn: close old connection before reconnect

---
 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
 			}