diff --git a/weed/operation/upload_chunked.go b/weed/operation/upload_chunked.go index ad62a0874..034f558ce 100644 --- a/weed/operation/upload_chunked.go +++ b/weed/operation/upload_chunked.go @@ -61,6 +61,7 @@ func UploadReaderInChunks(ctx context.Context, reader io.Reader, opt *ChunkedUpl const bytesBufferCounter = 4 bytesBufferLimitChan := make(chan struct{}, bytesBufferCounter) +uploadLoop: for { // Throttle buffer usage bytesBufferLimitChan <- struct{}{} @@ -83,7 +84,7 @@ func UploadReaderInChunks(ctx context.Context, reader io.Reader, opt *ChunkedUpl uploadErr = ctx.Err() } uploadErrLock.Unlock() - break + break uploadLoop default: }