Merge pull request shell909090#13 from pingliu/fix_reload_bug

fix reload bug
wang1219 · May 9, 2017 · 63fd6df · 63fd6df
2 parents 7fbe1f8 + 91508b7
commit 63fd6df
Show file tree

Hide file tree

Showing 3 changed files with 8 additions and 0 deletions.
diff --git a/backend/backends.go b/backend/backends.go
@@ -62,6 +62,7 @@ func (bs *Backends) worker() {
 				// closed
 				bs.Flush()
 				bs.HttpBackend.Close()
+				bs.fb.Close()
 				return
 			}
 			bs.WriteBuffer(p)

diff --git a/backend/file.go b/backend/file.go
@@ -216,3 +216,9 @@ func (fb *FileBackend) RollbackMeta() (err error) {
 	}
 	return
 }
+
+func (fb *FileBackend) Close() {
+	fb.producer.Close()
+	fb.consumer.Close()
+	fb.meta.Close()
+}
diff --git a/backend/http.go b/backend/http.go
@@ -221,5 +221,6 @@ func (hb *HttpBackend) WriteStream(stream io.Reader, compressed bool) (err error
 
 func (hb *HttpBackend) Close() (err error) {
 	hb.running = false
+	hb.transport.CloseIdleConnections()
 	return
 }