Skip to content

Commit 649f916

Browse files
Mark ourself as connected (#543)
1 parent 82b6c4e commit 649f916

File tree

1 file changed

+8
-5
lines changed

1 file changed

+8
-5
lines changed

peer/network.go

Lines changed: 8 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -505,12 +505,11 @@ func (n *network) Connected(ctx context.Context, nodeID ids.NodeID, nodeVersion
505505
return nil
506506
}
507507

508-
if nodeID == n.self {
509-
log.Debug("skipping registering self as peer")
510-
return nil
508+
if nodeID != n.self {
509+
// The legacy peer tracker doesn't expect to be connected to itself.
510+
n.peers.Connected(nodeID, nodeVersion)
511511
}
512512

513-
n.peers.Connected(nodeID, nodeVersion)
514513
return n.p2pNetwork.Connected(ctx, nodeID, nodeVersion)
515514
}
516515

@@ -524,7 +523,11 @@ func (n *network) Disconnected(ctx context.Context, nodeID ids.NodeID) error {
524523
return nil
525524
}
526525

527-
n.peers.Disconnected(nodeID)
526+
if nodeID != n.self {
527+
// The legacy peer tracker doesn't expect to be connected to itself.
528+
n.peers.Disconnected(nodeID)
529+
}
530+
528531
return n.p2pNetwork.Disconnected(ctx, nodeID)
529532
}
530533

0 commit comments

Comments
 (0)