From 512bca5b18e2481d0048924a3c4c6fbc2756704c Mon Sep 17 00:00:00 2001
From: Guy Arbitman <guy20495@gmail.com>
Date: Sun, 8 Dec 2024 15:22:18 +0200
Subject: [PATCH] usm: Move helper function to its only usage (#31862)

---
 pkg/network/usm/sharedlibraries/watcher.go | 28 +++++++++++++++++++++-
 pkg/process/monitor/process_monitor.go     | 26 --------------------
 2 files changed, 27 insertions(+), 27 deletions(-)

diff --git a/pkg/network/usm/sharedlibraries/watcher.go b/pkg/network/usm/sharedlibraries/watcher.go
index ca44117d637727..f23673fc6c24ea 100644
--- a/pkg/network/usm/sharedlibraries/watcher.go
+++ b/pkg/network/usm/sharedlibraries/watcher.go
@@ -275,7 +275,7 @@ func (w *Watcher) Start() {
 				return
 			case <-processSync.C:
 				processSet := w.registry.GetRegisteredProcesses()
-				deletedPids := monitor.FindDeletedProcesses(processSet)
+				deletedPids := findDeletedProcesses(processSet)
 				for deletedPid := range deletedPids {
 					_ = w.registry.Unregister(deletedPid)
 				}
@@ -290,3 +290,29 @@ func (w *Watcher) Start() {
 
 	utils.AddAttacher(consts.USMModuleName, "native", w)
 }
+
+// findDeletedProcesses returns the terminated PIDs from the given map.
+func findDeletedProcesses[V any](pids map[uint32]V) map[uint32]struct{} {
+	existingPids := make(map[uint32]struct{}, len(pids))
+
+	procIter := func(pid int) error {
+		if _, exists := pids[uint32(pid)]; exists {
+			existingPids[uint32(pid)] = struct{}{}
+		}
+		return nil
+	}
+	// Scanning already running processes
+	if err := kernel.WithAllProcs(kernel.ProcFSRoot(), procIter); err != nil {
+		return nil
+	}
+
+	res := make(map[uint32]struct{}, len(pids)-len(existingPids))
+	for pid := range pids {
+		if _, exists := existingPids[pid]; exists {
+			continue
+		}
+		res[pid] = struct{}{}
+	}
+
+	return res
+}
diff --git a/pkg/process/monitor/process_monitor.go b/pkg/process/monitor/process_monitor.go
index 1b9e30eb1ec849..8710aa63e324f3 100644
--- a/pkg/process/monitor/process_monitor.go
+++ b/pkg/process/monitor/process_monitor.go
@@ -487,32 +487,6 @@ func (pm *ProcessMonitor) Stop() {
 	pm.processExitCallbacksMutex.Unlock()
 }
 
-// FindDeletedProcesses returns the terminated PIDs from the given map.
-func FindDeletedProcesses[V any](pids map[uint32]V) map[uint32]struct{} {
-	existingPids := make(map[uint32]struct{}, len(pids))
-
-	procIter := func(pid int) error {
-		if _, exists := pids[uint32(pid)]; exists {
-			existingPids[uint32(pid)] = struct{}{}
-		}
-		return nil
-	}
-	// Scanning already running processes
-	if err := kernel.WithAllProcs(kernel.ProcFSRoot(), procIter); err != nil {
-		return nil
-	}
-
-	res := make(map[uint32]struct{}, len(pids)-len(existingPids))
-	for pid := range pids {
-		if _, exists := existingPids[pid]; exists {
-			continue
-		}
-		res[pid] = struct{}{}
-	}
-
-	return res
-}
-
 // Event defines the event used by the process monitor
 type Event struct {
 	Type model.EventType