fix race when multiple defercleanups are called in goroutines

internal/internal_integration/cleanup_test.go

@@ -2,6 +2,7 @@ package internal_integration_test
 
 import (
 	"fmt"
+	"sync"
 	"time"
 
 	. "github.com/onsi/ginkgo/v2"
@@ -285,5 +286,30 @@ var _ = Describe("Cleanup", func() {
 				Ω(rt).Should(HaveTracked("A", "AE", "AA", "C-AE", "C-A", "C-AA"))
 			})
 		})
+
+		Context("when cleanup is added in parallel in some goroutines", func() {
+			BeforeEach(func() {
+				success, _ := RunFixture("concurrent cleanup", func() {
+					Context("ordered", Ordered, func() {
+						It("A", func() {
+							wg := &sync.WaitGroup{}
+							wg.Add(5)
+							for i := 0; i < 5; i++ {
+								i := i
+								go func() {
+									DeferCleanup(rt.Run, fmt.Sprintf("dc-%d", i))
+									wg.Done()
+								}()
+							}
+							wg.Wait()
+						})
+					})
+				})
+				Ω(success).Should(BeTrue())
+			})
+			It("doesn't race", func() {
+				Ω(rt.TrackedRuns()).Should(ConsistOf("dc-0", "dc-1", "dc-2", "dc-3", "dc-4"))
+			})
+		})
 	})
 })

internal/suite.go

@@ -245,7 +245,9 @@ func (suite *Suite) pushCleanupNode(node Node) error {
 
 	node.NodeIDWhereCleanupWasGenerated = suite.currentNode.ID
 	node.NestingLevel = suite.currentNode.NestingLevel
+	suite.selectiveLock.Lock()
 	suite.cleanupNodes = append(suite.cleanupNodes, node)
+	suite.selectiveLock.Unlock()
 
 	return nil
 }