From 132d1b29fe57474faada2f64f598f63415ce6fc3 Mon Sep 17 00:00:00 2001 From: Gaius Date: Mon, 30 Oct 2023 10:49:53 +0800 Subject: [PATCH] feat: print headers with debug log (#2834) Signed-off-by: Gaius --- scheduler/job/job.go | 17 ++++------------- 1 file changed, 4 insertions(+), 13 deletions(-) diff --git a/scheduler/job/job.go b/scheduler/job/job.go index 8daf7b529..74dc2e41a 100644 --- a/scheduler/job/job.go +++ b/scheduler/job/job.go @@ -185,8 +185,10 @@ func (j *job) preheat(ctx context.Context, req string) error { // Trigger seed peer download seeds. taskID := idgen.TaskIDV1(preheat.URL, urlMeta) log := logger.WithTask(taskID, preheat.URL) - log.Infof("preheat %s headers: %#v, tag: %s, range: %s, filter: %s, digest: %s", - preheat.URL, filterHeaders(urlMeta.Header, log.IsDebug()), urlMeta.Tag, urlMeta.Range, urlMeta.Filter, urlMeta.Digest) + log.Infof("preheat %s tag: %s, range: %s, filter: %s, digest: %s", + preheat.URL, urlMeta.Tag, urlMeta.Range, urlMeta.Filter, urlMeta.Digest) + log.Debugf("preheat %s headers: %#v", preheat.URL, urlMeta.Header) + stream, err := j.resource.SeedPeer().Client().ObtainSeeds(ctx, &cdnsystemv1.SeedRequest{ TaskId: taskID, Url: preheat.URL, @@ -227,14 +229,3 @@ func (j *job) syncPeers() (string, error) { return internaljob.MarshalResponse(hosts) } - -// filterHeaders filters Authorization header if debugging is not enabled -func filterHeaders(urlHeader map[string]string, isDebug bool) map[string]string { - filteredHeaders := make(map[string]string) - for k, v := range urlHeader { - if isDebug || k != headers.Authorization { - filteredHeaders[k] = v - } - } - return filteredHeaders -}