Function BenchmarkRateLimiter

worker/proposal_test.go:108–136

(b *testing.B)

}

func BenchmarkRateLimiter(b *testing.B) {
	ious := []int{256}
	retries := []int{3}
	var failed, success uint64

	for _, iou := range ious {
		for _, retry := range retries {
			b.Run(fmt.Sprintf("IOU:%d-Retry:%d", iou, retry), func(b *testing.B) {
				l := &rateLimiter{c: sync.NewCond(&sync.Mutex{}), max: iou}
				go l.bleed()

				// var success, failed uint64
				b.RunParallel(func(pb *testing.PB) {
					r := rand.New(rand.NewSource(time.Now().UnixNano()))
					for pb.Next() {
						if err := proposeAndWaitEmulator(l, r, retry, false); err != nil {
							atomic.AddUint64(&failed, 1)
						} else {
							atomic.AddUint64(&success, 1)
						}
					}
				})

				fmt.Println("IOU:", iou, "Max Retries:", retry, "Success:",
					success, "Failed:", failed)
			})
		}
	}
}