Just a checkpoint. All of this still WIP.

scionproto · Nov 29, 2024 · 1443c95 · 1443c95
1 parent 3c8e30f
commit 1443c95
Show file tree

Hide file tree

Showing 5 changed files with 354 additions and 154 deletions.
diff --git a/router/cmd/router/main.go b/router/cmd/router/main.go
@@ -61,6 +61,11 @@ func realMain(ctx context.Context) error {
 		DataPlane: router.DataPlane{
 			Metrics:                        metrics,
 			ExperimentalSCMPAuthentication: globalCfg.Features.ExperimentalSCMPAuthentication,
+			RunConfig: router.RunConfig{
+				NumProcessors:         globalCfg.Router.NumProcessors,
+				NumSlowPathProcessors: globalCfg.Router.NumSlowPathProcessors,
+				BatchSize:             globalCfg.Router.BatchSize,
+			},
 		},
 		ReceiveBufferSize:   globalCfg.Router.ReceiveBufferSize,
 		SendBufferSize:      globalCfg.Router.SendBufferSize,
@@ -128,12 +133,7 @@ func realMain(ctx context.Context) error {
 	})
 	g.Go(func() error {
 		defer log.HandlePanic()
-		runConfig := &router.RunConfig{
-			NumProcessors:         globalCfg.Router.NumProcessors,
-			NumSlowPathProcessors: globalCfg.Router.NumSlowPathProcessors,
-			BatchSize:             globalCfg.Router.BatchSize,
-		}
-		if err := dp.DataPlane.Run(errCtx, runConfig); err != nil {
+		if err := dp.DataPlane.Run(errCtx); err != nil {
 			return serrors.Wrap("running dataplane", err)
 		}
 		return nil