as2252258/kiri-core
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases 2 Wiki Activity

modify

Browse Source
This commit is contained in:
as2252258@163.com
2021-02-27 04:09:30 +08:00
parent 99215107dd
commit 3e48e811fb
1 changed files with 3 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files
HttpServer/Events/OnWorkerStart.php
+3 -5
View File
@@ -40,6 +40,9 @@ class OnWorkerStart extends Callback
Coroutine\go(function () use ($server, $worker_id) { Coroutine\go(function () use ($server, $worker_id) {
$this->onTaskSignal($server, $worker_id); $this->onTaskSignal($server, $worker_id);
}); });
Coroutine\go(function () use ($server) {
var_dump(Coroutine::waitPid($server->worker_pid));
});
$get_name = $this->get_process_name($server, $worker_id); $get_name = $this->get_process_name($server, $worker_id);
if (!empty($get_name) && !Snowflake::isMac()) { if (!empty($get_name) && !Snowflake::isMac()) {
@@ -75,11 +78,6 @@ class OnWorkerStart extends Callback
Coroutine::sleep(0.01); Coroutine::sleep(0.01);
} while (true); } while (true);
} }
go(function () use ($server) {
var_dump(__LINE__);
var_dump(Coroutine::waitPid($server->worker_pid));
});
$server->stop($workerId);; $server->stop($workerId);;
} catch (\Throwable $exception) { } catch (\Throwable $exception) {
$this->addError($exception); $this->addError($exception);