瀏覽代碼

rafthttp: cleanup prober when stopping the transport

Xiang Li 10 年之前
父節點
當前提交
1e048b5c24
共有 1 個文件被更改,包括 1 次插入0 次删除
  1. 1 0
      rafthttp/transport.go

+ 1 - 0
rafthttp/transport.go

@@ -171,6 +171,7 @@ func (t *transport) Stop() {
 	for _, p := range t.peers {
 		p.Stop()
 	}
+	t.prober.RemoveAll()
 	if tr, ok := t.roundTripper.(*http.Transport); ok {
 		tr.CloseIdleConnections()
 	}