fix(buffer): Set correct buffer boundaries

OrlandoCo · OrlandoCo · commit e17042627cd1 · 2021-01-06T13:43:37.000-06:00
diff --git a/pkg/buffer/bucket.go b/pkg/buffer/bucket.go
@@ -45,7 +45,7 @@ func (b *Bucket) addPacket(pkt []byte, sn uint16, latest bool) []byte {
 		if b.nacker != nil {
 			b.nacker.push(sn - i)
 		}
-		if b.step > b.maxSteps {
+		if b.step >= b.maxSteps {
 			b.step = 0
 		}
 	}
@@ -79,7 +79,7 @@ func (b *Bucket) push(pkt []byte) []byte {
 	off := b.step*maxPktSize + 2
 	copy(b.buf[off:], pkt)
 	b.step++
-	if b.step > b.maxSteps {
+	if b.step >= b.maxSteps {
 		b.step = 0
 	}
 	return b.buf[off : off+len(pkt)]

Original file line number	Diff line number	Diff line change
`@@ -45,7 +45,7 @@ func (b *Bucket) addPacket(pkt []byte, sn uint16, latest bool) []byte {`
`45`	`45`	`if b.nacker != nil {`
`46`	`46`	`b.nacker.push(sn - i)`
`47`	`47`	`}`
`48`		`- if b.step > b.maxSteps {`
	`48`	`+ if b.step >= b.maxSteps {`
`49`	`49`	`b.step = 0`
`50`	`50`	`}`
`51`	`51`	`}`
`@@ -79,7 +79,7 @@ func (b *Bucket) push(pkt []byte) []byte {`
`79`	`79`	`off := b.step*maxPktSize + 2`
`80`	`80`	`copy(b.buf[off:], pkt)`
`81`	`81`	`b.step++`
`82`		`- if b.step > b.maxSteps {`
	`82`	`+ if b.step >= b.maxSteps {`
`83`	`83`	`b.step = 0`
`84`	`84`	`}`
`85`	`85`	`return b.buf[off : off+len(pkt)]`