feature: Add option to skip certain interfaces for multicast

Author: g3force

cmd/ssl-game-controller/main.go

@@ -9,13 +9,15 @@ import (
 	"net/http"
 	"os"
 	"os/signal"
+	"strings"
 	"syscall"
 )
 
 var address = flag.String("address", "localhost:8081", "The address on which the UI and API is served")
 var visionAddress = flag.String("visionAddress", "", "The address (ip+port) from which vision packages are received")
 var publishAddress = flag.String("publishAddress", "", "The address (ip+port) to which referee command should be sent")
 var timeAcquisitionMode = flag.String("timeAcquisitionMode", "", "The time acquisitionMode to use (system, ci, vision)")
+var skipInterfaces = flag.String("skipInterfaces", "", "Comma separated list of interface names to ignore when receiving multicast packets")
 
 const configFileName = "config/ssl-game-controller.yaml"
 
@@ -43,6 +45,9 @@ func setupGameController() {
 	if timeAcquisitionMode != nil && *timeAcquisitionMode != "" {
 		cfg.TimeAcquisitionMode = config.TimeAcquisitionMode(*timeAcquisitionMode)
 	}
+	if skipInterfaces != nil && *skipInterfaces != "" {
+		cfg.Network.SkipInterfaces = parseSkipInterfaces()
+	}
 
 	gameController := gc.NewGameController(cfg)
 	gameController.Start()
@@ -68,3 +73,7 @@ func setupUi() {
 		log.Print("Backend-only version started. Run the UI separately or get a binary that has the UI included")
 	}
 }
+
+func parseSkipInterfaces() []string {
+	return strings.Split(*skipInterfaces, ",")
+}

config/ssl-game-controller.yaml

@@ -3,6 +3,7 @@ network:
   publish-address: 224.5.23.1:10003
   vision-address: 224.5.23.2:10006
   tracker-address: 224.5.23.2:10010
+  skip-interfaces: []
 server:
   auto-ref:
     address: :10007

internal/app/config/config.go

@@ -65,9 +65,10 @@ type Game struct {
 
 // Network holds configs for network communication
 type Network struct {
-	PublishAddress string `yaml:"publish-address"`
-	VisionAddress  string `yaml:"vision-address"`
-	TrackerAddress string `yaml:"tracker-address"`
+	PublishAddress string   `yaml:"publish-address"`
+	VisionAddress  string   `yaml:"vision-address"`
+	TrackerAddress string   `yaml:"tracker-address"`
+	SkipInterfaces []string `yaml:"skip-interfaces"`
 }
 
 // Server holds configs for the available server services
@@ -167,6 +168,7 @@ func DefaultControllerConfig() (c Controller) {
 	c.Network.PublishAddress = "224.5.23.1:10003"
 	c.Network.VisionAddress = "224.5.23.2:10006"
 	c.Network.TrackerAddress = "224.5.23.2:10010"
+	c.Network.SkipInterfaces = []string{}
 	c.Game.StateStoreFile = "state-store.json.stream"
 	c.Game.YellowCardDuration = 2 * time.Minute
 	c.Game.YellowCardBotRemovalTime = 10 * time.Second

internal/app/config/testdata/config.yaml

@@ -3,6 +3,7 @@ network:
   publish-address: 224.5.23.1:10003
   vision-address: 224.5.23.2:10006
   tracker-address: 224.5.23.2:10010
+  skip-interfaces: []
 server:
   auto-ref:
     address: :10007

internal/app/gc/gc.go

@@ -49,8 +49,10 @@ func NewGameController(cfg config.Controller) (c *GameController) {
 	c.ciServer = ci.NewServer(cfg.Server.Ci.Address)
 	c.visionReceiver = vision.NewReceiver(cfg.Network.VisionAddress)
 	c.visionReceiver.GeometryCallback = c.gcEngine.ProcessGeometry
+	c.visionReceiver.MulticastReceiver.SkipInterfaces = cfg.Network.SkipInterfaces
 	c.trackerReceiver = tracker.NewReceiver(cfg.Network.TrackerAddress)
 	c.trackerReceiver.Callback = c.gcEngine.ProcessTrackerFrame
+	c.trackerReceiver.MulticastReceiver.SkipInterfaces = cfg.Network.SkipInterfaces
 	return
 }