Keep trying

local_cache/cache_api.go

@@ -102,6 +102,7 @@ func (lc *LocalCache) LaunchListener(ctx context.Context, egrp *errgroup.Group)
 			if headerTimeout > 0 {
 				var cancelReqFunc context.CancelFunc
 				ctx, cancelReqFunc = context.WithTimeout(ctx, headerTimeout)
+				ctx = context.WithValue(ctx, contextNameKey, "localCacheHeaderTimeout")
 				defer cancelReqFunc()
 			}
 			reader, err = lc.Get(ctx, path, bearerToken)

local_cache/cache_test.go

@@ -376,7 +376,7 @@ func TestLargeFile(t *testing.T) {
 
 	clientConfig := map[string]interface{}{
 		"Client.MaximumDownloadSpeed":     40 * 1024 * 1024,
-		"Transport.ResponseHeaderTimeout": "1000s",
+		"Transport.ResponseHeaderTimeout": "100s",
 	}
 	test_utils.InitClient(t, clientConfig)
 	ft := fed_test_utils.NewFedTest(t, pubOriginCfg)

local_cache/local_cache.go

@@ -48,6 +48,10 @@ import (
 	"github.com/pelicanplatform/pelican/utils"
 )
 
+type contextKey string
+
+const contextNameKey contextKey = "contextName"
+
 type (
 	LocalCache struct {
 		ctx           context.Context
@@ -864,6 +868,19 @@ func (cr *cacheReader) readRaw(ctx context.Context, p []byte) (n int, err error)
 		}
 		select {
 		case <-cr.sc.ctx.Done():
+
+			contextName, ok := cr.sc.ctx.Value(contextNameKey).(string)
+			if !ok {
+				contextName = "unknown"
+			}
+
+			fields := log.Fields{
+				"component":   "local_cache",
+				"contextName": contextName,
+				"error":       cr.sc.ctx.Err().Error(),
+			}
+			log.WithFields(fields).Debugf("\n\n\nLocal cache header timeout hit\n\n\n")
+
 			return 0, cr.sc.ctx.Err()
 		case availSize, ok := <-cr.status:
 			cr.status = nil