This commit is contained in:
2021-07-12 17:22:57 +08:00
parent 857ec53870
commit a7dfb571eb
2 changed files with 7 additions and 10 deletions
-3
View File
@@ -27,9 +27,6 @@ class OnConnect extends Callback
{ {
try { try {
defer(fn() => fire(Event::SYSTEM_RESOURCE_RELEASES)); defer(fn() => fire(Event::SYSTEM_RESOURCE_RELEASES));
var_dump($fd.' On Connect');
if (($clientInfo = $server->getClientInfo($fd, $reactorId)) === false) { if (($clientInfo = $server->getClientInfo($fd, $reactorId)) === false) {
return; return;
} }
+7 -7
View File
@@ -53,7 +53,7 @@ trait Server
{ {
$this->on('Shutdown', $this->createHandler('shutdown')); $this->on('Shutdown', $this->createHandler('shutdown'));
$this->on('Start', $this->createHandler('start')); $this->on('Start', $this->createHandler('start'));
if ($this->setting['task_worker_num'] ?? 0 > 0) { if (($this->setting['task_worker_num'] ?? 0) > 0) {
$this->on('Finish', $this->createHandler('finish')); $this->on('Finish', $this->createHandler('finish'));
$this->on('Task', $this->createHandler('task')); $this->on('Task', $this->createHandler('task'));
} }
@@ -62,8 +62,8 @@ trait Server
/** /**
* @throws \ReflectionException * @throws ReflectionException
* @throws \Snowflake\Exception\NotFindClassException * @throws NotFindClassException
*/ */
private function onManager() private function onManager()
{ {
@@ -76,8 +76,8 @@ trait Server
/** /**
* @throws \ReflectionException * @throws ReflectionException
* @throws \Snowflake\Exception\NotFindClassException * @throws NotFindClassException
*/ */
private function onWorker() private function onWorker()
{ {
@@ -89,8 +89,8 @@ trait Server
/** /**
* @throws \ReflectionException * @throws ReflectionException
* @throws \Snowflake\Exception\NotFindClassException * @throws NotFindClassException
*/ */
private function onOther() private function onOther()
{ {