sendnrw/netbird
2
0
Fork 0
mirror of https://github.com/netbirdio/netbird.git synced 2026-04-18 08:16:39 +00:00
Code Issues Packages Projects Releases Wiki Activity

reduce log level of scheduler to trace

Browse Source
This commit is contained in:
braginini
2024-04-17 19:34:59 +02:00
parent 30bed57711
commit 41d4dd2aff
1 changed files with 4 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

8
management/server/scheduler.go
View File

@@ -95,18 +95,18 @@ func (wm *DefaultScheduler) Schedule(in time.Duration, ID string, job func() (ne
case <-ticker.C: case <-ticker.C:
select { select {
case <-cancel: case <-cancel:
log.Debugf("scheduled job %s was canceled, stop timer", ID) log.Tracef("scheduled job %s was canceled, stop timer", ID)
ticker.Stop() ticker.Stop()
return return
default: default:
log.Debugf("time to do a scheduled job %s", ID) log.Tracef("time to do a scheduled job %s", ID)
} }
runIn, reschedule := job() runIn, reschedule := job()
if !reschedule { if !reschedule {
wm.mu.Lock() wm.mu.Lock()
defer wm.mu.Unlock() defer wm.mu.Unlock()
delete(wm.jobs, ID) delete(wm.jobs, ID)
log.Debugf("job %s is not scheduled to run again", ID) log.Tracef("job %s is not scheduled to run again", ID)
ticker.Stop() ticker.Stop()
return return
} }
@@ -115,7 +115,7 @@ func (wm *DefaultScheduler) Schedule(in time.Duration, ID string, job func() (ne
ticker.Reset(runIn) ticker.Reset(runIn)
} }
case <-cancel: case <-cancel:
log.Debugf("job %s was canceled, stopping timer", ID) log.Tracef("job %s was canceled, stopping timer", ID)
ticker.Stop() ticker.Stop()
return return
} }