fix: cio.Cancel() should close the pipes

PR fixes #8326. Signed-off-by: Hsing-Yu (David) Chen <[email protected]> (cherry picked from commit 82ec62b) Signed-off-by: Hsing-Yu (David) Chen <[email protected]>
containerd · Jun 1, 2023 · 99582fb · 99582fb
1 parent deec965
commit 99582fb
Showing 1 changed file with 8 additions and 1 deletion.
diff --git a/cio/io_unix.go b/cio/io_unix.go
@@ -98,7 +98,14 @@ func copyIO(fifos *FIFOSet, ioset *Streams) (*cio, error) {
 		config:  fifos.Config,
 		wg:      wg,
 		closers: append(pipes.closers(), fifos),
-		cancel:  cancel,
+		cancel: func() {
+			cancel()
+			for _, c := range pipes.closers() {
+				if c != nil {
+					c.Close()
+				}
+			}
+		},
 	}, nil
 }