From f6ff84181e9858a0f28a03d9b75faf8b6258d939 Mon Sep 17 00:00:00 2001 From: Darren Dowker Date: Wed, 5 Jun 2024 11:24:43 -0700 Subject: [PATCH] name cleanup --- broker/client/reader.go | 8 ++++---- 1 file changed, 4 insertions(+), 4 deletions(-) diff --git a/broker/client/reader.go b/broker/client/reader.go index 5c197195..7e9231e5 100644 --- a/broker/client/reader.go +++ b/broker/client/reader.go @@ -171,15 +171,15 @@ func (r *Reader) Read(p []byte) (n int, err error) { // If the frame preceding EOF provided a fragment URL, open it directly. if !r.Request.MetadataOnly && r.Response.Status == pb.Status_OK && r.Response.FragmentUrl != "" { if TransformSignedURLs { - var url *url.URL - if url, err = url.Parse(r.Response.FragmentUrl); err != nil { + var fragURL *url.URL + if fragURL, err = url.Parse(r.Response.FragmentUrl); err != nil { return 0, err } - if url.Scheme != "gs" { + if fragURL.Scheme != "gs" { return 0, fmt.Error("TransformSignedURLs is only supported for GCS") } - if r.direct, err = gcs.OpenWithOffset(r.ctx, r.Response.FragmentUrl, + if r.direct, err = gcs.OpenWithOffset(r.ctx, fragURL, *r.Response.Fragment, r.Request.Offset); err == nil { n, err = r.Read(p) // Recurse to attempt read against opened |r.direct|. }