Skip to content

Commit 24b642a

Browse files
authored
Merge pull request kubernetes#125282 from matthyx/run2gether
ignore starting order in RunTogether, add another that does
2 parents 99cb3eb + 367e8c5 commit 24b642a

File tree

2 files changed

+16
-10
lines changed

2 files changed

+16
-10
lines changed

test/e2e_node/container_lifecycle_pod_construction.go

Lines changed: 11 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -119,8 +119,18 @@ func (o containerOutputList) String() string {
119119
return b.String()
120120
}
121121

122-
// RunTogether returns an error the lhs and rhs run together
122+
// RunTogether returns an error if containers don't run together
123123
func (o containerOutputList) RunTogether(lhs, rhs string) error {
124+
if err := o.RunTogetherLhsFirst(lhs, rhs); err != nil {
125+
if err := o.RunTogetherLhsFirst(rhs, lhs); err != nil {
126+
return err
127+
}
128+
}
129+
return nil
130+
}
131+
132+
// RunTogetherLhsFirst returns an error if containers don't run together or if rhs starts before lhs
133+
func (o containerOutputList) RunTogetherLhsFirst(lhs, rhs string) error {
124134
lhsStart := o.findIndex(lhs, "Started", 0)
125135
if lhsStart == -1 {
126136
return fmt.Errorf("couldn't find that %s ever started, got\n%v", lhs, o)

test/e2e_node/container_lifecycle_test.go

Lines changed: 5 additions & 9 deletions
Original file line numberDiff line numberDiff line change
@@ -834,9 +834,9 @@ var _ = SIGDescribe(framework.WithNodeConformance(), "Containers Lifecycle", fun
834834

835835
ginkgo.By("Analyzing results")
836836
// readiness probes are called during pod termination
837-
framework.ExpectNoError(results.RunTogether(prefixedName(PreStopPrefix, regular1), prefixedName(ReadinessPrefix, regular1)))
837+
framework.ExpectNoError(results.RunTogetherLhsFirst(prefixedName(PreStopPrefix, regular1), prefixedName(ReadinessPrefix, regular1)))
838838
// liveness probes are not called during pod termination
839-
err = results.RunTogether(prefixedName(PreStopPrefix, regular1), prefixedName(LivenessPrefix, regular1))
839+
err = results.RunTogetherLhsFirst(prefixedName(PreStopPrefix, regular1), prefixedName(LivenessPrefix, regular1))
840840
gomega.Expect(err).To(gomega.HaveOccurred())
841841
})
842842

@@ -897,11 +897,11 @@ var _ = SIGDescribe(framework.WithNodeConformance(), "Containers Lifecycle", fun
897897
ginkgo.By("Analyzing results")
898898
// FIXME ExpectNoError: this will be implemented in KEP 4438
899899
// liveness probes are called for restartable init containers during pod termination
900-
err = results.RunTogether(prefixedName(PreStopPrefix, regular1), prefixedName(LivenessPrefix, restartableInit1))
900+
err = results.RunTogetherLhsFirst(prefixedName(PreStopPrefix, regular1), prefixedName(LivenessPrefix, restartableInit1))
901901
gomega.Expect(err).To(gomega.HaveOccurred())
902902
// FIXME ExpectNoError: this will be implemented in KEP 4438
903903
// restartable init containers are restarted during pod termination
904-
err = results.RunTogether(prefixedName(PreStopPrefix, regular1), restartableInit1)
904+
err = results.RunTogetherLhsFirst(prefixedName(PreStopPrefix, regular1), restartableInit1)
905905
gomega.Expect(err).To(gomega.HaveOccurred())
906906
})
907907
})
@@ -1147,12 +1147,8 @@ var _ = SIGDescribe(nodefeature.SidecarContainers, "Containers Lifecycle", func(
11471147
framework.ExpectNoError(results.ExitsBefore(init1, restartableInit1))
11481148
})
11491149

1150-
ginkgo.It("should start first restartable init container before starting second init container", func() {
1151-
framework.ExpectNoError(results.StartsBefore(restartableInit1, init2))
1152-
})
1153-
11541150
ginkgo.It("should run first init container and first restartable init container together", func() {
1155-
framework.ExpectNoError(results.RunTogether(restartableInit1, init2))
1151+
framework.ExpectNoError(results.RunTogetherLhsFirst(restartableInit1, init2))
11561152
})
11571153

11581154
ginkgo.It("should run second init container to completion before starting second restartable init container", func() {

0 commit comments

Comments
 (0)