Fixing hardlink rule

Signed-off-by: Amit Schendel <[email protected]>
kubescape · Jun 4, 2024 · b7a2e89 · b7a2e89
1 parent b5601d3
commit b7a2e89
Show file tree

Hide file tree

Showing 2 changed files with 13 additions and 2 deletions.
diff --git a/pkg/containerwatcher/v1/container_watcher_private.go b/pkg/containerwatcher/v1/container_watcher_private.go
@@ -259,6 +259,11 @@ func (ch *IGContainerWatcher) startTracers() error {
 			logger.L().Error("error starting symlink tracing", helpers.Error(err))
 			return err
 		}
+
+		if err := ch.startHardlinkTracing(); err != nil {
+			logger.L().Error("error starting hardlink tracing", helpers.Error(err))
+			return err
+		}
 	}
 
 	return nil
@@ -318,6 +323,12 @@ func (ch *IGContainerWatcher) stopTracers() error {
 			logger.L().Error("error stopping symlink tracing", helpers.Error(err))
 			errs = errors.Join(errs, err)
 		}
+
+		// Stop hardlink tracer
+		if err := ch.stopHardlinkTracing(); err != nil {
+			logger.L().Error("error stopping hardlink tracing", helpers.Error(err))
+			errs = errors.Join(errs, err)
+		}
 	}
 
 	return errs

diff --git a/pkg/containerwatcher/v1/hardlink.go b/pkg/containerwatcher/v1/hardlink.go
@@ -33,8 +33,8 @@ func (ch *IGContainerWatcher) startHardlinkTracing() error {
 	}
 
 	go func() {
-		for event := range ch.symlinkWorkerChan {
-			ch.symlinkWorkerPool.Invoke(*event)
+		for event := range ch.hardlinkWorkerChan {
+			ch.hardlinkWorkerPool.Invoke(*event)
 		}
 	}()