This commit is contained in:
tycho garen
2022-06-16 12:18:09 -04:00
parent 1d286fc869
commit 01f9c20fb5
+2 -2
View File
@@ -598,7 +598,7 @@ func (m *PeerManager) TryDialNext() (NodeAddress, error) {
func (m *PeerManager) DialFailed(address NodeAddress) error {
m.mtx.Lock()
defer m.mtx.Unlock()
m.metrics.PeerConnectionFailure.Add(1)
m.metrics.PeersConnectedFailure.Add(1)
delete(m.dialing, address.NodeID)
for from, to := range m.upgrading {
@@ -665,7 +665,7 @@ func (m *PeerManager) Dialed(address NodeAddress) error {
m.mtx.Lock()
defer m.mtx.Unlock()
m.metrics.PeerConnectionSuccess.Add(1)
m.metrics.PeersConnectedSuccuess.Add(1)
delete(m.dialing, address.NodeID)