From 9d8e830e4e3159a10a3a4fe01b21279e71911ad0 Mon Sep 17 00:00:00 2001 From: JackDoan Date: Fri, 31 Jul 2026 12:38:53 -0500 Subject: [PATCH] disallow listen.batch < 1 --- main.go | 8 +++++++- 1 file changed, 7 insertions(+), 1 deletion(-) diff --git a/main.go b/main.go index f03028c5..4947008d 100644 --- a/main.go +++ b/main.go @@ -165,7 +165,13 @@ func Main(c *config.C, configTest bool, buildVersion string, l *slog.Logger, dev for i := 0; i < routines; i++ { l.Info("listening", "addr", netip.AddrPortFrom(listenHost, uint16(port))) - udpServer, err := udp.NewListener(l, listenHost, port, routines > 1, c.GetInt("listen.batch", 64)) + batchSize := c.GetInt("listen.batch", 64) + if batchSize < 1 { + oldBatch := batchSize + batchSize = 1 + l.Warn("listen.batch size is invalid", "provided", oldBatch, "overridden to", batchSize) + } + udpServer, err := udp.NewListener(l, listenHost, port, routines > 1, batchSize) if err != nil { return nil, util.NewContextualError("Failed to open udp listener", m{"queue": i}, err) }