Delay the self-check slightly
This commit is contained in:
@@ -29,14 +29,15 @@ func prep() error {
|
|||||||
func start() error {
|
func start() error {
|
||||||
selfcheckTask = module.NewTask("compatibility self-check", selfcheckTaskFunc).
|
selfcheckTask = module.NewTask("compatibility self-check", selfcheckTaskFunc).
|
||||||
Repeat(1 * time.Minute).
|
Repeat(1 * time.Minute).
|
||||||
StartASAP()
|
MaxDelay(selfcheckTaskRetryAfter).
|
||||||
|
Schedule(time.Now().Add(selfcheckTaskRetryAfter))
|
||||||
|
|
||||||
return module.RegisterEventHook(
|
return module.RegisterEventHook(
|
||||||
netenv.ModuleName,
|
netenv.ModuleName,
|
||||||
netenv.NetworkChangedEvent,
|
netenv.NetworkChangedEvent,
|
||||||
"trigger compat self-check",
|
"trigger compat self-check",
|
||||||
func(_ context.Context, _ interface{}) error {
|
func(_ context.Context, _ interface{}) error {
|
||||||
selfcheckTask.StartASAP()
|
selfcheckTask.Schedule(time.Now().Add(selfcheckTaskRetryAfter))
|
||||||
return nil
|
return nil
|
||||||
},
|
},
|
||||||
)
|
)
|
||||||
|
|||||||
Reference in New Issue
Block a user