mirrors/yggdrasil-go
2
0
Fork 0
mirror of https://github.com/yggdrasil-network/yggdrasil-go synced 2024-11-10 15:30:34 +03:00
Code Issues Packages Projects Releases Wiki Activity

Increase multicast interval at startup from 1s to 15s

Browse Source
This commit is contained in:
Neil Alexander 2019-09-20 10:08:41 +01:00
parent 6432eaa9f5
commit 1cd4b6e8dd
No known key found for this signature in database
GPG Key ID: A02A2019A2BB0944
1 changed files with 6 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
src/multicast/multicast.go
View File

@ -29,6 +29,7 @@ type Multicast struct {
listeners map[string]*yggdrasil.TcpListener listeners map[string]*yggdrasil.TcpListener
listenPort uint16 listenPort uint16
isOpen bool isOpen bool
interval time.Duration
announcer *time.Timer announcer *time.Timer
platformhandler *time.Timer platformhandler *time.Timer
} }
@ -42,6 +43,7 @@ func (m *Multicast) Init(core *yggdrasil.Core, state *config.NodeState, log *log
current := m.config.GetCurrent() current := m.config.GetCurrent()
m.listenPort = current.LinkLocalTCPPort m.listenPort = current.LinkLocalTCPPort
m.groupAddr = "[ff02::114]:9001" m.groupAddr = "[ff02::114]:9001"
m.interval = time.Second
return nil return nil
} }
@ -245,9 +247,12 @@ func (m *Multicast) announce() {
break break
} }
} }
m.announcer = time.AfterFunc(time.Second*15, func() { m.announcer = time.AfterFunc(m.interval, func() {
m.Act(m, m.announce) m.Act(m, m.announce)
}) })
if m.interval.Seconds() < 15 {
m.interval += time.Second
}
} }
func (m *Multicast) listen() { func (m *Multicast) listen() {