From 3f27f5c9438e23af78a94c6f6c5bb83353505176 Mon Sep 17 00:00:00 2001 From: speatzle Date: Sat, 31 May 2025 22:13:03 +0000 Subject: [PATCH] Update worker/worker.go Cleanup Websocket connections to prevent FD leak --- worker/worker.go | 2 ++ 1 file changed, 2 insertions(+) diff --git a/worker/worker.go b/worker/worker.go index 9c2c594..ab4621f 100644 --- a/worker/worker.go +++ b/worker/worker.go @@ -89,6 +89,8 @@ func connectToServer(ctx context.Context, uuid uuid.UUID) { c, res, err := websocket.Dial(ctx, conf.Worker.Address+"/worker", &websocket.DialOptions{ HTTPHeader: headers, }) + defer c.CloseNow() + if err != nil { if res != nil { b, _ := io.ReadAll(res.Body)