uevent: should close uevent channel

Signed-off-by: Vicente Cheng <[email protected]>
harvester · Jan 25, 2024 · 69de43f · 69de43f
1 parent a8c2931
commit 69de43f
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/pkg/udev/uevent.go b/pkg/udev/uevent.go
@@ -74,6 +74,7 @@ func (u *Udev) monitor(ctx context.Context, errors chan error) {
 	uqueue := make(chan netlink.UEvent)
 	errChan := make(chan error)
 	quit := conn.Monitor(uqueue, errChan, matcher)
+	defer close(quit)
 
 	// simulator the error from udev monitor
 	if u.injectError {
@@ -91,7 +92,6 @@ func (u *Udev) monitor(ctx context.Context, errors chan error) {
 			errors <- err
 			return
 		case <-ctx.Done():
-			close(quit)
 			return
 		}
 	}