diff --git a/libnetwork/networkdb/networkdb.go b/libnetwork/networkdb/networkdb.go index af38d81dc1..9a2195ea54 100644 --- a/libnetwork/networkdb/networkdb.go +++ b/libnetwork/networkdb/networkdb.go @@ -267,6 +267,9 @@ func (nDB *NetworkDB) Close() { if err := nDB.clusterLeave(); err != nil { logrus.Errorf("%v(%v) Could not close DB: %v", nDB.config.Hostname, nDB.config.NodeID, err) } + + //Avoid (*Broadcaster).run goroutine leak + nDB.broadcaster.Close() } // ClusterPeers returns all the gossip cluster peers.