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