How to use handleAbort method of parallel_support Package

...46	mux.HandleFunc("/have-nonprimary-procs-finished", server.handleHaveNonprimaryProcsFinished)47	mux.HandleFunc("/aggregated-nonprimary-procs-report", server.handleAggregatedNonprimaryProcsReport)48	mux.HandleFunc("/counter", server.handleCounter)49	mux.HandleFunc("/up", server.handleUp)50	mux.HandleFunc("/abort", server.handleAbort)51	go httpServer.Serve(server.listener)52}53//Stop the server54func (server *httpServer) Close() {55	server.listener.Close()56}57//The address the server can be reached it.  Pass this into the `ForwardingReporter`.58func (server *httpServer) Address() string {59	return "http://" + server.listener.Addr().String()60}61func (server *httpServer) GetSuiteDone() chan interface{} {62	return server.handler.done63}64func (server *httpServer) GetOutputDestination() io.Writer {65	return server.handler.outputDestination66}67func (server *httpServer) SetOutputDestination(w io.Writer) {68	server.handler.outputDestination = w69}70func (server *httpServer) RegisterAlive(node int, alive func() bool) {71	server.handler.registerAlive(node, alive)72}73//74// Streaming Endpoints75//76//The server will forward all received messages to Ginkgo reporters registered with `RegisterReporters`77func (server *httpServer) decode(writer http.ResponseWriter, request *http.Request, object interface{}) bool {78	defer request.Body.Close()79	if json.NewDecoder(request.Body).Decode(object) != nil {80		writer.WriteHeader(http.StatusBadRequest)81		return false82	}83	return true84}85func (server *httpServer) handleError(err error, writer http.ResponseWriter) bool {86	if err == nil {87		return false88	}89	switch err {90	case ErrorEarly:91		writer.WriteHeader(http.StatusTooEarly)92	case ErrorGone:93		writer.WriteHeader(http.StatusGone)94	case ErrorFailed:95		writer.WriteHeader(http.StatusFailedDependency)96	default:97		writer.WriteHeader(http.StatusInternalServerError)98	}99	return true100}101func (server *httpServer) specSuiteWillBegin(writer http.ResponseWriter, request *http.Request) {102	var report types.Report103	if !server.decode(writer, request, &report) {104		return105	}106	server.handleError(server.handler.SpecSuiteWillBegin(report, voidReceiver), writer)107}108func (server *httpServer) didRun(writer http.ResponseWriter, request *http.Request) {109	var report types.SpecReport110	if !server.decode(writer, request, &report) {111		return112	}113	server.handleError(server.handler.DidRun(report, voidReceiver), writer)114}115func (server *httpServer) specSuiteDidEnd(writer http.ResponseWriter, request *http.Request) {116	var report types.Report117	if !server.decode(writer, request, &report) {118		return119	}120	server.handleError(server.handler.SpecSuiteDidEnd(report, voidReceiver), writer)121}122func (server *httpServer) emitOutput(writer http.ResponseWriter, request *http.Request) {123	output, err := io.ReadAll(request.Body)124	if err != nil {125		writer.WriteHeader(http.StatusInternalServerError)126		return127	}128	var n int129	server.handleError(server.handler.EmitOutput(output, &n), writer)130}131func (server *httpServer) handleBeforeSuiteCompleted(writer http.ResponseWriter, request *http.Request) {132	var beforeSuiteState BeforeSuiteState133	if !server.decode(writer, request, &beforeSuiteState) {134		return135	}136	server.handleError(server.handler.BeforeSuiteCompleted(beforeSuiteState, voidReceiver), writer)137}138func (server *httpServer) handleBeforeSuiteState(writer http.ResponseWriter, request *http.Request) {139	var beforeSuiteState BeforeSuiteState140	if server.handleError(server.handler.BeforeSuiteState(voidSender, &beforeSuiteState), writer) {141		return142	}143	json.NewEncoder(writer).Encode(beforeSuiteState)144}145func (server *httpServer) handleHaveNonprimaryProcsFinished(writer http.ResponseWriter, request *http.Request) {146	if server.handleError(server.handler.HaveNonprimaryProcsFinished(voidSender, voidReceiver), writer) {147		return148	}149	writer.WriteHeader(http.StatusOK)150}151func (server *httpServer) handleAggregatedNonprimaryProcsReport(writer http.ResponseWriter, request *http.Request) {152	var aggregatedReport types.Report153	if server.handleError(server.handler.AggregatedNonprimaryProcsReport(voidSender, &aggregatedReport), writer) {154		return155	}156	json.NewEncoder(writer).Encode(aggregatedReport)157}158func (server *httpServer) handleCounter(writer http.ResponseWriter, request *http.Request) {159	var n int160	if server.handleError(server.handler.Counter(voidSender, &n), writer) {161		return162	}163	json.NewEncoder(writer).Encode(ParallelIndexCounter{Index: n})164}165func (server *httpServer) handleUp(writer http.ResponseWriter, request *http.Request) {166	writer.WriteHeader(http.StatusOK)167}168func (server *httpServer) handleAbort(writer http.ResponseWriter, request *http.Request) {169	if request.Method == "GET" {170		var shouldAbort bool171		server.handler.ShouldAbort(voidSender, &shouldAbort)172		if shouldAbort {173			writer.WriteHeader(http.StatusGone)174		} else {175			writer.WriteHeader(http.StatusOK)176		}177	} else {178		server.handler.Abort(voidSender, voidReceiver)179	}180}...

