Merge pull request #6842 from henry118/fifo

cri: close fifos when container is deleted
2022-04-22 16:28:32 +01:00 · 2022-04-22 16:28:32 +01:00 · 6111b5ea8e
commit 6111b5ea8e
parent 7f8506a4f9 8710d4d014
1 changed files with 5 additions and 1 deletions
--- a/pkg/cri/store/container/container.go
+++ b/pkg/cri/store/container/container.go
@ -200,7 +200,11 @@ func (s *Store) Delete(id string) {
 		// So we need to return if there are error.
 		return
 	}
-	s.labels.Release(s.containers[id].ProcessLabel)
+	c := s.containers[id]
+	if c.IO != nil {
+		c.IO.Close()
+	}
+	s.labels.Release(c.ProcessLabel)
 	s.idIndex.Delete(id) // nolint: errcheck
 	delete(s.containers, id)
 }