From b0373910a328134cc073b15359a84f0b42dab76a Mon Sep 17 00:00:00 2001 From: Sendya <18x@loacg.com> Date: Wed, 4 Feb 2026 21:20:04 +0800 Subject: [PATCH] fix: caching middleware's partRequest getUpstreamReader range request preparation. --- server/middleware/caching/internal.go | 8 ++------ 1 file changed, 2 insertions(+), 6 deletions(-) diff --git a/server/middleware/caching/internal.go b/server/middleware/caching/internal.go index ee06639..72eb64e 100644 --- a/server/middleware/caching/internal.go +++ b/server/middleware/caching/internal.go @@ -197,10 +197,8 @@ func getContents(c *Caching, reqChunks []uint32, from uint32) (io.ReadCloser, in // Identify an anchor block and synchronize any missing blocks prior to the current index. toByte := min(c.md.Size-1, uint64(availableChunks[index]*uint32(partSize))-1) - req := c.req.Clone(context.Background()) - newRange := fmt.Sprintf("bytes=%d-%d", fromByte, toByte) - req.Header.Set("Range", newRange) + // Request is automatically cloned by getUpstreamReader reader, err := c.getUpstreamReader(fromByte, toByte, true) if err != nil { return nil, 0, err @@ -218,10 +216,8 @@ func getContents(c *Caching, reqChunks []uint32, from uint32) (io.ReadCloser, in tailChunkSize = uint64(rng.End) } toByte := min(c.md.Size-1, tailChunkSize) - newRange := fmt.Sprintf("bytes=%d-%d", fromByte, toByte) - req := c.req.Clone(context.Background()) - req.Header.Set("Range", newRange) + // Request is automatically cloned by getUpstreamReader reader, err := c.getUpstreamReader(fromByte, toByte, true) if err != nil { return nil, 0, err