Function selfcheckTaskFunc

service/compat/module.go:107–151

(wc *mgr.WorkerCtx)

}

func selfcheckTaskFunc(wc *mgr.WorkerCtx) error {

	// Create tracing logger.
	ctx, tracer := log.AddTracer(wc.Ctx())
	defer tracer.Submit()
	tracer.Tracef("compat: running self-check")

	// Run selfcheck and return if successful.
	issue, err := selfcheck(ctx)
	switch {
	case err == nil:
		// Successful.
		tracer.Debugf("compat: self-check successful")
	case errors.Is(err, errSelfcheckSkipped):
		// Skipped.
		tracer.Debugf("compat: %s", err)
	case issue == nil:
		// Internal error.
		tracer.Warningf("compat: %s", err)
	case selfcheckNetworkChangedFlag.IsSet():
		// The network changed, ignore the issue.
	default:
		// The self-check failed.

		// Set state and increase counter.
		selfCheckIsFailing.Set()
		selfcheckFails++

		// Log and notify.
		tracer.Errorf("compat: %s", err)
		if selfcheckFails >= selfcheckFailThreshold {
			issue.notify(err)
		}

		// Retry quicker when failed.
		module.selfcheckWorkerMgr.Delay(selfcheckTaskRetryAfter)

		return nil
	}

	// Reset self-check state.
	resetSelfCheckState()

	return nil
}

func resetSelfCheckState() {
	selfcheckNetworkChangedFlag.Refresh()