Always include local peer in Peers

This commit is contained in:
David Wragg committed 2015-10-12 21:27:11 +01:00
1 parent 1d00bdd2a4
commit 97fb90c37a
3 files changed
+3 -3

No files matched your search

+3 -1
View File
@@ -32,7 +32,9 @@ type ConnectionSummary struct {
}
func NewPeers(ourself *LocalPeer) *Peers {
return &Peers{ourself: ourself, table: make(map[PeerName]*Peer)}
peers := &Peers{ourself: ourself, table: make(map[PeerName]*Peer)}
peers.FetchWithDefault(ourself.Peer)
return peers
}
func (peers *Peers) OnGC(callback func(*Peer)) {
-1
View File
@@ -20,7 +20,6 @@ import (
func newNode(name PeerName) (*Peer, *Peers) {
peer := NewLocalPeer(name, "", nil)
peers := NewPeers(peer)
peers.FetchWithDefault(peer.Peer)
return peer.Peer, peers
}
-1
View File
@@ -73,7 +73,6 @@ func NewRouter(config Config, name PeerName, nickName string) *Router {
router.Macs = NewMacCache(macMaxAge, onMacExpiry)
router.Peers = NewPeers(router.Ourself)
router.Peers.OnGC(onPeerGC)
router.Peers.FetchWithDefault(router.Ourself.Peer)
router.Routes = NewRoutes(router.Ourself, router.Peers, router.Overlay.InvalidateRoutes)
router.ConnectionMaker = NewConnectionMaker(router.Ourself, router.Peers, router.Port, router.PeerDiscovery)
router.TopologyGossip = router.NewGossip("topology", router)