diff --git a/pkg/pillar/cmd/loguploader/loguploader.go b/pkg/pillar/cmd/loguploader/loguploader.go index 0d5c86ab04..0e259d08cd 100644 --- a/pkg/pillar/cmd/loguploader/loguploader.go +++ b/pkg/pillar/cmd/loguploader/loguploader.go @@ -103,6 +103,7 @@ func Run(ps *pubsub.PubSub, loggerArg *logrus.Logger, logArg *base.LogObject, ar // Run a periodic timer so we always update StillRunning stillRunning := time.NewTicker(stillRunningInerval) + ps.StillRunning(agentName, warningTime, errorTime) // Wait until we have been onboarded aka know our own UUID subOnboardStatus, err := ps.NewSubscription(pubsub.SubscriptionOptions{ diff --git a/pkg/pillar/cmd/nodeagent/nodeagent.go b/pkg/pillar/cmd/nodeagent/nodeagent.go index 8fedb8cb59..e3a331fe61 100644 --- a/pkg/pillar/cmd/nodeagent/nodeagent.go +++ b/pkg/pillar/cmd/nodeagent/nodeagent.go @@ -123,7 +123,7 @@ type nodeagentContext struct { domainHaltWaitIncrement uint32 } -func newNodeagentContext(_ *pubsub.PubSub, _ *logrus.Logger, _ *base.LogObject) *nodeagentContext { +func newNodeagentContext(ps *pubsub.PubSub, _ *logrus.Logger, _ *base.LogObject) *nodeagentContext { nodeagentCtx := nodeagentContext{} nodeagentCtx.minRebootDelay = minRebootDelay nodeagentCtx.maxDomainHaltTime = maxDomainHaltTime @@ -134,6 +134,7 @@ func newNodeagentContext(_ *pubsub.PubSub, _ *logrus.Logger, _ *base.LogObject) // start the watchdog process timer tick duration := time.Duration(watchdogInterval) * time.Second nodeagentCtx.stillRunning = time.NewTicker(duration) + ps.StillRunning(agentName, warningTime, errorTime) // set the ticker timer duration = time.Duration(timeTickInterval) * time.Second diff --git a/pkg/pillar/cmd/zfsmanager/zfsmanager.go b/pkg/pillar/cmd/zfsmanager/zfsmanager.go index 9537d5a8d1..9c82688e6d 100644 --- a/pkg/pillar/cmd/zfsmanager/zfsmanager.go +++ b/pkg/pillar/cmd/zfsmanager/zfsmanager.go @@ -71,6 +71,7 @@ func Run(ps *pubsub.PubSub, loggerArg *logrus.Logger, logArg *base.LogObject, ar // Run a periodic timer so we always update StillRunning stillRunning := time.NewTicker(stillRunningInterval) + ps.StillRunning(agentName, warningTime, errorTime) // Wait until we have been onboarded aka know our own UUID, but we don't use the UUID err := utils.WaitForOnboarded(ps, log, agentName, warningTime, errorTime) diff --git a/pkg/pillar/zedbox/zedbox.go b/pkg/pillar/zedbox/zedbox.go index c3489ab2a9..4b07d2e787 100644 --- a/pkg/pillar/zedbox/zedbox.go +++ b/pkg/pillar/zedbox/zedbox.go @@ -180,6 +180,7 @@ func runZedbox(ps *pubsub.PubSub, logger *logrus.Logger, log *base.LogObject, ar agentbase.WithArguments(arguments)) stillRunning := time.NewTicker(15 * time.Second) + ps.StillRunning(agentName, warningTime, errorTime) subChan := reverse.NewSubscriber(log, agentName, types.ServiceInitStatus{})