1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
|
package integration_test
import (
"strings"
. "github.com/onsi/ginkgo/v2"
. "github.com/onsi/gomega"
"github.com/onsi/gomega/gexec"
)
var _ = Describe("SuiteSetup", func() {
Context("With passing synchronized before and after suites", func() {
BeforeEach(func() {
fm.MountFixture("synchronized_setup_tests")
})
Context("when run with one proc", func() {
It("should do all the work on that one proc", func() {
session := startGinkgo(fm.PathTo("synchronized_setup_tests"), "--no-color")
Eventually(session).Should(gexec.Exit(0))
output := string(session.Out.Contents())
Ω(output).Should(ContainSubstring("BEFORE_A_1\nBEFORE_B_1: DATA"))
Ω(output).Should(ContainSubstring("AFTER_A_1\nAFTER_B_1"))
})
})
Context("when run across multiple procs", func() {
It("should run the first BeforeSuite function (BEFORE_A) on proc 1, the second (BEFORE_B) on all the procs, the first AfterSuite (AFTER_A) on all the procs, and then the second (AFTER_B) on Node 1 *after* everything else is finished", func() {
session := startGinkgo(fm.PathTo("synchronized_setup_tests"), "--no-color", "--procs=3")
Eventually(session).Should(gexec.Exit(0))
output := string(session.Out.Contents())
numOccurrences := 0
for _, line := range strings.Split(output, "\n") {
occurs, _ := ContainSubstring("BEFORE_A_1").Match(line)
if occurs {
numOccurrences += 1
}
}
Ω(numOccurrences).Should(Equal(2)) // once when it's emitted because it's in the synchronizedBeforeSuite proc. And once again when it's captured in the spec report that includes the stdout output.
numOccurrences = 0
for _, line := range strings.Split(output, "\n") {
occurs, _ := ContainSubstring("AFTER_B_1").Match(line)
if occurs {
numOccurrences += 1
}
}
Ω(numOccurrences).Should(Equal(2)) // once when it's emitted because it's in the synchronizedAfterSuite proc. And once again when it's captured in the spec report that includes the stdout output.
Ω(output).Should(ContainSubstring("BEFORE_A_1"))
Ω(output).Should(ContainSubstring("BEFORE_B_1: DATA"))
Ω(output).Should(ContainSubstring("BEFORE_B_2: DATA"))
Ω(output).Should(ContainSubstring("BEFORE_B_3: DATA"))
Ω(output).ShouldNot(ContainSubstring("BEFORE_A_2"))
Ω(output).ShouldNot(ContainSubstring("BEFORE_A_3"))
Ω(output).Should(ContainSubstring("AFTER_A_1"))
Ω(output).Should(ContainSubstring("AFTER_A_2"))
Ω(output).Should(ContainSubstring("AFTER_A_3"))
Ω(output).Should(ContainSubstring("AFTER_B_1"))
Ω(output).ShouldNot(ContainSubstring("AFTER_B_2"))
Ω(output).ShouldNot(ContainSubstring("AFTER_B_3"))
})
})
})
Context("With a failing synchronized before suite", func() {
BeforeEach(func() {
fm.MountFixture("exiting_synchronized_setup")
})
It("should fail and let the user know that proc 1 disappeared prematurely", func() {
session := startGinkgo(fm.PathTo("exiting_synchronized_setup"), "--no-color", "--procs=3")
Eventually(session).Should(gexec.Exit(1))
output := string(session.Out.Contents()) + string(session.Err.Contents())
Ω(output).Should(ContainSubstring("Process #1 disappeared before SynchronizedBeforeSuite could report back"))
Ω(output).Should(ContainSubstring("Ginkgo timed out waiting for all parallel procs to report back"))
})
})
})
|
