add test

pion · Nov 24, 2024 · 06a4ff4 · 06a4ff4
1 parent 75f2dab
commit 06a4ff4
Showing 1 changed file with 60 additions and 0 deletions.
diff --git a/pkg/gcc/arrival_group_accumulator_test.go b/pkg/gcc/arrival_group_accumulator_test.go
@@ -156,6 +156,66 @@ func TestArrivalGroupAccumulator(t *testing.T) {
 				},
 			},
 		},
+		{
+			name: "newGroupBecauseOfInterDepartureTime",
+			log: []cc.Acknowledgment{
+				{
+					SequenceNumber: 0,
+					Departure:      time.Time{},
+					Arrival:        time.Time{}.Add(4 * time.Millisecond),
+				},
+				{
+					SequenceNumber: 1,
+					Departure:      time.Time{}.Add(3 * time.Millisecond),
+					Arrival:        time.Time{}.Add(4 * time.Millisecond),
+				},
+				{
+					SequenceNumber: 2,
+					Departure:      time.Time{}.Add(6 * time.Millisecond),
+					Arrival:        time.Time{}.Add(10 * time.Millisecond),
+				},
+				{
+					SequenceNumber: 3,
+					Departure:      time.Time{}.Add(9 * time.Millisecond),
+					Arrival:        time.Time{}.Add(10 * time.Millisecond),
+				},
+				triggerNewGroupElement,
+			},
+			exp: []arrivalGroup{
+				{
+					packets: []cc.Acknowledgment{
+						{
+							SequenceNumber: 0,
+							Departure:      time.Time{},
+							Arrival:        time.Time{}.Add(4 * time.Millisecond),
+						},
+						{
+							SequenceNumber: 1,
+							Departure:      time.Time{}.Add(3 * time.Millisecond),
+							Arrival:        time.Time{}.Add(4 * time.Millisecond),
+						},
+					},
+					departure: time.Time{},
+					arrival:   time.Time{}.Add(4 * time.Millisecond),
+				},
+				{
+					packets: []cc.Acknowledgment{
+						{
+							SequenceNumber: 2,
+							Departure:      time.Time{}.Add(6 * time.Millisecond),
+							Arrival:        time.Time{}.Add(10 * time.Millisecond),
+						},
+						{
+							SequenceNumber: 3,
+							Departure:      time.Time{}.Add(9 * time.Millisecond),
+							Arrival:        time.Time{}.Add(10 * time.Millisecond),
+						},
+					},
+					departure: time.Time{}.Add(6 * time.Millisecond),
+					arrival:   time.Time{}.Add(10 * time.Millisecond),
+				},
+			},
+		},
 	}
 
 	for _, tc := range cases {