cri: close fifos when container is deleted

henry118 · fuweid · commit 689b342c1d6a · 2022-04-27T00:12:38.000+08:00
Signed-off-by: Henry Wang <henwang@amazon.com> (cherry picked from commit 8710d4d) Signed-off-by: Wei Fu <fuweid89@gmail.com>
diff --git a/pkg/cri/store/container/container.go b/pkg/cri/store/container/container.go
@@ -175,7 +175,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)
 }

Original file line number	Diff line number	Diff line change
`@@ -175,7 +175,11 @@ func (s *Store) Delete(id string) {`
`175`	`175`	`// So we need to return if there are error.`
`176`	`176`	`return`
`177`	`177`	`}`
`178`		`- s.labels.Release(s.containers[id].ProcessLabel)`
	`178`	`+ c := s.containers[id]`
	`179`	`+ if c.IO != nil {`
	`180`	`+ c.IO.Close()`
	`181`	`+ }`
	`182`	`+ s.labels.Release(c.ProcessLabel)`
`179`	`183`	`s.idIndex.Delete(id) // nolint: errcheck`
`180`	`184`	`delete(s.containers, id)`
`181`	`185`	`}`