Merge pull request #414 from qiniu/fix/resume-upload-fail-fast

fix resume upload can not fail fast when init upload id failed

Author: bachue

CHANGELOG.md

@@ -3,6 +3,7 @@
 ## 7.10.0 (2023-06-20)
 * 对象存储，新增请求中间件逻辑，方便拓展请求逻辑
 * 对象存储，新增备用 UC 域名用于查询区域域名
+* 对象存储，修复分片上传初始化失败无法快速失败
 
 ## 7.9.0 (2023-03-31)
 * 对象存储，修复无法对 key 为空字符串的对象进行操作

src/Qiniu/Storage/ResumeUploader.php

@@ -283,8 +283,10 @@ private function uploadV2($fname, $blkputRets = null)
         $uploaded = 0;
         $partNumber = 1;
         $encodedObjectName = $this->key ? \Qiniu\base64_urlSafeEncode($this->key) : '~';
-
         $isResumeUpload = $blkputRets !== null;
+
+        // 初始化 upload id
+        $err = null;
         if ($blkputRets) {
             if (isset($blkputRets["etags"]) && isset($blkputRets["uploadId"]) &&
                 isset($blkputRets["expiredAt"]) && $blkputRets["expiredAt"] > time() &&
@@ -298,12 +300,16 @@ private function uploadV2($fname, $blkputRets = null)
                 $uploaded = $blkputRets["uploaded"];
                 $partNumber = count($this->finishedEtags["etags"]) + 1;
             } else {
-                $this->makeInitReq($encodedObjectName);
+                $err = $this->makeInitReq($encodedObjectName);
             }
         } else {
-            $this->makeInitReq($encodedObjectName);
+            $err = $this->makeInitReq($encodedObjectName);
+        }
+        if ($err != null) {
+            return array(null, $err);
         }
 
+        // 上传分片
         fseek($this->inputStream, $uploaded);
         while ($uploaded < $this->size) {
             $blockSize = $this->blockSize($uploaded);
@@ -452,9 +458,15 @@ private function blockSize($uploaded)
 
     private function makeInitReq($encodedObjectName)
     {
-        $res = $this->initReq($encodedObjectName);
-        $this->finishedEtags["uploadId"] = $res['uploadId'];
-        $this->finishedEtags["expiredAt"] = $res['expireAt'];
+        list($ret, $err) = $this->initReq($encodedObjectName);
+
+        if ($ret == null) {
+            return $err;
+        }
+
+        $this->finishedEtags["uploadId"] = $ret['uploadId'];
+        $this->finishedEtags["expiredAt"] = $ret['expireAt'];
+        return $err;
     }
 
     /**
@@ -468,7 +480,12 @@ private function initReq($encodedObjectName)
             'Content-Type' => 'application/json'
         );
         $response = $this->postWithHeaders($url, null, $headers);
-        return $response->json();
+        $ret = $response->json();
+        if ($response->ok() && $ret != null) {
+            return array($ret, null);
+        }
+
+        return array(null, new Error($url, $response));
     }
 
     /**