From e3148b16eb989af8d57192c51463622de71e50e1 Mon Sep 17 00:00:00 2001 From: Christoph Kluge Date: Thu, 5 Feb 2026 15:24:11 +0100 Subject: [PATCH] add timers to updateNodeStates --- internal/api/node.go | 8 ++++++++ 1 file changed, 8 insertions(+) diff --git a/internal/api/node.go b/internal/api/node.go index 37a8576c..930deb50 100644 --- a/internal/api/node.go +++ b/internal/api/node.go @@ -15,6 +15,7 @@ import ( "github.com/ClusterCockpit/cc-backend/internal/repository" "github.com/ClusterCockpit/cc-backend/pkg/archive" "github.com/ClusterCockpit/cc-backend/pkg/metricstore" + cclog "github.com/ClusterCockpit/cc-lib/v2/ccLogger" "github.com/ClusterCockpit/cc-lib/v2/schema" ) @@ -81,6 +82,8 @@ func (api *RestAPI) updateNodeStates(rw http.ResponseWriter, r *http.Request) { m := make(map[string][]string) healthStates := make(map[string]schema.MonitoringState) + startMs := time.Now() + for _, node := range req.Nodes { if sc, err := archive.GetSubClusterByNode(req.Cluster, node.Hostname); err == nil { m[sc] = append(m[sc], node.Hostname) @@ -97,6 +100,9 @@ func (api *RestAPI) updateNodeStates(rw http.ResponseWriter, r *http.Request) { } } + cclog.Infof("Timer updateNodeStates, MemStore HealthCheck: %s", time.Since(startMs)) + startDb := time.Now() + for _, node := range req.Nodes { state := determineState(node.States) healthState := schema.MonitoringStateFailed @@ -115,4 +121,6 @@ func (api *RestAPI) updateNodeStates(rw http.ResponseWriter, r *http.Request) { repo.UpdateNodeState(node.Hostname, req.Cluster, &nodeState) } + + cclog.Infof("Timer updateNodeStates, SQLite Inserts: %s", time.Since(startDb)) }