Remove Queue Breaks
This commit is contained in:
parent
5ef2f6f94c
commit
667fc15294
|
@ -190,7 +190,6 @@ func (cr *contactRetry) run() {
|
||||||
if contact.state == connections.DISCONNECTED {
|
if contact.state == connections.DISCONNECTED {
|
||||||
cr.publishConnectionRequest(contact)
|
cr.publishConnectionRequest(contact)
|
||||||
connectingCount++
|
connectingCount++
|
||||||
break
|
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
@ -203,7 +202,6 @@ func (cr *contactRetry) run() {
|
||||||
if contact.state == connections.DISCONNECTED {
|
if contact.state == connections.DISCONNECTED {
|
||||||
cr.publishConnectionRequest(contact)
|
cr.publishConnectionRequest(contact)
|
||||||
connectingCount++
|
connectingCount++
|
||||||
break
|
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
cr.lastCheck = time.Now()
|
cr.lastCheck = time.Now()
|
||||||
|
|
Loading…
Reference in New Issue