How to use PostSuiteWillBegin method of parallel_support Package

...62					endReport3 = types.Report{StartTime: t.Add(-time.Second), EndTime: t.Add(2 * time.Second), SuiteSucceeded: false, SpecReports: types.SpecReports{specReportC}}63				})64				Context("before all procs have reported SuiteWillBegin", func() {65					BeforeEach(func() {66						Ω(client.PostSuiteWillBegin(beginReport)).Should(Succeed())67						Ω(client.PostDidRun(specReportA)).Should(Succeed())68						Ω(client.PostSuiteWillBegin(beginReport)).Should(Succeed())69						Ω(client.PostDidRun(specReportB)).Should(Succeed())70					})71					It("should not forward anything to the attached reporter", func() {72						Ω(reporter.Begin).Should(BeZero())73						Ω(reporter.Will).Should(BeEmpty())74						Ω(reporter.Did).Should(BeEmpty())75					})76					Context("when the final proc reports SuiteWillBegin", func() {77						BeforeEach(func() {78							Ω(client.PostSuiteWillBegin(thirdBeginReport)).Should(Succeed())79						})80						It("forwards to SuiteWillBegin and catches up on any received summaries", func() {81							Ω(reporter.Begin).Should(Equal(thirdBeginReport))82							Ω(reporter.Will.Names()).Should(ConsistOf("A", "B"))83							Ω(reporter.Did.Names()).Should(ConsistOf("A", "B"))84						})85						Context("any subsequent summaries", func() {86							BeforeEach(func() {87								Ω(client.PostDidRun(specReportC)).Should(Succeed())88							})89							It("are forwarded immediately", func() {90								Ω(reporter.Will.Names()).Should(ConsistOf("A", "B", "C"))91								Ω(reporter.Did.Names()).Should(ConsistOf("A", "B", "C"))92							})93						})94						Context("when SuiteDidEnd start arriving", func() {95							BeforeEach(func() {96								Ω(client.PostSuiteDidEnd(endReport1)).Should(Succeed())97								Ω(client.PostSuiteDidEnd(endReport2)).Should(Succeed())98							})99							It("does not forward them yet...", func() {100								Ω(reporter.End).Should(BeZero())101							})102							It("doesn't signal it's done", func() {103								Ω(server.GetSuiteDone()).ShouldNot(BeClosed())104							})105							Context("when the final SuiteDidEnd arrive", func() {106								BeforeEach(func() {107									Ω(client.PostSuiteDidEnd(endReport3)).Should(Succeed())108								})109								It("forwards the aggregation of all received end summaries", func() {110									Ω(reporter.End.StartTime.Unix()).Should(BeNumerically("~", t.Add(-2*time.Second).Unix()))111									Ω(reporter.End.EndTime.Unix()).Should(BeNumerically("~", t.Add(2*time.Second).Unix()))112									Ω(reporter.End.RunTime).Should(BeNumerically("~", 4*time.Second))113									Ω(reporter.End.SuiteSucceeded).Should(BeFalse())114									Ω(reporter.End.SpecReports).Should(ConsistOf(specReportA, specReportB, specReportC))115								})116								It("should signal it's done", func() {117									Ω(server.GetSuiteDone()).Should(BeClosed())118								})119							})120						})121					})122				})123			})124			Describe("supporting ReportEntries (which RPC struggled with when I first implemented it)", func() {125				BeforeEach(func() {126					Ω(client.PostSuiteWillBegin(types.Report{SuiteDescription: "my sweet suite"})).Should(Succeed())127					Ω(client.PostSuiteWillBegin(types.Report{SuiteDescription: "my sweet suite"})).Should(Succeed())128					Ω(client.PostSuiteWillBegin(types.Report{SuiteDescription: "my sweet suite"})).Should(Succeed())129				})130				It("can pass in ReportEntries that include custom types", func() {131					cl := types.NewCodeLocation(0)132					entry, err := internal.NewReportEntry("No Value Entry", cl)133					Ω(err).ShouldNot(HaveOccurred())134					Ω(client.PostDidRun(types.SpecReport{135						LeafNodeText:  "no-value",136						ReportEntries: types.ReportEntries{entry},137					})).Should(Succeed())138					entry, err = internal.NewReportEntry("String Value Entry", cl, "The String")139					Ω(err).ShouldNot(HaveOccurred())140					Ω(client.PostDidRun(types.SpecReport{141						LeafNodeText:  "string-value",142						ReportEntries: types.ReportEntries{entry},...

...29}30type Client interface {31	Connect() bool32	Close() error33	PostSuiteWillBegin(report types.Report) error34	PostDidRun(report types.SpecReport) error35	PostSuiteDidEnd(report types.Report) error36	PostSynchronizedBeforeSuiteCompleted(state types.SpecState, data []byte) error37	BlockUntilSynchronizedBeforeSuiteData() (types.SpecState, []byte, error)38	BlockUntilNonprimaryProcsHaveFinished() error39	BlockUntilAggregatedNonprimaryProcsReport() (types.Report, error)40	FetchNextCounter() (int, error)41	PostAbort() error42	ShouldAbort() bool43	Write(p []byte) (int, error)44}45func NewServer(parallelTotal int, reporter reporters.Reporter) (Server, error) {46	if os.Getenv("GINKGO_PARALLEL_PROTOCOL") == "HTTP" {47		return newHttpServer(parallelTotal, reporter)...

1import (2func TestGinkgo(t *testing.T) {3    gomega.RegisterFailHandler(ginkgo.Fail)4    ginkgo.RunSpecs(t, "Ginkgo Suite")5}6var _ = ginkgo.Describe("Ginkgo", func() {7    ginkgo.BeforeSuite(func() {8        ginkgo.By("setting up the test environment")9    })10    ginkgo.AfterSuite(func() {11        ginkgo.By("tearing down the test environment")12    })13    ginkgo.It("should do something", func() {14        ginkgo.By("doing something")15    })16})17import (

1import (2func TestGinkgo(t *testing.T) {3	gomega.RegisterFailHandler(ginkgo.Fail)4	runtime.GOMAXPROCS(runtime.NumCPU())5	junitReporter := reporters.NewJUnitReporter("report.xml")6	ginkgo.RunSpecsWithDefaultAndCustomReporters(t, "Ginkgo", []ginkgo.Reporter{junitReporter})7}8var _ = ginkgo.SynchronizedBeforeSuite(func() []byte {9	fmt.Println("In SynchronizedBeforeSuite")10}, func(data []byte) {11	fmt.Println("In SynchronizedBeforeSuite - All nodes")12})13var _ = ginkgo.SynchronizedAfterSuite(func() {14	fmt.Println("In SynchronizedAfterSuite - All nodes")15}, func() {16	fmt.Println("In SynchronizedAfterSuite")17})18var _ = ginkgo.BeforeSuite(func() {19	fmt.Println("In BeforeSuite")20})21var _ = ginkgo.AfterSuite(func() {22	fmt.Println("In AfterSuite")23})24var _ = ginkgo.Describe("Ginkgo", func() {25	ginkgo.It("should run in parallel", func() {26		fmt.Println("In It")27	})28})

1func PostSuiteWillBegin() {2	fmt.Println("PostSuiteWillBegin")3}4func PostSuiteDidEnd() {5	fmt.Println("PostSuiteDidEnd")6}7func PostTestWillBegin() {8	fmt.Println("PostTestWillBegin")9}10func PostTestDidEnd() {11	fmt.Println("PostTestDidEnd")12}13func PostStepWillBegin() {14	fmt.Println("PostStepWillBegin")15}16func PostStepDidEnd() {17	fmt.Println("PostStepDidEnd")18}19func PostSuiteWillBegin() {20	fmt.Println("PostSuiteWillBegin")21}22func PostSuiteDidEnd() {23	fmt.Println("PostSuiteDidEnd")24}25func PostTestWillBegin() {26	fmt.Println("PostTestWillBegin")27}28func PostTestDidEnd() {29	fmt.Println("PostTestDidEnd")30}31func PostStepWillBegin() {32	fmt.Println("PostStepWillBegin")33}34func PostStepDidEnd() {35	fmt.Println("PostStepDidEnd")36}37func PostSuiteWillBegin() {38	fmt.Println("PostSuiteWillBegin")39}40func PostSuiteDidEnd() {41	fmt.Println("PostSuiteDidEnd")42}

1import (2func TestParallel(t *testing.T) {3	gomega.RegisterFailHandler(ginkgo.Fail)4	ginkgo.RunSpecs(t, "Parallel Suite")5}6var _ = ginkgo.SynchronizedBeforeSuite(func() []byte {7}, func(data []byte) {8})9var _ = ginkgo.SynchronizedAfterSuite(func() {10}, func() {11})12var _ = ginkgo.Describe("Parallel", func() {13	ginkgo.It("should run in parallel", func() {14		gomega.Expect(config.GinkgoConfig.ParallelNode).To(gomega.BeNumerically(">", 0))15	})16})17import (18func TestParallel(t *testing.T) {19	gomega.RegisterFailHandler(ginkgo.Fail)20	ginkgo.RunSpecs(t, "Parallel Suite")21}22var _ = ginkgo.SynchronizedBeforeSuite(func() []byte {23}, func(data []byte) {24})25var _ = ginkgo.SynchronizedAfterSuite(func() {26}, func() {27})28var _ = ginkgo.Describe("Parallel", func() {29	ginkgo.It("should run in parallel", func() {30		gomega.Expect(config.GinkgoConfig.ParallelNode).To(gomega.BeNumerically(">", 0))31	})32})33import (

1func TestMain(m *testing.M) {2    parallel_support.PostSuiteWillBegin()3    exitCode = m.Run()4    parallel_support.PostSuiteDidEnd()5    os.Exit(exitCode)6}7func TestMain(m *testing.M) {8    parallel_support.PostSuiteWillBegin()9    exitCode = m.Run()10    parallel_support.PostSuiteDidEnd()11    os.Exit(exitCode)12}13func TestMain(m *testing.M) {14    parallel_support.PostSuiteWillBegin()15    exitCode = m.Run()16    parallel_support.PostSuiteDidEnd()17    os.Exit(exitCode)18}19func TestMain(m *testing.M) {20    parallel_support.PostSuiteWillBegin()21    exitCode = m.Run()22    parallel_support.PostSuiteDidEnd()23    os.Exit(exitCode)24}25func TestMain(m *testing.M) {26    parallel_support.PostSuiteWillBegin()27    exitCode = m.Run()28    parallel_support.PostSuiteDidEnd()29    os.Exit(exitCode)30}31func TestMain(m *testing.M) {32    parallel_support.PostSuiteWillBegin()33    exitCode = m.Run()34    parallel_support.PostSuiteDidEnd()35    os.Exit(exitCode)36}37func TestMain(m *testing.M) {38    parallel_support.PostSuiteWillBegin()39    exitCode = m.Run()40    parallel_support.PostSuiteDidEnd()41    os.Exit(exitCode)42}43func TestMain(m *testing.M) {44    parallel_support.PostSuiteWillBegin()45    exitCode = m.Run()46    parallel_support.PostSuiteDidEnd()47    os.Exit(exitCode)48}49func TestMain(m *testing.M) {50    parallel_support.PostSuiteWillBegin()51    exitCode = m.Run()52    parallel_support.PostSuiteDidEnd()53    os.Exit(exitCode)54}55func TestMain(m *testing.M) {

1import (2func TestParallel(t *testing.T) {3  t.Parallel()4}5import (6func TestParallel(t *testing.T) {7  t.Parallel()8}9import (10func TestParallel(t *testing.T) {11  t.Parallel()12}13import (14func TestParallel(t *testing.T) {15  t.Parallel()16}17import (18func TestParallel(t *testing.T) {19  t.Parallel()20}21import (22func TestParallel(t *testing.T) {23  t.Parallel()24}25import (26func TestParallel(t *testing.T) {27  t.Parallel()28}29import (30func TestParallel(t *testing.T) {31  t.Parallel()32}33import (

1func TestPostSuiteWillBegin(t *testing.T) {2    parallel_support.PostSuiteWillBegin()3    t.Parallel()4    t.Log("TestPostSuiteWillBegin")5}6import (7func PostSuiteWillBegin() {8    fmt.Println("PostSuiteWillBegin")9    testing.PostSuiteWillBegin()10}11import (12func PostSuiteWillBegin() {13    fmt.Println("PostSuiteWillBegin")14    testing.PostSuiteWillBegin()15}16import (17func PostSuiteWillBegin() {18    fmt.Println("PostSuiteWillBegin")19    testing.PostSuiteWillBegin()20}21import (22func PostSuiteWillBegin() {23    fmt.Println("PostSuiteWillBegin")24    testing.PostSuiteWillBegin()25}26import (27func PostSuiteWillBegin() {28    fmt.Println("PostSuiteWillBegin")29    testing.PostSuiteWillBegin()30}31import (32func PostSuiteWillBegin() {33    fmt.Println("PostSuiteWillBegin")34    testing.PostSuiteWillBegin()35}36import (37func PostSuiteWillBegin() {38    fmt.Println("PostSuiteWillBegin")39    testing.PostSuiteWillBegin()40}41import (42func PostSuiteWillBegin() {43    fmt.Println("PostSuiteWillBegin")44    testing.PostSuiteWillBegin()45}46import (47func PostSuiteWillBegin() {48    fmt.Println("PostSuiteWillBegin")49    testing.PostSuiteWillBegin()50}51import (52func PostSuiteWillBegin() {53    fmt.Println("PostSuiteWillBegin")54    testing.PostSuiteWillBegin()55}56import (57func PostSuiteWillBegin() {58    fmt.Println("PostSuiteWillBegin")59    testing.PostSuiteWillBegin()60}61import (62func PostSuiteWillBegin() {63    fmt.Println("PostSuiteWillBegin")

1func TestMain(m *testing.M) {2    parallel_support.PostSuiteWillBegin(m, "test-suite-parallel", "test-suite-parallel")3}4func TestMain(m *testing.M) {5    parallel_support.PostSuiteWillBegin(m, "test-suite-parallel", "test-suite-parallel")6}7func TestMain(m *testing.M) {8    parallel_support.PostSuiteWillBegin(m, "test-suite-parallel", "test-suite-parallel")9}10func TestMain(m *testing.M) {11    parallel_support.PostSuiteWillBegin(m, "test-suite-parallel", "test-suite-parallel")12}13func TestMain(m *testing.M) {14    parallel_support.PostSuiteWillBegin(m, "test-suite-parallel", "test-suite-parallel")15}16func TestMain(m *testing.M) {17    parallel_support.PostSuiteWillBegin(m, "test-suite-parallel", "test-suite-parallel")18}19func TestMain(m *testing.M) {20    parallel_support.PostSuiteWillBegin(m, "test-suite-parallel", "test-suite-parallel")21}22func TestMain(m *testing.M) {23    parallel_support.PostSuiteWillBegin(m, "test-suite-parallel", "test-suite-parallel")24}25func TestMain(m *testing.M) {26    parallel_support.PostSuiteWillBegin(m, "test-suite-parallel", "test-suite-parallel")27}28func TestMain(m *testing.M) {29    parallel_support.PostSuiteWillBegin(m, "test-suite-parallel", "test-suite-parallel")