Close body on fail

Fangliding · Fangliding · commit 6ea2497fbc78 · 2026-05-08T13:39:42.000+08:00
diff --git a/transport/internet/splithttp/client.go b/transport/internet/splithttp/client.go
@@ -71,6 +71,7 @@ func (c *DefaultDialerClient) OpenStream(ctx context.Context, url string, sessio
 				errors.LogInfoInner(ctx, err, "failed to "+method+" "+url)
 			}
 			gotConn.Close()
+			common.Close(body)
 			wrc.Close()
 			return
 		}
@@ -80,6 +81,7 @@ func (c *DefaultDialerClient) OpenStream(ctx context.Context, url string, sessio
 		if resp.StatusCode != 200 || uploadOnly { // stream-up
 			io.Copy(io.Discard, resp.Body)
 			resp.Body.Close() // if it is called immediately, the upload will be interrupted also
+			gotConn.Close()
 			wrc.Close()
 			return
 		}

Original file line number	Diff line number	Diff line change
`@@ -71,6 +71,7 @@ func (c *DefaultDialerClient) OpenStream(ctx context.Context, url string, sessio`
`71`	`71`	`errors.LogInfoInner(ctx, err, "failed to "+method+" "+url)`
`72`	`72`	`}`
`73`	`73`	`gotConn.Close()`
	`74`	`+ common.Close(body)`
`74`	`75`	`wrc.Close()`
`75`	`76`	`return`
`76`	`77`	`}`
`@@ -80,6 +81,7 @@ func (c *DefaultDialerClient) OpenStream(ctx context.Context, url string, sessio`
`80`	`81`	`if resp.StatusCode != 200 \|\| uploadOnly { // stream-up`
`81`	`82`	`io.Copy(io.Discard, resp.Body)`
`82`	`83`	`resp.Body.Close() // if it is called immediately, the upload will be interrupted also`
	`84`	`+ gotConn.Close()`
`83`	`85`	`wrc.Close()`
`84`	`86`	`return`
`85`	`87`	`}`