diff --git a/pkg/nack/generator_interceptor.go b/pkg/nack/generator_interceptor.go index 58d720fa..d5f65b5b 100644 --- a/pkg/nack/generator_interceptor.go +++ b/pkg/nack/generator_interceptor.go @@ -18,7 +18,7 @@ type GeneratorInterceptorFactory struct { // NewInterceptor constructs a new ReceiverInterceptor func (g *GeneratorInterceptorFactory) NewInterceptor(id string) (interceptor.Interceptor, error) { i := &GeneratorInterceptor{ - size: 8192, + size: 512, skipLastN: 0, interval: time.Millisecond * 100, receiveLogs: map[uint32]*receiveLog{}, diff --git a/pkg/nack/receive_log_test.go b/pkg/nack/receive_log_test.go index 75e5e274..78992b48 100644 --- a/pkg/nack/receive_log_test.go +++ b/pkg/nack/receive_log_test.go @@ -8,8 +8,6 @@ import ( func TestReceivedBuffer(t *testing.T) { for _, start := range []uint16{0, 1, 127, 128, 129, 511, 512, 513, 32767, 32768, 32769, 65407, 65408, 65409, 65534, 65535} { - start := start - t.Run(fmt.Sprintf("StartFrom%d", start), func(t *testing.T) { rl, err := newReceiveLog(128) if err != nil {