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

Allow tasks to schedule themselves in-task

Browse source
This commit is contained in:
Daniel 2022-04-26 14:35:52 +02:00
parent 7797a54d18
commit 3f8f50ad1f
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 t.executing = false
// repeat? // repeat?
if t.isActive() && t.repeat != 0 { if t.isActive() && t.repeat != 0 && t.executeAt.IsZero() {
t.executeAt = time.Now().Add(t.repeat) t.executeAt = time.Now().Add(t.repeat)
t.addToSchedule(false) t.addToSchedule(false)
} }
@ -366,6 +366,9 @@ func (t *Task) executeWithLocking() {
t.lock.Unlock() t.lock.Unlock()
}() }()
// reset executeAt to detect if task set next execution itself
t.executeAt = time.Time{}
// run // run
err := t.taskFn(t.ctx, t) err := t.taskFn(t.ctx, t)
if err != nil { if err != nil {