From 40bf2d018635a691f7f5db533ad2fd83e3658340 Mon Sep 17 00:00:00 2001 From: Mathis Engelbart Date: Tue, 2 Jun 2026 11:07:21 +0200 Subject: [PATCH] Remove burst factor and add min burst size --- pkg/pacing/interceptor.go | 2 +- pkg/pacing/interceptor_test.go | 2 +- 2 files changed, 2 insertions(+), 2 deletions(-) diff --git a/pkg/pacing/interceptor.go b/pkg/pacing/interceptor.go index 25bc9ec5..210f6d88 100644 --- a/pkg/pacing/interceptor.go +++ b/pkg/pacing/interceptor.go @@ -182,7 +182,7 @@ func burst(rate int, interval time.Duration) int { } f := float64(time.Second.Milliseconds() / interval.Milliseconds()) - return 8 * int(float64(rate)/f) + return max(8*1500, int(float64(rate)/f)) } // setRate updates the pacing rate and burst of the rate limiter. diff --git a/pkg/pacing/interceptor_test.go b/pkg/pacing/interceptor_test.go index e8bb0f07..27f4958f 100644 --- a/pkg/pacing/interceptor_test.go +++ b/pkg/pacing/interceptor_test.go @@ -70,7 +70,7 @@ func TestInterceptor(t *testing.T) { i.SetRate("", 1_000_000) assert.Equal(t, 1_000_000, mp.rate) - assert.Equal(t, 40_000, mp.burst) + assert.Equal(t, 12000, mp.burst) }) t.Run("paces_packets", func(t *testing.T) {