Function runConstantInFlightIteration

dev/load.go:202–244

(url string, jsonBytes []byte, loopNum int)

}

func runConstantInFlightIteration(url string, jsonBytes []byte, loopNum int) bool {
	start := time.Now()

	wasKilled := false
	killed := make(chan bool)
	c := make(chan os.Signal, 1)
	signal.Notify(c, os.Interrupt, syscall.SIGTERM)
	go func() {
		<-c
		killed <- true
	}()

	doneChans := make([]chan struct{}, _numConcurrent)
	for i := range doneChans {
		doneChans[i] = make(chan struct{})
	}

	for i := range doneChans {
		doneChan := doneChans[i]

		go func() {
			makeRequestLoop(url, jsonBytes)
			doneChan <- struct{}{}
		}()
	}

LOOP:
	for _, doneChan := range doneChans {
		select {
		case <-killed:
			wasKilled = true
			break LOOP
		case <-doneChan:
			continue
		}
	}

	elapsed := time.Now().Sub(start)
	requestRate := float64(_requestCount.Load()) / elapsed.Seconds()
	fmt.Printf("\nelapsed time: %s | %d requests @ %f req/s | %d succeeded | %d http errors | %d go errors\n", elapsed, _requestCount.Load(), requestRate, _successCount.Load(), _httpErrCount.Load(), _goErrCount.Load())

	return wasKilled
}

func makeRequestLoop(url string, jsonBytes []byte) {
	var i int