From dea00a0e8fd22fcc189c6ffbdcd25636fc7bb651 Mon Sep 17 00:00:00 2001 From: Richard Kovacs Date: Mon, 16 Jan 2023 10:06:43 +0100 Subject: [PATCH] Fix memory leak of volume and node cache --- internal/controllers/sync-node/controller.go | 1 + internal/controllers/sync-volume/controller.go | 1 + 2 files changed, 2 insertions(+) diff --git a/internal/controllers/sync-node/controller.go b/internal/controllers/sync-node/controller.go index 9f8d2877..de141023 100644 --- a/internal/controllers/sync-node/controller.go +++ b/internal/controllers/sync-node/controller.go @@ -175,6 +175,7 @@ func (r *Reconciler) sync(ctx context.Context) { } } for nodeID, nodeKey := range orphanNodes { + delete(r.nodeHashes, nodeID) delete(r.existingNodes, nodeID) r.delete(ctx, nodeKey) } diff --git a/internal/controllers/sync-volume/controller.go b/internal/controllers/sync-volume/controller.go index cdb24158..8480bdc8 100644 --- a/internal/controllers/sync-volume/controller.go +++ b/internal/controllers/sync-volume/controller.go @@ -174,6 +174,7 @@ func (r *Reconciler) sync(ctx context.Context) { } } for volID, volKey := range orphanVolumes { + delete(r.volumeHashes, volID) delete(r.existingVolumes, volID) r.delete(ctx, volKey) }