vikarti.anatra/safing-portbase
1
0
Fork 0
mirror of https://github.com/safing/portbase synced 2025-09-01 10:09:50 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions

Merge pull request #159 from safing/fix/custom-task-scheduling

Browse source 
Allow tasks to schedule themselves in-task
This commit is contained in:
Daniel 2022-04-26 15:28:22 +02:00 • committed by GitHub
commit 85f8832911
No known key found for this signature in database
GPG key ID: 4AEE18F83AFDEB23
1 changed files with 4 additions and 1 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

5
modules/tasks.go
View file

@ -351,7 +351,7 @@ func (t *Task) executeWithLocking() {
t.executing = false
// repeat?
if t.isActive() && t.repeat != 0 {
if t.isActive() && t.repeat != 0 && t.executeAt.IsZero() {
t.executeAt = time.Now().Add(t.repeat)
t.addToSchedule(false)
}
@ -366,6 +366,9 @@ func (t *Task) executeWithLocking() {
t.lock.Unlock()
}()
// reset executeAt to detect if task set next execution itself
t.executeAt = time.Time{}
// run
err := t.taskFn(t.ctx, t)
if err != nil {