Function runConstantInFlight

dev/load.go:162–200

(url string, jsonBytes []byte)

}

func runConstantInFlight(url string, jsonBytes []byte) {
	if _numRequestsPerThread > 0 {
		fmt.Printf("spawning %d threads, %d requests each, %s delay on each\n", _numConcurrent, _numRequestsPerThread, _requestDelay.String())
	} else {
		fmt.Printf("spawning %d infinite threads, %s delay on each\n", _numConcurrent, _requestDelay.String())
	}

	var summedRequestCount uint64
	var summedSuccessCount uint64
	var summedHTTPErrCount uint64
	var summedGoErrCount uint64

	start := time.Now()
	loopNum := 1
	for {
		wasKilled := runConstantInFlightIteration(url, jsonBytes, loopNum)

		summedRequestCount += _requestCount.Load()
		summedSuccessCount += _successCount.Load()
		summedHTTPErrCount += _httpErrCount.Load()
		summedGoErrCount += _goErrCount.Load()

		_requestCount.Store(0)
		_successCount.Store(0)
		_httpErrCount.Store(0)
		_goErrCount.Store(0)

		if loopNum >= _numMainLoops || wasKilled {
			break
		}
		loopNum++
	}

	if _numMainLoops > 1 {
		elapsed := time.Since(start)
		requestRate := float64(summedRequestCount) / elapsed.Seconds()
		fmt.Printf("\ntotal elapsed time: %s | %d requests @ %f req/s | %d succeeded | %d http errors | %d go errors\n", elapsed, summedRequestCount, requestRate, summedSuccessCount, summedHTTPErrCount, summedGoErrCount)
	}
}

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