Added flag to set max-pending-msg per client (defaults to 25)

Author: cmaglie

main.go

@@ -45,12 +45,13 @@ var Version string = "0.0.0-dev"
 
 // Server configuration
 type Config struct {
-	LogLevel        slog.Level
-	ListenTCPAddr   string
-	ListenUnixAddr  string
-	SerialPortAddr  string
-	SerialBaudRate  int
-	MonitorPortAddr string
+	LogLevel                    slog.Level
+	ListenTCPAddr               string
+	ListenUnixAddr              string
+	SerialPortAddr              string
+	SerialBaudRate              int
+	MonitorPortAddr             string
+	MaxPendingRequestsPerClient int
 }
 
 func main() {
@@ -80,7 +81,7 @@ func main() {
 	cmd.Flags().StringVarP(&cfg.SerialPortAddr, "serial-port", "p", "", "Serial port address")
 	cmd.Flags().IntVarP(&cfg.SerialBaudRate, "serial-baudrate", "b", 115200, "Serial port baud rate")
 	cmd.Flags().StringVarP(&cfg.MonitorPortAddr, "monitor-port", "m", "127.0.0.1:7500", "Listening port for MCU monitor proxy")
-
+	cmd.Flags().IntVarP(&cfg.MaxPendingRequestsPerClient, "max-pending-requests", "", 25, "Maximum number of pending requests per client connection")
 	cmd.AddCommand(&cobra.Command{
 		Use:  "version",
 		Long: "Print version information",
@@ -155,7 +156,7 @@ func startRouter(cfg Config) error {
 	}
 
 	// Run router
-	router := msgpackrouter.New(0)
+	router := msgpackrouter.New(cfg.MaxPendingRequestsPerClient)
 
 	// Register TCP network API methods
 	networkapi.Register(router)