Merge pull request #271 from bboreham/258_rebuild_routes

Move call to Topology.RebuildRoutes

Closes #258
This commit is contained in:
rade committed 2014-12-12 14:34:52 +00:00
commit 8dfdeb3eff
2 files changed
+2 -1

No files matched your search

+1
View File
@@ -492,6 +492,7 @@ func (conn *LocalConnection) receiveTCP(decoder *gob.Decoder, usingPassword bool
if len(newUpdate) == 0 {
continue
}
conn.Router.Topology.RebuildRoutes()
conn.local.BroadcastTCP(Concat(ProtocolUpdateByte, newUpdate))
} else if msg[0] == ProtocolPMTUVerified {
conn.verifyPMTU <- int(binary.BigEndian.Uint16(msg[1:]))
+1 -1
View File
@@ -389,13 +389,13 @@ func (peer *Peer) handleConnectionEstablished(conn *LocalConnection) {
}
func (peer *Peer) handleBroadcastTCP(msg []byte) {
peer.Router.Topology.RebuildRoutes()
peer.ForEachConnection(func(_ PeerName, conn Connection) {
conn.(*LocalConnection).SendTCP(msg)
})
}
func (peer *Peer) broadcastPeerUpdate(peers ...*Peer) {
peer.Router.Topology.RebuildRoutes()
peer.handleBroadcastTCP(Concat(ProtocolUpdateByte, EncodePeers(append(peers, peer)...)))
}