改名

2021-03-01 17:48:20 +08:00
parent d6622a2b0b
commit cd1088f6ec
1 changed files with 4 additions and 3 deletions
@@ -95,10 +95,13 @@ class OnWorkerStart extends Callback
 	public function onSignal(Server $server, $worker_id): void
 	{
 		$ret = Coroutine::waitSignal($this->signal, -1);
-		Coroutine\go(function ($ret, $server, $worker_id) {
+		Coroutine\go(function ($ret, Server $server, $worker_id) {
 			if ($ret === true) {
 				$this->ticker();
 			}
+			if ($server->getWorkerStatus($worker_id) == 3) {
+				return 1;
+			}
 			return $server->stop($worker_id);
 		}, $ret, $server, $worker_id);
 	}
@@ -114,8 +117,6 @@ class OnWorkerStart extends Callback
 			return;
 		}

-		var_dump(__METHOD__);
-
 		sleep(1);

 		$this->ticker();