1func main() {2    wg.Add(1)3    go func() {4        defer wg.Done()5        handleAbort()6    }()7    wg.Wait()8    fmt.Println("Exiting main")9}10func main() {11    wg.Add(1)12    go func() {13        defer wg.Done()14        handleAbort()15    }()16    wg.Wait()17    fmt.Println("Exiting main")18}19func main() {20    wg.Add(1)21    go func() {22        defer wg.Done()23        handleAbort()24    }()25    wg.Wait()26    fmt.Println("Exiting main")27}28func main() {29    wg.Add(1)30    go func() {31        defer wg.Done()32        handleAbort()33    }()34    wg.Wait()35    fmt.Println("Exiting main")36}37func main() {38    wg.Add(1)39    go func() {40        defer wg.Done()41        handleAbort()42    }()43    wg.Wait()44    fmt.Println("Exiting main")45}46import (47func main() {

1import (2func main() {3    abort := make(chan os.Signal, 1)4    signal.Notify(abort, syscall.SIGINT, syscall.SIGTERM)5    done := make(chan bool, 1)6    doneParallel := make(chan bool, 1)7    abortParallel := make(chan bool, 1)8    abortParallelSend := make(chan bool, 1)9    doneParallelSend := make(chan bool, 1)10    abortParallelAck := make(chan bool, 1)11    doneParallelAck := make(chan bool, 1)12    abortParallelAck2 := make(chan bool, 1)13    doneParallelAck2 := make(chan bool, 1)14    abortParallelAck3 := make(chan bool, 1)15    doneParallelAck3 := make(chan bool, 1)16    abortParallelAck4 := make(chan bool, 1)

1import (2func main() {3	fmt.Println("main() started")4	parallel_support := new(ParallelSupport)5	parallel_support.Start()6	parallel_support.handleAbort()7	fmt.Println("main() ended")8}9import (10func main() {11	fmt.Println("main() started")12	parallel_support := new(ParallelSupport)13	parallel_support.Start()14	parallel_support.handleAbort()15	fmt.Println("main() ended")16}17import (18func main() {19	fmt.Println("main() started")20	parallel_support := new(ParallelSupport)21	parallel_support.Start()22	parallel_support.handleAbort()23	fmt.Println("main() ended")24}25import (26func main() {27	fmt.Println("main() started")28	parallel_support := new(ParallelSupport)29	parallel_support.Start()30	parallel_support.handleAbort()31	fmt.Println("main() ended")32}33import (34func main() {35	fmt.Println("main() started")36	parallel_support := new(ParallelSupport)37	parallel_support.Start()38	parallel_support.handleAbort()39	fmt.Println("main() ended")40}41import (42func main() {43	fmt.Println("main() started")44	parallel_support := new(ParallelSupport)45	parallel_support.Start()46	parallel_support.handleAbort()47	fmt.Println("main() ended")48}49import (50func main() {51	fmt.Println("main() started")52	parallel_support := new(ParallelSupport)53	parallel_support.Start()54	parallel_support.handleAbort()55	fmt.Println("main() ended")56}57import (

1import (2func main() {3    p := parallel_support.NewParallelSupport()4    wg.Add(2)5    ch := make(chan int)6    go func() {7        p.HandleAbort(&wg, ch)8    }()9    go func() {10        p.HandleAbort(&wg, ch)11    }()12    close(ch)13    wg.Wait()14    fmt.Println("Done")15}