|
@@ -22,13 +22,13 @@ func NewMRouter(cnode matrix.ClusterNode) Router {
|
|
|
mr := &mRouter{
|
|
|
cnode: cnode,
|
|
|
mtopo: mtopo}
|
|
|
- mtopo.OnTopoChange(func(connectedPeers map[matrix.PeerID]matrix.PeerIDs, update *mgossip.TopoInfo) {
|
|
|
- // peers := matrix.MPeerIDSet(cnode.Peers())
|
|
|
- // if !mpeers.Equal(peers) {
|
|
|
- // mpeers = peers
|
|
|
- // logger.Info(cnode.Name(), cnode.ID(), ":\n", mpeers.List())
|
|
|
- // }
|
|
|
- })
|
|
|
+ // mtopo.OnTopoChange(func(connectedPeers map[matrix.PeerID]matrix.PeerIDs, update *mgossip.TopoInfo) {
|
|
|
+ // peers := matrix.MPeerIDSet(cnode.Peers())
|
|
|
+ // if !mpeers.Equal(peers) {
|
|
|
+ // mpeers = peers
|
|
|
+ // logger.Info(cnode.Name(), cnode.ID(), ":\n", mpeers.List())
|
|
|
+ // }
|
|
|
+ // })
|
|
|
return mr
|
|
|
}
|
|
|
|