🐛 主控返回空节点导致报错

Mxmilu666 · Mxmilu666 · commit 431dc289affe · 2024-04-20T21:57:18.000+08:00
diff --git a/inc/cluster.php b/inc/cluster.php
@@ -133,6 +133,7 @@ private function downloader(Swoole\Coroutine\Http\Client $client, $file,$bar) {
             mlog("Error connecting to the main control:{$client->errMsg}",2);
             return false;
         } else {
+            if(isset($client->getHeaders()['location'])){
             $location_url = parse_url($client->getHeaders()['location']);
             $client->close();
             $client = new Swoole\Coroutine\Http\Client($location_url['host'], $location_url['port'], true);
@@ -189,6 +190,11 @@ private function downloader(Swoole\Coroutine\Http\Client $client, $file,$bar) {
                 }
             }
         }
+        else{
+            $bar->progress();
+            return false;
+        }
+        }
     }
 
     public function downloadFiles() {

Original file line number	Diff line number	Diff line change
`@@ -133,6 +133,7 @@ private function downloader(Swoole\Coroutine\Http\Client $client, $file,$bar) {`
`133`	`133`	`mlog("Error connecting to the main control:{$client->errMsg}",2);`
`134`	`134`	`return false;`
`135`	`135`	`} else {`
	`136`	`+ if(isset($client->getHeaders()['location'])){`
`136`	`137`	`$location_url = parse_url($client->getHeaders()['location']);`
`137`	`138`	`$client->close();`
`138`	`139`	`$client = new Swoole\Coroutine\Http\Client($location_url['host'], $location_url['port'], true);`
`@@ -189,6 +190,11 @@ private function downloader(Swoole\Coroutine\Http\Client $client, $file,$bar) {`
`189`	`190`	`}`
`190`	`191`	`}`
`191`	`192`	`}`
	`193`	`+ else{`
	`194`	`+ $bar->progress();`
	`195`	`+ return false;`
	`196`	`+ }`
	`197`	`+ }`
`192`	`198`	`}`
`193`	`199`
`194`	`200`	`public function downloadFiles() {`