fix(upstream-http): Properly close http body to fix goroutine leak.

2026-07-13 16:49:20 +08:00
parent 1fe56435af
commit 3266983024
1 changed files with 2 additions and 1 deletions
@@ -134,7 +134,8 @@ func upstreamFiber(name string) {
 					continue
 				}
 				if r.StatusCode != 200 {
-					fmt.Fprintf(os.Stderr, "Request to %s for stream %s failed with status code %d\n", upstreams[name], name, err)
+					fmt.Fprintf(os.Stderr, "Request to %s for stream %s failed with status code %d\n", upstreams[name], name, r.StatusCode)
+					r.Body.Close()
 					time.Sleep(5 * time.Second)
 					continue
 				}