modify
This commit is contained in:
@@ -39,13 +39,15 @@ class OnWorkerStart extends Callback
|
|||||||
|
|
||||||
name($server->worker_pid, $worker_id >= $server->setting['worker_num'] ? 'task' : 'worker');
|
name($server->worker_pid, $worker_id >= $server->setting['worker_num'] ? 'task' : 'worker');
|
||||||
|
|
||||||
/** @var ServerInotify $inotify */
|
/** @var Loader $runtime */
|
||||||
$inotify = Snowflake::app()->get(ServerInotify::class);
|
$runtime = unserialize(file_get_contents(storage('runtime.php')));
|
||||||
$inotify->write(sprintf('%03d', $worker_id));
|
|
||||||
|
|
||||||
if ($worker_id >= $server->setting['worker_num']) {
|
if ($worker_id >= $server->setting['worker_num']) {
|
||||||
|
$runtime->loadByDirectory(MODEL_PATH);
|
||||||
|
|
||||||
$this->onTask($server, $worker_id);
|
$this->onTask($server, $worker_id);
|
||||||
} else {
|
} else {
|
||||||
|
$runtime->loadByDirectory(APP_PATH);
|
||||||
|
|
||||||
$this->onWorker($server, $worker_id);
|
$this->onWorker($server, $worker_id);
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|||||||
Reference in New Issue
Block a user