Add more parameterized test cases

Author: mengelbart

bwe_test.go

@@ -67,7 +67,14 @@ func TestMain(m *testing.M) {
 
 func TestBWE(t *testing.T) {
 	networks := map[string]vnetFactory{
-		"constant_capacity": createVirtualNetwork(),
+		"constant_capacity_1mbps_very_low_latency": createVirtualNetwork(1_000_000, 80_000, 50*time.Millisecond),
+		"constant_capacity_5mbps_very_low_latency": createVirtualNetwork(5_000_000, 80_000, 50*time.Millisecond),
+		"constant_capacity_1mbps_low_latency":      createVirtualNetwork(1_000_000, 80_000, 50*time.Millisecond),
+		"constant_capacity_5mbps_low_latency":      createVirtualNetwork(5_000_000, 80_000, 50*time.Millisecond),
+		"constant_capacity_1mbps_medium_latency":   createVirtualNetwork(1_000_000, 80_000, 150*time.Millisecond),
+		"constant_capacity_5mbps_medium_latency":   createVirtualNetwork(5_000_000, 80_000, 150*time.Millisecond),
+		"constant_capacity_1mbps_high_latency":     createVirtualNetwork(1_000_000, 80_000, 300*time.Millisecond),
+		"constant_capacity_5mbps_high_latency":     createVirtualNetwork(5_000_000, 80_000, 300*time.Millisecond),
 	}
 	for name, vnf := range networks {
 		t.Run(name, func(t *testing.T) {
@@ -86,7 +93,6 @@ func TestBWE(t *testing.T) {
 				receiver, err := newPeer(
 					registerDefaultCodecs(),
 					setVNet(network.left, []string{"10.0.1.1"}),
-					registerTWCC(),
 					onRemoteTrack(func(track *webrtc.TrackRemote) {
 						close(onTrack)
 						go func() {
@@ -152,7 +158,7 @@ func TestBWE(t *testing.T) {
 
 				select {
 				case <-onTrack:
-				case <-time.After(time.Second):
+				case <-time.After(5 * time.Second):
 					assert.Fail(t, "on track not called")
 				}
 

peer_test.go

@@ -122,7 +122,7 @@ func registerCCFB() option {
 
 func initGCC(onRateUpdate func(int)) option {
 	return func(p *peer) (err error) {
-		p.estimator, err = gcc.NewSendSideController(1_000_000, 128_000, 5_000_000)
+		p.estimator, err = gcc.NewSendSideController(1_000_000, 128_000, 50_000_000)
 		if err != nil {
 			return err
 		}

virtual_network_test.go

@@ -36,7 +36,7 @@ func (n *virtualNetwork) Close() error {
 	)
 }
 
-func createVirtualNetwork() func(*testing.T) *virtualNetwork {
+func createVirtualNetwork(rate, burst int, delay time.Duration) func(*testing.T) *virtualNetwork {
 	return func(t *testing.T) *virtualNetwork {
 		t.Helper()
 
@@ -58,10 +58,14 @@ func createVirtualNetwork() func(*testing.T) *virtualNetwork {
 		})
 		assert.NoError(t, err)
 
-		leftTBF, err := vnet.NewTokenBucketFilter(leftRouter, vnet.TBFRate(1_000_000), vnet.TBFMaxBurst(80_000))
+		leftTBF, err := vnet.NewTokenBucketFilter(
+			leftRouter,
+			vnet.TBFRate(rate),
+			vnet.TBFMaxBurst(burst),
+		)
 		assert.NoError(t, err)
 
-		leftDelay, err := vnet.NewDelayFilter(leftTBF, 10*time.Millisecond)
+		leftDelay, err := vnet.NewDelayFilter(leftTBF, delay)
 		assert.NoError(t, err)
 
 		err = wan.AddNet(leftDelay)
@@ -82,10 +86,14 @@ func createVirtualNetwork() func(*testing.T) *virtualNetwork {
 		})
 		assert.NoError(t, err)
 
-		rightTBF, err := vnet.NewTokenBucketFilter(rightRouter, vnet.TBFRate(1_000_000), vnet.TBFMaxBurst(80_000))
+		rightTBF, err := vnet.NewTokenBucketFilter(
+			rightRouter,
+			vnet.TBFRate(rate),
+			vnet.TBFMaxBurst(burst),
+		)
 		assert.NoError(t, err)
 
-		rightDelay, err := vnet.NewDelayFilter(rightTBF, 10*time.Millisecond)
+		rightDelay, err := vnet.NewDelayFilter(rightTBF, delay)
 		assert.NoError(t, err)
 
 		err = wan.AddNet(rightDelay)