Skip to content

Commit

Permalink
pingPeers ==> pingPeersAndLogEnr.
Browse files Browse the repository at this point in the history
  • Loading branch information
nalepae committed Sep 3, 2024
1 parent 0b39d26 commit bd82d71
Show file tree
Hide file tree
Showing 2 changed files with 4 additions and 4 deletions.
6 changes: 3 additions & 3 deletions beacon-chain/p2p/discovery.go
Original file line number Diff line number Diff line change
Expand Up @@ -119,7 +119,7 @@ func (s *Service) RefreshPersistentSubnets() {
s.updateSubnetRecordWithMetadata(bitV)

// Ping all peers.
s.pingPeers()
s.pingPeersAndLogEnr()

return
}
Expand Down Expand Up @@ -157,7 +157,7 @@ func (s *Service) RefreshPersistentSubnets() {
s.updateSubnetRecordWithMetadataV2(bitV, bitS)

// Ping all peers to inform them of new metadata
s.pingPeers()
s.pingPeersAndLogEnr()

return
}
Expand Down Expand Up @@ -186,7 +186,7 @@ func (s *Service) RefreshPersistentSubnets() {
s.updateSubnetRecordWithMetadataV3(bitV, bitS, custodySubnetCount)

// Ping all peers.
s.pingPeers()
s.pingPeersAndLogEnr()
}

// listen for new nodes watches for new nodes in the network and adds them to the peerstore.
Expand Down
2 changes: 1 addition & 1 deletion beacon-chain/p2p/service.go
Original file line number Diff line number Diff line change
Expand Up @@ -394,7 +394,7 @@ func (s *Service) AddPingMethod(reqFunc func(ctx context.Context, id peer.ID) er
s.pingMethodLock.Unlock()
}

func (s *Service) pingPeers() {
func (s *Service) pingPeersAndLogEnr() {
s.pingMethodLock.RLock()
defer s.pingMethodLock.RUnlock()

Expand Down

0 comments on commit bd82d71

Please sign in to comment.