From 22913db39fd6c7bbcc37c6734f56c9a12c10c953 Mon Sep 17 00:00:00 2001 From: Jim Ma Date: Tue, 13 Aug 2024 20:59:57 +0800 Subject: [PATCH] fix: reuse length check (#3432) Signed-off-by: Jim Ma --- client/daemon/peer/peertask_reuse.go | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) diff --git a/client/daemon/peer/peertask_reuse.go b/client/daemon/peer/peertask_reuse.go index e837ba80d..3b661d337 100644 --- a/client/daemon/peer/peertask_reuse.go +++ b/client/daemon/peer/peertask_reuse.go @@ -227,8 +227,8 @@ func (ptm *peerTaskManager) storePartialFile(ctx context.Context, request *FileT return nil } -func noRangeEnd(rg string) bool { - return strings.HasSuffix(rg, "-") +func hasRangeEnd(rg string) bool { + return !strings.HasSuffix(rg, "-") } func (ptm *peerTaskManager) tryReuseStreamPeerTask(ctx context.Context, taskID string, @@ -335,7 +335,7 @@ func (ptm *peerTaskManager) tryReuseStreamPeerTask(ctx context.Context, taskID s } else if request.Range != nil { // the length is from reuse task, ensure it equal with request // skip check no range end case - if length != request.Range.Length && noRangeEnd(request.URLMeta.Range) { + if length != request.Range.Length && hasRangeEnd(request.URLMeta.Range) { log.Errorf("target task length %d did not match range length %d", length, request.Range.Length) return nil, nil, false }