WIP: Use synctest

Author: mengelbart

go.mod

@@ -1,6 +1,6 @@
 module github.com/pion/bwe-test
 
-go 1.21
+go 1.25
 
 toolchain go1.25.1
 

vnet/main.go

@@ -204,7 +204,7 @@ func (r *Runner) runVariableAvailableCapacitySingleFlow() error {
 		},
 	}
 	r.runNetworkSimulation(path, nm)
-
+	nm.Close()
 	return nil
 }
 

vnet/manager.go

@@ -44,6 +44,7 @@ func (r *RouterWithConfig) getIPMapping() (private, public string, err error) {
 
 // NetworkManager manages the virtual network topology for bandwidth estimation tests.
 type NetworkManager struct {
+	wan         *vnet.Router
 	leftRouter  *RouterWithConfig
 	leftTBF     *vnet.TokenBucketFilter
 	rightRouter *RouterWithConfig
@@ -94,6 +95,7 @@ func NewManager() (*NetworkManager, error) {
 	}
 
 	manager := &NetworkManager{
+		wan:         wan,
 		leftRouter:  leftRouter,
 		leftTBF:     leftTBF,
 		rightRouter: rightRouter,
@@ -107,6 +109,15 @@ func NewManager() (*NetworkManager, error) {
 	return manager, nil
 }
 
+func (m *NetworkManager) Close() error {
+	m.wan.Stop()
+	m.leftRouter.Stop()
+	m.rightRouter.Stop()
+	m.leftTBF.Close()
+	m.rightTBF.Close()
+	return nil
+}
+
 // GetLeftNet creates and returns a new Net on the left side of the network topology.
 func (m *NetworkManager) GetLeftNet() (*vnet.Net, string, error) {
 	privateIP, publicIP, err := m.leftRouter.getIPMapping()

vnet/vnet_test.go

@@ -0,0 +1,29 @@
+// SPDX-FileCopyrightText: 2025 The Pion community <https://pion.ly>
+// SPDX-License-Identifier: MIT
+
+package main
+
+import (
+	"testing"
+	"testing/synctest"
+
+	"github.com/pion/logging"
+	"github.com/stretchr/testify/assert"
+)
+
+func TestVnet(t *testing.T) {
+	synctest.Test(t, func(t *testing.T) {
+		lf := logging.NewDefaultLoggerFactory()
+		logger := lf.NewLogger("bwe_vnet_synctest")
+		runner := Runner{
+			loggerFactory: lf,
+			logger:        logger,
+			name:          "VariableAvailableCapacitySingleFlow",
+			senderMode:    abrSenderMode,
+			flowMode:      singleFlowMode,
+		}
+		err := runner.Run()
+		assert.NoError(t, err)
+		synctest.Wait()
+	})
+}