host query add error param

Author: rwifeng

src/Qiniu/Storage/FormUploader.php

@@ -49,7 +49,11 @@ public static function put(
             }
         }
 
-        $upHost = $config->zone->getUpHostByToken($upToken);
+        list($upHost, $err) = $config->zone->getUpHostByToken($upToken);
+        if ($err != null) {
+            return array(null, $err);
+        }
+
         $response = Client::multipartPost($upHost, $fields, 'file', $fname, $data, $mime);
         if (!$response->ok()) {
             return array(null, new Error($upHost, $response));
@@ -99,7 +103,11 @@ public static function putFile(
         $fields['key'] = $key;
         $headers =array('Content-Type' => 'multipart/form-data');
 
-        $upHost = $config->zone->getUpHostByToken($upToken);
+        list($upHost, $err) = $config->zone->getUpHostByToken($upToken);
+        if ($err != null) {
+            return array(null, $err);
+        }
+        
         $response = client::post($upHost, $fields, $headers);
         if (!$response->ok()) {
             return array(null, new Error($upHost, $response));

src/Qiniu/Storage/ResumeUploader.php

@@ -54,7 +54,12 @@ public function __construct(
         $this->mime = $mime;
         $this->contexts = array();
         $this->config = $config;
-        $this->host = $config->zone->getUpHostByToken($upToken);
+
+        list($upHost, $err) = $config->zone->getUpHostByToken($upToken);
+        if ($err != null) {
+            throw new \Exception($err, 1);
+        }
+        $this->host = $upHost;
     }
 
     /**
@@ -76,7 +81,11 @@ public function upload()
                 $ret = $response->json();
             }
             if ($response->statusCode < 0) {
-                $this->host = $this->config->zone->getBackupUpHostByToken($this->upToken);
+                list($bakHost, $err) = $this->config->zone->getBackupUpHostByToken($this->upToken);
+                if ($err != null) {
+                    return array(null, $err);
+                }
+                $this->host = $bakHost;
             }
             if ($response->needRetry() || !isset($ret['crc32']) || $crc != $ret['crc32']) {
                 $response = $this->makeBlock($data, $blockSize);

src/Qiniu/Zone.php

@@ -28,17 +28,19 @@ public function __construct($scheme = null)
     public function getUpHostByToken($uptoken)
     {
         list($ak, $bucket) = $this->unmarshalUpToken($uptoken);
-        list($upHosts,) = $this->getUpHosts($ak, $bucket);
-        return $upHosts[0];
+        // sssssssssssssssssssssssssss
+        list($upHosts, $err) = $this->getUpHosts($ak, $bucket);
+        return array($upHosts[0], $err);
     }
 
     public function getBackupUpHostByToken($uptoken)
     {
         list($ak, $bucket) = $this->unmarshalUpToken($uptoken);
-        list($upHosts,) = $this->getUpHosts($ak, $bucket);
+        // sssssssssssssssssssssssssss
+        list($upHosts, $err) = $this->getUpHosts($ak, $bucket);
 
         $upHost = isset($upHosts[1]) ? $upHosts[1] : $upHosts[0];
-        return $upHost;
+        return array($upHost, $err);
     }
 
     public function getIoHost($ak, $bucket)

tests/Qiniu/Tests/ZoneTest.php

@@ -58,21 +58,25 @@ public function testUpHostByToken()
         3RzIjpbImh0dHA6XC9cL3VwLXoxLnFpbml1LmNvbSIsImh0dHA6XC9cL3VwbG9hZC16MS5xaW5p
         dS5jb20iLCItSCB1cC16MS5xaW5pdS5jb20gaHR0cDpcL1wvMTA2LjM4LjIyNy4yNyJdfQ==';
 
-        $upHost = $this->zone->getUpHostByToken($uptoken_bc);
+        list($upHost, $err) = $this->zone->getUpHostByToken($uptoken_bc);
         $this->assertEquals('http://up-z1.qiniu.com', $upHost);
+        $this->assertEquals(null, $err);
 
-        $upHostBackup = $this->zone->getBackupUpHostByToken($uptoken_bc);
+        list($upHostBackup, $err) = $this->zone->getBackupUpHostByToken($uptoken_bc);
         $this->assertEquals('http://upload-z1.qiniu.com', $upHostBackup);
+        $this->assertEquals(null, $err);
 
 
         $uptoken_bc_https = 'QWYn5TFQsLLU1pL5MFEmX3s5DmHdUThav9WyOWOm:7I47O-vFcN5TKO
         6D7cobHPVkyIA=:eyJzY29wZSI6InBocHNkay1iYyIsImRlYWRsaW5lIjoxNDcwNzIyNzQ1LCJ1c
         Ehvc3RzIjpbImh0dHBzOlwvXC91cC16MS5xYm94Lm1lIl19';
-        $upHost = $this->zoneHttps->getUpHostByToken($uptoken_bc_https);
+        list($upHost, $err) = $this->zoneHttps->getUpHostByToken($uptoken_bc_https);
         $this->assertEquals('https://up-z1.qbox.me', $upHost);
+        $this->assertEquals(null, $err);
 
-        $upHostBackup = $this->zoneHttps->getBackupUpHostByToken($uptoken_bc_https);
+        list($upHostBackup, $err) = $this->zoneHttps->getBackupUpHostByToken($uptoken_bc_https);
         $this->assertEquals('https://up-z1.qbox.me', $upHostBackup);
+        $this->assertEquals(null, $err);
     }
 
     public function testIoHosts()