Skip to content

Commit

Permalink
Reduce NACK buffer size to 512
Browse files Browse the repository at this point in the history
  • Loading branch information
boks1971 authored and Sean-Der committed Nov 22, 2021
1 parent e2d57d5 commit d75d7da
Show file tree
Hide file tree
Showing 2 changed files with 1 addition and 3 deletions.
2 changes: 1 addition & 1 deletion pkg/nack/generator_interceptor.go
Original file line number Diff line number Diff line change
Expand Up @@ -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{},
Expand Down
2 changes: 0 additions & 2 deletions pkg/nack/receive_log_test.go
Original file line number Diff line number Diff line change
Expand Up @@ -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 {
Expand Down

0 comments on commit d75d7da

Please sign in to comment.