fix(buffer): Set correct buffer boundaries

ionorg · Jan 6, 2021 · e170426 · e170426
1 parent 7ae23ae
commit e170426
Showing 1 changed file with 2 additions and 2 deletions.
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)]