INNER CODE UNIT · Go
base
bhope/hedge · benchmark/simulate/main.go:44
base := time.Duration(math.Exp(muLn + sigmaLn*rand.NormFloat64()))
if rand.Float64() < stragglerP {
return time.Duration(float64(base) * stragglerMul)
}
return base
}
type simResult struct {
latencies []time.Duration
overhead float64
}
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++ {