INNER CODE UNIT · Go

runSim

bhope/hedge · benchmark/simulate/main.go:56

func runSim(transport http.RoundTripper, serverHits *atomic.Int64, url string) simResult {
	before := serverHits.Load()

	latencies := make([]time.Duration, numRequests)
	work := make(chan int, numRequests)
	for i := 0; i < numRequests; i++ {
		work <- i
	}
	close(work)

	var wg sync.WaitGroup
	wg.Add(concurrency)
	for w := 0; w < concurrency; w++ {
		go func() {
			defer wg.Done()
			for i := range work {
				start := time.Now()
				req, _ := http.NewRequest("GET", url, nil)

View source record →