refactor: extract helper function

This commit is contained in:
Matthias Radestock committed 2015-03-27 12:06:22 +00:00
1 parent 4d8c156915
commit 60ba8cb90d
1 file changed
+12 -8
+12 -8
View File
@@ -149,6 +149,18 @@ func (cm *ConnectionMaker) checkStateAndAttemptConnections() time.Duration {
}
})
return cm.connectToTargets(validTarget, ourConnectedTargets)
}
func (cm *ConnectionMaker) addTarget(address string) {
if _, found := cm.targets[address]; !found {
target := &Target{}
target.tryAfter, target.tryInterval = tryImmediately()
cm.targets[address] = target
}
}
func (cm *ConnectionMaker) connectToTargets(validTarget map[string]bool, ourConnectedTargets map[string]bool) time.Duration {
now := time.Now() // make sure we catch items just added
after := MaxDuration
for address, target := range cm.targets {
@@ -174,14 +186,6 @@ func (cm *ConnectionMaker) checkStateAndAttemptConnections() time.Duration {
return after
}
func (cm *ConnectionMaker) addTarget(address string) {
if _, found := cm.targets[address]; !found {
target := &Target{}
target.tryAfter, target.tryInterval = tryImmediately()
cm.targets[address] = target
}
}
func (cm *ConnectionMaker) attemptConnection(address string, acceptNewPeer bool) {
log.Printf("->[%s] attempting connection\n", address)
if err := cm.ourself.CreateConnection(address, acceptNewPeer); err != nil {