|
|
@ -61,6 +61,7 @@ func UploadReaderInChunks(ctx context.Context, reader io.Reader, opt *ChunkedUpl |
|
|
const bytesBufferCounter = 4 |
|
|
const bytesBufferCounter = 4 |
|
|
bytesBufferLimitChan := make(chan struct{}, bytesBufferCounter) |
|
|
bytesBufferLimitChan := make(chan struct{}, bytesBufferCounter) |
|
|
|
|
|
|
|
|
|
|
|
uploadLoop: |
|
|
for { |
|
|
for { |
|
|
// Throttle buffer usage
|
|
|
// Throttle buffer usage
|
|
|
bytesBufferLimitChan <- struct{}{} |
|
|
bytesBufferLimitChan <- struct{}{} |
|
|
@ -83,7 +84,7 @@ func UploadReaderInChunks(ctx context.Context, reader io.Reader, opt *ChunkedUpl |
|
|
uploadErr = ctx.Err() |
|
|
uploadErr = ctx.Err() |
|
|
} |
|
|
} |
|
|
uploadErrLock.Unlock() |
|
|
uploadErrLock.Unlock() |
|
|
break |
|
|
|
|
|
|
|
|
break uploadLoop |
|
|
default: |
|
|
default: |
|
|
} |
|
|
} |
|
|
|
|
|
|
|
|
|