diff options
Diffstat (limited to 'weed/filer/filechunk_manifest.go')
| -rw-r--r-- | weed/filer/filechunk_manifest.go | 6 |
1 files changed, 3 insertions, 3 deletions
diff --git a/weed/filer/filechunk_manifest.go b/weed/filer/filechunk_manifest.go index 00e9a73a1..884be591e 100644 --- a/weed/filer/filechunk_manifest.go +++ b/weed/filer/filechunk_manifest.go @@ -106,7 +106,7 @@ func ResolveOneChunkManifest(ctx context.Context, lookupFileIdFn wdclient.Lookup func fetchWholeChunk(ctx context.Context, bytesBuffer *bytes.Buffer, lookupFileIdFn wdclient.LookupFileIdFunctionType, fileId string, cipherKey []byte, isGzipped bool) error { urlStrings, err := lookupFileIdFn(ctx, fileId) if err != nil { - glog.Errorf("operation LookupFileId %s failed, err: %v", fileId, err) + glog.ErrorfCtx(ctx, "operation LookupFileId %s failed, err: %v", fileId, err) return err } err = retriedStreamFetchChunkData(ctx, bytesBuffer, urlStrings, "", cipherKey, isGzipped, true, 0, 0) @@ -159,7 +159,7 @@ func retriedStreamFetchChunkData(ctx context.Context, writer io.Writer, urlStrin break } if err != nil { - glog.V(0).Infof("read %s failed, err: %v", urlString, err) + glog.V(0).InfofCtx(ctx, "read %s failed, err: %v", urlString, err) } else { break } @@ -169,7 +169,7 @@ func retriedStreamFetchChunkData(ctx context.Context, writer io.Writer, urlStrin break } if err != nil && shouldRetry { - glog.V(0).Infof("retry reading in %v", waitTime) + glog.V(0).InfofCtx(ctx, "retry reading in %v", waitTime) time.Sleep(waitTime) } else { break |