How to use BlockUntilAggregatedNonprimaryProcsReport method of parallel_support Package

...263						close(proc3Exited)264						Eventually(done).Should(BeClosed())265					})266				})267				Describe("BlockUntilAggregatedNonprimaryProcsReport", func() {268					var specReportA, specReportB types.SpecReport269					var endReport2, endReport3 types.Report270					BeforeEach(func() {271						specReportA = types.SpecReport{LeafNodeText: "A"}272						specReportB = types.SpecReport{LeafNodeText: "B"}273						endReport2 = types.Report{SpecReports: types.SpecReports{specReportA}}274						endReport3 = types.Report{SpecReports: types.SpecReports{specReportB}}275					})276					It("blocks until all non-primary procs exit, then returns the aggregated report", func() {277						done := make(chan interface{})278						go func() {279							defer GinkgoRecover()280							report, err := client.BlockUntilAggregatedNonprimaryProcsReport()281							Ω(err).ShouldNot(HaveOccurred())282							Ω(report.SpecReports).Should(ConsistOf(specReportA, specReportB))283							close(done)284						}()285						Consistently(done).ShouldNot(BeClosed())286						Ω(client.PostSuiteDidEnd(endReport2)).Should(Succeed())287						close(proc2Exited)288						Consistently(done).ShouldNot(BeClosed())289						Ω(client.PostSuiteDidEnd(endReport3)).Should(Succeed())290						close(proc3Exited)291						Eventually(done).Should(BeClosed())292					})293					Context("when a non-primary proc disappears without reporting back", func() {294						It("blocks returns an appropriate error", func() {295							done := make(chan interface{})296							go func() {297								defer GinkgoRecover()298								report, err := client.BlockUntilAggregatedNonprimaryProcsReport()299								Ω(err).Should(Equal(types.GinkgoErrors.AggregatedReportUnavailableDueToNodeDisappearing()))300								Ω(report).Should(BeZero())301								close(done)302							}()303							Consistently(done).ShouldNot(BeClosed())304							Ω(client.PostSuiteDidEnd(endReport2)).Should(Succeed())305							close(proc2Exited)306							Consistently(done).ShouldNot(BeClosed())307							close(proc3Exited)308							Eventually(done).Should(BeClosed())309						})310					})311				})312				Describe("Fetching counters", func() {...

...35	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)48	} else {49		return newRPCServer(parallelTotal, reporter)50	}51}52func NewClient(serverHost string) Client {53	if os.Getenv("GINKGO_PARALLEL_PROTOCOL") == "HTTP" {...

1import (2func main() {3    gplog.InitializeLogging("gplog", "")4    gplog.Info("starting test")5    parallel_support := parallel.NewParallelSupport(0, 0)6    parallel_support.BlockUntilAggregatedNonprimaryProcsReport()7    gplog.Info("done")8}9import (10func main() {11    gplog.InitializeLogging("gplog", "")12    gplog.Info("starting test")13    parallel_support := parallel.NewParallelSupport(0, 0)14    parallel_support.BlockUntilAggregatedNonprimaryProcsReport()15    gplog.Info("done")16}17import (18func main() {19    gplog.InitializeLogging("gplog", "")20    gplog.Info("starting test")21    parallel_support := parallel.NewParallelSupport(0, 0)22    parallel_support.BlockUntilAggregatedNonprimaryProcsReport()23    gplog.Info("done")24}25import (26func main() {27    gplog.InitializeLogging("gplog", "")28    gplog.Info("starting test")29    parallel_support := parallel.NewParallelSupport(0, 0)30    parallel_support.BlockUntilAggregatedNonprimaryProcsReport()31    gplog.Info("done")32}

1func BlockUntilAggregatedNonprimaryProcsReport() {2	parallel_support.BlockUntilAggregatedNonprimaryProcsReport()3}4func BlockUntilAggregatedNonprimaryProcsReport() {5	parallel_support.BlockUntilAggregatedNonprimaryProcsReport()6}7func BlockUntilAggregatedNonprimaryProcsReport() {8	parallel_support.BlockUntilAggregatedNonprimaryProcsReport()9}10func BlockUntilAggregatedNonprimaryProcsReport() {11	parallel_support.BlockUntilAggregatedNonprimaryProcsReport()12}13func BlockUntilAggregatedNonprimaryProcsReport() {14	parallel_support.BlockUntilAggregatedNonprimaryProcsReport()15}16func BlockUntilAggregatedNonprimaryProcsReport() {17	parallel_support.BlockUntilAggregatedNonprimaryProcsReport()18}19func BlockUntilAggregatedNonprimaryProcsReport() {20	parallel_support.BlockUntilAggregatedNonprimaryProcsReport()21}

1import (2func main() {3	fmt.Println("Hello World")4	parallel_support.BlockUntilAggregatedNonprimaryProcsReport()5}6import (7func main() {8	fmt.Println("Hello World")9	parallel_support.BlockUntilAggregatedNonprimaryProcsReport()10}11import (12func main() {13	fmt.Println("Hello World")14	parallel_support.BlockUntilAggregatedNonprimaryProcsReport()15}16import (17func main() {18	fmt.Println("Hello World")19	parallel_support.BlockUntilAggregatedNonprimaryProcsReport()20}21import (22func main() {23	fmt.Println("Hello World")24	parallel_support.BlockUntilAggregatedNonprimaryProcsReport()25}26import (27func main() {28	fmt.Println("Hello World")29	parallel_support.BlockUntilAggregatedNonprimaryProcsReport()30}31import (32func main() {33	fmt.Println("Hello World")34	parallel_support.BlockUntilAggregatedNonprimaryProcsReport()35}36import (37func main() {38	fmt.Println("Hello World")39	parallel_support.BlockUntilAggregatedNonprimaryProcsReport()40}

1import (2func main() {3    p := parallel.NewUnordered(1)4    p.Go(func() error {5        fmt.Println("Hello World")6    })7    p.BlockUntilAggregatedNonprimaryProcsReport()8}9func (p *Unordered) BlockUntilAggregatedNonprimaryProcsReport() {10    p.aggregatedNonprimaryProcs.Wait()11}12func (p *Unordered) BlockUntilAggregatedNonprimaryProcsReport() {13    p.aggregatedNonprimaryProcs.Wait()14}15func (wg *WaitGroup) Wait() {16    runtime_SemacquireMutex(&wg.sema, false)17    runtime_Semrelease(&wg.sema, 1, false)18}19func runtime_SemacquireMutex(s *uint32, lifo bool) {20    if atomic.Xadd(s, -mutexLocked) == 0 {21    }