lib/connections: Don't look at devices that are already optimally connected

Just an optimization. Required exposing the priority from the factory,
so made that an interface with an extra method instead of just a func
type.

GitHub-Pull-Request: https://github.com/syncthing/syncthing/pull/3071
This commit is contained in:
Jakob Borg
2016-05-09 15:33:25 +00:00
committed by Audrius Butkevicius
parent 31f64186ae
commit d77d8ff803
4 changed files with 35 additions and 8 deletions

View File

@@ -240,6 +240,13 @@ func (s *Service) connect() {
delay := time.Second
sleep := time.Second
bestDialerPrio := 1<<31 - 1 // worse prio won't build on 32 bit
for _, df := range dialers {
if prio := df.Priority(); prio < bestDialerPrio {
bestDialerPrio = prio
}
}
for {
l.Debugln("Reconnect loop")
@@ -257,13 +264,18 @@ func (s *Service) connect() {
continue
}
l.Debugln("Reconnect loop for", deviceID)
connected := s.model.ConnectedTo(deviceID)
s.curConMut.Lock()
ct := s.currentConnection[deviceID]
s.curConMut.Unlock()
if connected && ct.Priority == bestDialerPrio {
// Things are already as good as they can get.
continue
}
l.Debugln("Reconnect loop for", deviceID)
var addrs []string
for _, addr := range deviceCfg.Addresses {
if addr == "dynamic" {
@@ -292,7 +304,7 @@ func (s *Service) connect() {
continue
}
dialer := dialerFactory(s.cfg, s.tlsCfg)
dialer := dialerFactory.New(s.cfg, s.tlsCfg)
nextDialAt, ok := nextDial[uri.String()]
// See below for comments on this delay >= sleep check