Rename keepAlive function, as it now does more things
This commit is contained in:
parent
8d1adaaef3
commit
48ef6e5a6f
5
poll.go
5
poll.go
|
@ -218,7 +218,7 @@ func (h *Headscale) PollNetMapStream(
|
||||||
updateChan chan struct{},
|
updateChan chan struct{},
|
||||||
cancelKeepAlive chan struct{},
|
cancelKeepAlive chan struct{},
|
||||||
) {
|
) {
|
||||||
go h.keepAlive(cancelKeepAlive, keepAliveChan, mKey, req, m)
|
go h.scheduledPollWorker(cancelKeepAlive, keepAliveChan, mKey, req, m)
|
||||||
|
|
||||||
c.Stream(func(w io.Writer) bool {
|
c.Stream(func(w io.Writer) bool {
|
||||||
log.Trace().
|
log.Trace().
|
||||||
|
@ -376,8 +376,7 @@ func (h *Headscale) PollNetMapStream(
|
||||||
})
|
})
|
||||||
}
|
}
|
||||||
|
|
||||||
// TODO: Rename this function to schedule ...
|
func (h *Headscale) scheduledPollWorker(
|
||||||
func (h *Headscale) keepAlive(
|
|
||||||
cancelChan <-chan struct{},
|
cancelChan <-chan struct{},
|
||||||
keepAliveChan chan<- []byte,
|
keepAliveChan chan<- []byte,
|
||||||
mKey wgkey.Key,
|
mKey wgkey.Key,
|
||||||
|
|
Loading…
Reference in New Issue