This commit is contained in:
Bryan Boreham committed 2014-09-10 13:45:56 +01:00
1 parent cd92fad369
commit 634d4e0fe3
2 files changed
+8 -8

No files matched your search

+7 -7
View File
@@ -95,6 +95,7 @@ func (cm *ConnectionMaker) queryLoop(queryChan <-chan *ConnectionMakerInteractio
func (cm *ConnectionMaker) checkStateAndAttemptConnections(now time.Time) {
ourself := cm.router.Ourself
// Any targets that are now connected, we don't need to attempt any more
for address, target := range cm.targets {
if _, found := ourself.ConnectionOn(address); found {
@@ -108,6 +109,7 @@ func (cm *ConnectionMaker) checkStateAndAttemptConnections(now time.Time) {
delete(cm.targets, address)
}
} else if target.isCmdLine {
// This is a target that we are not connected to - if we are not currently attempting to connect, make sure we record it as unconnected
if target.state != CSAttempting {
target.state = CSUnconnected
}
@@ -135,13 +137,11 @@ func (cm *ConnectionMaker) checkStateAndAttemptConnections(now time.Time) {
})
})
{
for address, target := range cm.targets {
if target.state == CSUnconnected && now.After(target.tryAfter) {
target.attemptCount += 1
target.state = CSAttempting
go cm.attemptConnection(address, target.isCmdLine)
}
for address, target := range cm.targets {
if target.state == CSUnconnected && now.After(target.tryAfter) {
target.attemptCount += 1
target.state = CSAttempting
go cm.attemptConnection(address, target.isCmdLine)
}
}
}
+1 -1
View File
@@ -155,7 +155,7 @@ type Topology struct {
type ConnectionMakerInteraction struct {
Interaction
address string
address string
}
type ConnectionMaker struct {