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-04-08 02:25:18 +08:00
parent 3e28888417
commit 648385b64a
1 changed files with 2 additions and 10 deletions
Download Patch File Download Diff File Expand all files Collapse all files
HttpServer/Events/OnPipeMessage.php
+2 -10
View File
@@ -28,16 +28,8 @@ class OnPipeMessage extends Callback
*/ */
public function onHandler(Server $server, int $src_worker_id, $message) public function onHandler(Server $server, int $src_worker_id, $message)
{ {
if ($message instanceof Loader) { $events = Snowflake::app()->getEvent();
if ($src_worker_id > $server->setting['worker_num']) { $events->trigger(Event::PIPE_MESSAGE, [$server, $src_worker_id, $message]);
$message->loadByDirectory(MODEL_PATH);
} else {
$message->loadByDirectory(APP_PATH);
}
} else {
$events = Snowflake::app()->getEvent();
$events->trigger(Event::PIPE_MESSAGE, [$server, $src_worker_id, $message]);
}
} }
} }