This commit is contained in:
as2252258@163.com
2021-02-28 00:28:54 +08:00
parent 9887e20930
commit ddddb17c7a
+17 -15
View File
@@ -9,26 +9,28 @@ use HttpServer\Abstracts\Callback;
use Snowflake\Abstracts\Config; use Snowflake\Abstracts\Config;
use Snowflake\Event; use Snowflake\Event;
use Snowflake\Snowflake; use Snowflake\Snowflake;
use Swoole\Coroutine;
use Swoole\Server; use Swoole\Server;
class OnManagerStart extends Callback class OnManagerStart extends Callback
{ {
/** /**
* @param Server $server * @param Server $server
* @throws Exception * @throws Exception
*/ */
public function onHandler(Server $server) public function onHandler(Server $server)
{ {
$this->debug('manager start.'); $this->debug('manager start.');
Snowflake::setWorkerId($server->manager_pid); Snowflake::setWorkerId($server->manager_pid);
$events = Snowflake::app()->getEvent(); $events = Snowflake::app()->getEvent();
$events->trigger(Event::SERVER_MANAGER_START, null, $server); $events->trigger(Event::SERVER_MANAGER_START, null, $server);
if (Snowflake::isLinux()) { if (Snowflake::isLinux()) {
$prefix = Config::get('id', false, 'system:'); $prefix = Config::get('id', false, 'system:');
name($prefix . ': Server Manager.'); name($prefix . ': Server Manager.');
} }
} Coroutine::waitPid($server->manager_pid);
}
} }