fix >= check for SNA

pion · Apr 3, 2024 · c57fa56 · c57fa56
1 parent ab755db
commit c57fa56
Showing 1 changed file with 3 additions and 3 deletions.
diff --git a/received_chunk_tracker.go b/received_chunk_tracker.go
@@ -10,7 +10,7 @@ import (
 
 // receivedChunkTracker tracks received chunks for maintaining ACK ranges
 type receivedChunkTracker struct {
-	tsns map[uint32]struct{}
+	tsns   map[uint32]struct{}
 	dupTSN []uint32
 	ranges []ackRange
 }
@@ -72,7 +72,7 @@ func (q *receivedChunkTracker) push(tsn uint32, cumulativeTSN uint32) bool {
 	} else {
 		// extended element at pos, check if we can merge it with adjacent elements
 		if pos-1 >= 0 {
-			if q.ranges[pos-1].end+1 >= q.ranges[pos].start {
+			if q.ranges[pos-1].end+1 == q.ranges[pos].start {
 				q.ranges[pos-1] = ackRange{
 					start: q.ranges[pos-1].start,
 					end:   q.ranges[pos].end,
@@ -85,7 +85,7 @@ func (q *receivedChunkTracker) push(tsn uint32, cumulativeTSN uint32) bool {
 			}
 		}
 		if pos+1 < len(q.ranges) {
-			if q.ranges[pos].end+1 >= q.ranges[pos+1].start {
+			if q.ranges[pos].end+1 == q.ranges[pos+1].start {
 				q.ranges[pos+1] = ackRange{
 					start: q.ranges[pos].start,
 					end:   q.ranges[pos+1].end,