remove peers from the peer store when they disconnect

libp2p · Nov 26, 2021 · 03203a8 · 03203a8
1 parent 3a71a6d
commit 03203a8
Show file tree

Hide file tree

Showing 10 changed files with 56 additions and 24 deletions.
diff --git a/examples/go.mod b/examples/go.mod
@@ -9,7 +9,7 @@ require (
  github.com/ipfs/go-log/v2 v2.3.0
  github.com/libp2p/go-libp2p v0.14.4
  github.com/libp2p/go-libp2p-connmgr v0.2.4
- github.com/libp2p/go-libp2p-core v0.11.0
+ github.com/libp2p/go-libp2p-core v0.11.1-0.20211024101752-b18a4c9c5629
  github.com/libp2p/go-libp2p-discovery v0.6.0
  github.com/libp2p/go-libp2p-kad-dht v0.15.0
  github.com/libp2p/go-libp2p-noise v0.3.0

diff --git a/examples/go.sum b/examples/go.sum
@@ -461,8 +461,9 @@ github.com/libp2p/go-libp2p-core v0.8.2/go.mod h1:FfewUH/YpvWbEB+ZY9AQRQ4TAD8sJB
 github.com/libp2p/go-libp2p-core v0.8.6/go.mod h1:dgHr0l0hIKfWpGpqAMbpo19pen9wJfdCGv51mTmdpmM=
 github.com/libp2p/go-libp2p-core v0.9.0/go.mod h1:ESsbz31oC3C1AvMJoGx26RTuCkNhmkSRCqZ0kQtJ2/8=
 github.com/libp2p/go-libp2p-core v0.10.0/go.mod h1:ECdxehoYosLYHgDDFa2N4yE8Y7aQRAMf0sX9mf2sbGg=
-github.com/libp2p/go-libp2p-core v0.11.0 h1:75jAgdA+IChNa+/mZXogfmrGkgwxkVvxmIC7pV+F6sI=
 github.com/libp2p/go-libp2p-core v0.11.0/go.mod h1:ECdxehoYosLYHgDDFa2N4yE8Y7aQRAMf0sX9mf2sbGg=
+github.com/libp2p/go-libp2p-core v0.11.1-0.20211024101752-b18a4c9c5629 h1:Gxw2x2hSzZlveZyLMMuOS04Irmu9QVkPaoEBT6KzFHA=
+github.com/libp2p/go-libp2p-core v0.11.1-0.20211024101752-b18a4c9c5629/go.mod h1:ECdxehoYosLYHgDDFa2N4yE8Y7aQRAMf0sX9mf2sbGg=
 github.com/libp2p/go-libp2p-discovery v0.6.0 h1:1XdPmhMJr8Tmj/yUfkJMIi8mgwWrLUsCB3bMxdT+DSo=
 github.com/libp2p/go-libp2p-discovery v0.6.0/go.mod h1:/u1voHt0tKIe5oIA1RHBKQLVCWPna2dXmPNHc2zR9S8=
 github.com/libp2p/go-libp2p-kad-dht v0.15.0 h1:Ke+Oj78gX5UDXnA6HBdrgvi+fStJxgYTDa51U0TsCLo=
@@ -484,8 +485,9 @@ github.com/libp2p/go-libp2p-noise v0.3.0/go.mod h1:JNjHbociDJKHD64KTkzGnzqJ0FEV5
 github.com/libp2p/go-libp2p-peerstore v0.1.4/go.mod h1:+4BDbDiiKf4PzpANZDAT+knVdLxvqh7hXOujessqdzs=
 github.com/libp2p/go-libp2p-peerstore v0.2.6/go.mod h1:ss/TWTgHZTMpsU/oKVVPQCGuDHItOpf2W8RxAi50P2s=
 github.com/libp2p/go-libp2p-peerstore v0.2.8/go.mod h1:gGiPlXdz7mIHd2vfAsHzBNAMqSDkt2UBFwgcITgw1lA=
-github.com/libp2p/go-libp2p-peerstore v0.4.0 h1:DOhRJLnM9Dc9lIXi3rPDZBf789LXy1BrzwIs7Tj0cKA=
 github.com/libp2p/go-libp2p-peerstore v0.4.0/go.mod h1:rDJUFyzEWPpXpEwywkcTYYzDHlwza8riYMaUzaN6hX0=
+github.com/libp2p/go-libp2p-peerstore v0.4.1-0.20211126123923-2767c2ed5a96 h1:ChCixfVsgP+nteVEfRkzuSJhRvH7VPI4GAZCOvtQ+LE=
+github.com/libp2p/go-libp2p-peerstore v0.4.1-0.20211126123923-2767c2ed5a96/go.mod h1:csiAYXUQDv5+lSQsrrR/1TNV5B34pAYV0mMNlhLoHY8=
 github.com/libp2p/go-libp2p-pnet v0.2.0 h1:J6htxttBipJujEjz1y0a5+eYoiPcFHhSYHH6na5f0/k=
 github.com/libp2p/go-libp2p-pnet v0.2.0/go.mod h1:Qqvq6JH/oMZGwqs3N1Fqhv8NVhrdYcO0BW4wssv21LA=
 github.com/libp2p/go-libp2p-quic-transport v0.11.2/go.mod h1:wlanzKtIh6pHrq+0U3p3DY9PJfGqxMgPaGKaK5LifwQ=

diff --git a/examples/ipfs-camp-2019/go.mod b/examples/ipfs-camp-2019/go.mod
@@ -5,7 +5,7 @@ go 1.16
 require (
  github.com/gogo/protobuf v1.3.2
  github.com/libp2p/go-libp2p v0.14.4
- github.com/libp2p/go-libp2p-core v0.11.0
+ github.com/libp2p/go-libp2p-core v0.11.1-0.20211024101752-b18a4c9c5629
  github.com/libp2p/go-libp2p-discovery v0.6.0
  github.com/libp2p/go-libp2p-kad-dht v0.15.0
  github.com/libp2p/go-libp2p-mplex v0.4.1

diff --git a/examples/ipfs-camp-2019/go.sum b/examples/ipfs-camp-2019/go.sum
@@ -464,8 +464,9 @@ github.com/libp2p/go-libp2p-core v0.8.2/go.mod h1:FfewUH/YpvWbEB+ZY9AQRQ4TAD8sJB
 github.com/libp2p/go-libp2p-core v0.8.6/go.mod h1:dgHr0l0hIKfWpGpqAMbpo19pen9wJfdCGv51mTmdpmM=
 github.com/libp2p/go-libp2p-core v0.9.0/go.mod h1:ESsbz31oC3C1AvMJoGx26RTuCkNhmkSRCqZ0kQtJ2/8=
 github.com/libp2p/go-libp2p-core v0.10.0/go.mod h1:ECdxehoYosLYHgDDFa2N4yE8Y7aQRAMf0sX9mf2sbGg=
-github.com/libp2p/go-libp2p-core v0.11.0 h1:75jAgdA+IChNa+/mZXogfmrGkgwxkVvxmIC7pV+F6sI=
 github.com/libp2p/go-libp2p-core v0.11.0/go.mod h1:ECdxehoYosLYHgDDFa2N4yE8Y7aQRAMf0sX9mf2sbGg=
+github.com/libp2p/go-libp2p-core v0.11.1-0.20211024101752-b18a4c9c5629 h1:Gxw2x2hSzZlveZyLMMuOS04Irmu9QVkPaoEBT6KzFHA=
+github.com/libp2p/go-libp2p-core v0.11.1-0.20211024101752-b18a4c9c5629/go.mod h1:ECdxehoYosLYHgDDFa2N4yE8Y7aQRAMf0sX9mf2sbGg=
 github.com/libp2p/go-libp2p-discovery v0.5.1/go.mod h1:+srtPIU9gDaBNu//UHvcdliKBIcr4SfDcm0/PfPJLug=
 github.com/libp2p/go-libp2p-discovery v0.6.0 h1:1XdPmhMJr8Tmj/yUfkJMIi8mgwWrLUsCB3bMxdT+DSo=
 github.com/libp2p/go-libp2p-discovery v0.6.0/go.mod h1:/u1voHt0tKIe5oIA1RHBKQLVCWPna2dXmPNHc2zR9S8=
@@ -488,8 +489,9 @@ github.com/libp2p/go-libp2p-noise v0.3.0/go.mod h1:JNjHbociDJKHD64KTkzGnzqJ0FEV5
 github.com/libp2p/go-libp2p-peerstore v0.1.4/go.mod h1:+4BDbDiiKf4PzpANZDAT+knVdLxvqh7hXOujessqdzs=
 github.com/libp2p/go-libp2p-peerstore v0.2.6/go.mod h1:ss/TWTgHZTMpsU/oKVVPQCGuDHItOpf2W8RxAi50P2s=
 github.com/libp2p/go-libp2p-peerstore v0.2.8/go.mod h1:gGiPlXdz7mIHd2vfAsHzBNAMqSDkt2UBFwgcITgw1lA=
-github.com/libp2p/go-libp2p-peerstore v0.4.0 h1:DOhRJLnM9Dc9lIXi3rPDZBf789LXy1BrzwIs7Tj0cKA=
 github.com/libp2p/go-libp2p-peerstore v0.4.0/go.mod h1:rDJUFyzEWPpXpEwywkcTYYzDHlwza8riYMaUzaN6hX0=
+github.com/libp2p/go-libp2p-peerstore v0.4.1-0.20211126123923-2767c2ed5a96 h1:ChCixfVsgP+nteVEfRkzuSJhRvH7VPI4GAZCOvtQ+LE=
+github.com/libp2p/go-libp2p-peerstore v0.4.1-0.20211126123923-2767c2ed5a96/go.mod h1:csiAYXUQDv5+lSQsrrR/1TNV5B34pAYV0mMNlhLoHY8=
 github.com/libp2p/go-libp2p-pnet v0.2.0 h1:J6htxttBipJujEjz1y0a5+eYoiPcFHhSYHH6na5f0/k=
 github.com/libp2p/go-libp2p-pnet v0.2.0/go.mod h1:Qqvq6JH/oMZGwqs3N1Fqhv8NVhrdYcO0BW4wssv21LA=
 github.com/libp2p/go-libp2p-pubsub v0.5.3 h1:XCn5xvgA/AKpbbaeqbomfKtQCbT9QsU39tYsVj0IndQ=

diff --git a/examples/pubsub/chat/go.mod b/examples/pubsub/chat/go.mod
@@ -5,7 +5,7 @@ go 1.16
 require (
  github.com/gdamore/tcell/v2 v2.1.0
  github.com/libp2p/go-libp2p v0.14.1
- github.com/libp2p/go-libp2p-core v0.11.0
+ github.com/libp2p/go-libp2p-core v0.11.1-0.20211024101752-b18a4c9c5629
  github.com/libp2p/go-libp2p-pubsub v0.6.0
  github.com/rivo/tview v0.0.0-20210125085121-dbc1f32bb1d0
 )

diff --git a/examples/pubsub/chat/go.sum b/examples/pubsub/chat/go.sum
@@ -437,8 +437,9 @@ github.com/libp2p/go-libp2p-core v0.8.2/go.mod h1:FfewUH/YpvWbEB+ZY9AQRQ4TAD8sJB
 github.com/libp2p/go-libp2p-core v0.8.6/go.mod h1:dgHr0l0hIKfWpGpqAMbpo19pen9wJfdCGv51mTmdpmM=
 github.com/libp2p/go-libp2p-core v0.9.0/go.mod h1:ESsbz31oC3C1AvMJoGx26RTuCkNhmkSRCqZ0kQtJ2/8=
 github.com/libp2p/go-libp2p-core v0.10.0/go.mod h1:ECdxehoYosLYHgDDFa2N4yE8Y7aQRAMf0sX9mf2sbGg=
-github.com/libp2p/go-libp2p-core v0.11.0 h1:75jAgdA+IChNa+/mZXogfmrGkgwxkVvxmIC7pV+F6sI=
 github.com/libp2p/go-libp2p-core v0.11.0/go.mod h1:ECdxehoYosLYHgDDFa2N4yE8Y7aQRAMf0sX9mf2sbGg=
+github.com/libp2p/go-libp2p-core v0.11.1-0.20211024101752-b18a4c9c5629 h1:Gxw2x2hSzZlveZyLMMuOS04Irmu9QVkPaoEBT6KzFHA=
+github.com/libp2p/go-libp2p-core v0.11.1-0.20211024101752-b18a4c9c5629/go.mod h1:ECdxehoYosLYHgDDFa2N4yE8Y7aQRAMf0sX9mf2sbGg=
 github.com/libp2p/go-libp2p-discovery v0.6.0 h1:1XdPmhMJr8Tmj/yUfkJMIi8mgwWrLUsCB3bMxdT+DSo=
 github.com/libp2p/go-libp2p-discovery v0.6.0/go.mod h1:/u1voHt0tKIe5oIA1RHBKQLVCWPna2dXmPNHc2zR9S8=
 github.com/libp2p/go-libp2p-loggables v0.1.0/go.mod h1:EyumB2Y6PrYjr55Q3/tiJ/o3xoDasoRYM7nOzEpoa90=
@@ -453,8 +454,9 @@ github.com/libp2p/go-libp2p-netutil v0.1.0/go.mod h1:3Qv/aDqtMLTUyQeundkKsA+YCTh
 github.com/libp2p/go-libp2p-noise v0.3.0 h1:NCVH7evhVt9njbTQshzT7N1S3Q6fjj9M11FCgfH5+cA=
 github.com/libp2p/go-libp2p-noise v0.3.0/go.mod h1:JNjHbociDJKHD64KTkzGnzqJ0FEV5gHJa6AB00kbCNQ=
 github.com/libp2p/go-libp2p-peerstore v0.2.6/go.mod h1:ss/TWTgHZTMpsU/oKVVPQCGuDHItOpf2W8RxAi50P2s=
-github.com/libp2p/go-libp2p-peerstore v0.4.0 h1:DOhRJLnM9Dc9lIXi3rPDZBf789LXy1BrzwIs7Tj0cKA=
 github.com/libp2p/go-libp2p-peerstore v0.4.0/go.mod h1:rDJUFyzEWPpXpEwywkcTYYzDHlwza8riYMaUzaN6hX0=
+github.com/libp2p/go-libp2p-peerstore v0.4.1-0.20211126123923-2767c2ed5a96 h1:ChCixfVsgP+nteVEfRkzuSJhRvH7VPI4GAZCOvtQ+LE=
+github.com/libp2p/go-libp2p-peerstore v0.4.1-0.20211126123923-2767c2ed5a96/go.mod h1:csiAYXUQDv5+lSQsrrR/1TNV5B34pAYV0mMNlhLoHY8=
 github.com/libp2p/go-libp2p-pnet v0.2.0 h1:J6htxttBipJujEjz1y0a5+eYoiPcFHhSYHH6na5f0/k=
 github.com/libp2p/go-libp2p-pnet v0.2.0/go.mod h1:Qqvq6JH/oMZGwqs3N1Fqhv8NVhrdYcO0BW4wssv21LA=
 github.com/libp2p/go-libp2p-pubsub v0.6.0 h1:98+RXuEWW17U6cAijK1yaTf6mw/B+n5yPA421z+dlo0=

diff --git a/go.mod b/go.mod
@@ -23,13 +23,13 @@ require (
  github.com/libp2p/go-libp2p-autonat v0.6.0
  github.com/libp2p/go-libp2p-blankhost v0.2.0
  github.com/libp2p/go-libp2p-circuit v0.4.0
- github.com/libp2p/go-libp2p-core v0.11.0
+ github.com/libp2p/go-libp2p-core v0.11.1-0.20211024101752-b18a4c9c5629
  github.com/libp2p/go-libp2p-discovery v0.6.0
  github.com/libp2p/go-libp2p-mplex v0.4.1
  github.com/libp2p/go-libp2p-nat v0.1.0
  github.com/libp2p/go-libp2p-netutil v0.1.0
  github.com/libp2p/go-libp2p-noise v0.3.0
- github.com/libp2p/go-libp2p-peerstore v0.4.0
+ github.com/libp2p/go-libp2p-peerstore v0.4.1-0.20211126123923-2767c2ed5a96
  github.com/libp2p/go-libp2p-quic-transport v0.15.0
  github.com/libp2p/go-libp2p-swarm v0.8.0
  github.com/libp2p/go-libp2p-testing v0.5.0

diff --git a/go.sum b/go.sum
@@ -428,8 +428,9 @@ github.com/libp2p/go-libp2p-core v0.8.2/go.mod h1:FfewUH/YpvWbEB+ZY9AQRQ4TAD8sJB
 github.com/libp2p/go-libp2p-core v0.8.6/go.mod h1:dgHr0l0hIKfWpGpqAMbpo19pen9wJfdCGv51mTmdpmM=
 github.com/libp2p/go-libp2p-core v0.9.0/go.mod h1:ESsbz31oC3C1AvMJoGx26RTuCkNhmkSRCqZ0kQtJ2/8=
 github.com/libp2p/go-libp2p-core v0.10.0/go.mod h1:ECdxehoYosLYHgDDFa2N4yE8Y7aQRAMf0sX9mf2sbGg=
-github.com/libp2p/go-libp2p-core v0.11.0 h1:75jAgdA+IChNa+/mZXogfmrGkgwxkVvxmIC7pV+F6sI=
 github.com/libp2p/go-libp2p-core v0.11.0/go.mod h1:ECdxehoYosLYHgDDFa2N4yE8Y7aQRAMf0sX9mf2sbGg=
+github.com/libp2p/go-libp2p-core v0.11.1-0.20211024101752-b18a4c9c5629 h1:Gxw2x2hSzZlveZyLMMuOS04Irmu9QVkPaoEBT6KzFHA=
+github.com/libp2p/go-libp2p-core v0.11.1-0.20211024101752-b18a4c9c5629/go.mod h1:ECdxehoYosLYHgDDFa2N4yE8Y7aQRAMf0sX9mf2sbGg=
 github.com/libp2p/go-libp2p-discovery v0.6.0 h1:1XdPmhMJr8Tmj/yUfkJMIi8mgwWrLUsCB3bMxdT+DSo=
 github.com/libp2p/go-libp2p-discovery v0.6.0/go.mod h1:/u1voHt0tKIe5oIA1RHBKQLVCWPna2dXmPNHc2zR9S8=
 github.com/libp2p/go-libp2p-loggables v0.1.0/go.mod h1:EyumB2Y6PrYjr55Q3/tiJ/o3xoDasoRYM7nOzEpoa90=
@@ -444,8 +445,9 @@ github.com/libp2p/go-libp2p-netutil v0.1.0/go.mod h1:3Qv/aDqtMLTUyQeundkKsA+YCTh
 github.com/libp2p/go-libp2p-noise v0.3.0 h1:NCVH7evhVt9njbTQshzT7N1S3Q6fjj9M11FCgfH5+cA=
 github.com/libp2p/go-libp2p-noise v0.3.0/go.mod h1:JNjHbociDJKHD64KTkzGnzqJ0FEV5gHJa6AB00kbCNQ=
 github.com/libp2p/go-libp2p-peerstore v0.2.6/go.mod h1:ss/TWTgHZTMpsU/oKVVPQCGuDHItOpf2W8RxAi50P2s=
-github.com/libp2p/go-libp2p-peerstore v0.4.0 h1:DOhRJLnM9Dc9lIXi3rPDZBf789LXy1BrzwIs7Tj0cKA=
 github.com/libp2p/go-libp2p-peerstore v0.4.0/go.mod h1:rDJUFyzEWPpXpEwywkcTYYzDHlwza8riYMaUzaN6hX0=
+github.com/libp2p/go-libp2p-peerstore v0.4.1-0.20211126123923-2767c2ed5a96 h1:ChCixfVsgP+nteVEfRkzuSJhRvH7VPI4GAZCOvtQ+LE=
+github.com/libp2p/go-libp2p-peerstore v0.4.1-0.20211126123923-2767c2ed5a96/go.mod h1:csiAYXUQDv5+lSQsrrR/1TNV5B34pAYV0mMNlhLoHY8=
 github.com/libp2p/go-libp2p-pnet v0.2.0 h1:J6htxttBipJujEjz1y0a5+eYoiPcFHhSYHH6na5f0/k=
 github.com/libp2p/go-libp2p-pnet v0.2.0/go.mod h1:Qqvq6JH/oMZGwqs3N1Fqhv8NVhrdYcO0BW4wssv21LA=
 github.com/libp2p/go-libp2p-quic-transport v0.13.0/go.mod h1:39/ZWJ1TW/jx1iFkKzzUg00W6tDJh73FC0xYudjr7Hc=

diff --git a/p2p/host/basic/basic_host.go b/p2p/host/basic/basic_host.go
@@ -89,8 +89,9 @@ type BasicHost struct {
  negtimeout time.Duration
 
  emitters struct {
- evtLocalProtocolsUpdated event.Emitter
- evtLocalAddrsUpdated event.Emitter
+ evtLocalProtocolsUpdated event.Emitter
+ evtLocalAddrsUpdated event.Emitter
+ evtPeerConnectednessChanged event.Emitter
  }
 
  addrChangeChan chan struct{}
@@ -183,11 +184,10 @@ func NewHost(n network.Network, opts *HostOpts) (*BasicHost, error) {
  if h.emitters.evtLocalAddrsUpdated, err = h.eventbus.Emitter(&event.EvtLocalAddressesUpdated{}, eventbus.Stateful); err != nil {
  return nil, err
  }
- evtPeerConnectednessChanged, err := h.eventbus.Emitter(&event.EvtPeerConnectednessChanged{})
- if err != nil {
+ if h.emitters.evtPeerConnectednessChanged, err = h.eventbus.Emitter(&event.EvtPeerConnectednessChanged{}); err != nil {
  return nil, err
  }
- h.Network().Notify(newPeerConnectWatcher(evtPeerConnectednessChanged))
+ h.Network().Notify(newPeerConnectWatcher(h.emitters.evtPeerConnectednessChanged))
 
  if !h.disableSignedPeerRecord {
  cab, ok := peerstore.GetCertifiedAddrBook(n.Peerstore())
@@ -350,10 +350,11 @@ func (h *BasicHost) updateLocalIpAddr() {
  }
 }
 
-// Start starts background tasks in the host
+// Start starts watchForAddrChanges tasks in the host
 func (h *BasicHost) Start() {
- h.refCount.Add(1)
- go h.background()
+ h.refCount.Add(2)
+ go h.watchForAddrChanges()
+ go h.gcPeerstore()
 }
 
 // newStreamHandler is the remote-opened stream handler for network.Network
@@ -459,7 +460,7 @@ func (h *BasicHost) makeSignedPeerRecord(evt *event.EvtLocalAddressesUpdated) (*
  return record.Seal(rec, h.signKey)
 }
 
-func (h *BasicHost) background() {
+func (h *BasicHost) watchForAddrChanges() {
  defer h.refCount.Done()
  var lastAddrs []ma.Multiaddr
 
@@ -521,6 +522,28 @@ func (h *BasicHost) background() {
  }
 }
 
+func (h *BasicHost) gcPeerstore() {
+ defer h.refCount.Done()
+ sub, err := h.EventBus().Subscribe(&event.EvtPeerConnectednessChanged{})
+ if err != nil {
+ log.Warnw("failed to listen for peer connectedness changed events", "error", err)
+ return
+ }
+ defer sub.Close()
+ for {
+ // Note that this might shut down before the swarm has closed all connections.
+ select {
+ case <-h.ctx.Done():
+ return
+ case e := <-sub.Out():
+ ev := e.(event.EvtPeerConnectednessChanged)
+ if ev.Connectedness == network.NotConnected {
+ h.Peerstore().RemovePeer(ev.Peer)
+ }
+ }
+ }
+}
+
 // ID returns the (local) peer.ID associated with this Host
 func (h *BasicHost) ID() peer.ID {
  return h.Network().LocalPeer()
@@ -627,7 +650,7 @@ func (h *BasicHost) NewStream(ctx context.Context, p peer.ID, pids ...protocol.I
  }, nil
  }
 
- // Negotiate the protocol in the background, obeying the context.
+ // Negotiate the protocol in the watchForAddrChanges, obeying the context.
  var selected string
  errCh := make(chan error, 1)
  go func() {
@@ -1035,6 +1058,7 @@ func (h *BasicHost) Close() error {
  _ = h.emitters.evtLocalProtocolsUpdated.Close()
  _ = h.emitters.evtLocalAddrsUpdated.Close()
  h.Network().Close()
+ _ = h.emitters.evtPeerConnectednessChanged.Close()
 
  if h.Peerstore() != nil {
  h.Peerstore().Close()

diff --git a/p2p/host/basic/basic_host_test.go b/p2p/host/basic/basic_host_test.go
@@ -723,7 +723,7 @@ func TestHostAddrChangeDetection(t *testing.T) {
  require.NoError(t, err)
  defer sub.Close()
 
- // wait for the host background thread to start
+ // wait for the host watchForAddrChanges thread to start
  time.Sleep(1 * time.Second)
  // host should start with no addrs (addrSet 0)
  addrs := h.Addrs()