modify
This commit is contained in:
@@ -29,6 +29,7 @@ class OnPipeMessage extends Callback
|
|||||||
public function onHandler(Server $server, int $src_worker_id, $message)
|
public function onHandler(Server $server, int $src_worker_id, $message)
|
||||||
{
|
{
|
||||||
// TODO: Implement onHandler() method.
|
// TODO: Implement onHandler() method.
|
||||||
|
var_dump($message);
|
||||||
if (is_array($message) && ($message[1] ?? null) instanceof Loader) {
|
if (is_array($message) && ($message[1] ?? null) instanceof Loader) {
|
||||||
if ($src_worker_id > $server->setting['worker_num']) {
|
if ($src_worker_id > $server->setting['worker_num']) {
|
||||||
$message[1]->loadByDirectory(MODEL_PATH);
|
$message[1]->loadByDirectory(MODEL_PATH);
|
||||||
|
|||||||
Reference in New Issue
Block a user