Skip to content

Commit 80146eb

Browse files
authored
Merge pull request #206 from tencentyun/dev/checkPointUpload
original content mark
2 parents 11ca5ea + ee5a1cb commit 80146eb

File tree

1 file changed

+7
-11
lines changed

1 file changed

+7
-11
lines changed

src/main/java/com/qcloud/cos/http/DefaultCosHttpClient.java

Lines changed: 7 additions & 11 deletions
Original file line numberDiff line numberDiff line change
@@ -496,17 +496,13 @@ public <X, Y extends CosServiceRequest> X exeute(CosHttpRequest<Y> request,
496496
while (true) {
497497
try {
498498
checkInterrupted();
499-
/**
500-
* 目前sdk所有的上传请求都会把流包装成ReleasableInputStream
501-
* 所以这里不再需要判断BufferedInputStream的子类了
502-
* */
503-
// if (originalContent instanceof BufferedInputStream
504-
// && originalContent.markSupported()) {
505-
// // Mark everytime for BufferedInputStream, since the marker could have been
506-
// // invalidated
507-
// final int readLimit = clientConfig.getReadLimit();
508-
// originalContent.mark(readLimit);
509-
// }
499+
if (originalContent instanceof BufferedInputStream
500+
&& originalContent.markSupported()) {
501+
// Mark everytime for BufferedInputStream, since the marker could have been
502+
// invalidated
503+
final int readLimit = clientConfig.getReadLimit();
504+
originalContent.mark(readLimit);
505+
}
510506
// 如果是重试的则恢复流
511507
if (retryIndex != 0 && originalContent != null) {
512508
originalContent.reset();

0 commit comments

Comments
 (0)