改名

HttpServer/Abstracts/Callback.php

@@ -33,8 +33,6 @@ abstract class Callback extends HttpService
 	protected function clear($server, $worker_id, $message)
 	{
 		try {
-			Timer::clearAll();
-
 			fire(Event::SYSTEM_RESOURCE_CLEAN);
 
 			\logger()->insert();
@@ -52,7 +50,6 @@ abstract class Callback extends HttpService
 	}
 
 
-
 	const EVENT_ERROR = 'WORKER:ERROR';
 	const EVENT_STOP = 'WORKER:STOP';
 	const EVENT_EXIT = 'WORKER:EXIT';

HttpServer/Events/OnWorkerError.php

@@ -7,7 +7,9 @@ namespace HttpServer\Events;
 use Exception;
 use HttpServer\Abstracts\Callback;
 use Snowflake\Abstracts\Config;
+use Snowflake\Event;
 use Snowflake\Exception\ConfigException;
+use Snowflake\Snowflake;
 use Swoole\Coroutine;
 use Swoole\Server;
 
@@ -28,6 +30,10 @@ class OnWorkerError extends Callback
 	 */
 	public function onHandler(Server $server, int $worker_id, int $worker_pid, int $exit_code, int $signal)
 	{
+		$event = Snowflake::app()->getEvent();
+		$event->trigger(Event::SERVER_WORKER_ERROR);
+		$event->offName(Event::SERVER_WORKER_ERROR);
+
 		$this->clear($server, $worker_id, self::EVENT_ERROR);
 		if (!Config::has('email')) {
 			return;

HttpServer/Events/OnWorkerExit.php

@@ -6,6 +6,8 @@ namespace HttpServer\Events;
 
 use Exception;
 use HttpServer\Abstracts\Callback;
+use Snowflake\Event;
+use Snowflake\Snowflake;
 
 /**
  * Class OnWorkerExit
@@ -21,6 +23,10 @@ class OnWorkerExit extends Callback
 	 */
 	public function onHandler($server, $worker_id)
 	{
+		$event = Snowflake::app()->getEvent();
+		$event->trigger(Event::SERVER_WORKER_EXIT);
+		$event->offName(Event::SERVER_WORKER_EXIT);
+
 		$this->clear($server, $worker_id, self::EVENT_EXIT);
 	}
 

HttpServer/Events/OnWorkerStart.php

@@ -13,6 +13,7 @@ use Snowflake\Exception\ConfigException;
 use Snowflake\Snowflake;
 use Swoole\Coroutine;
 use Swoole\Server;
+use Swoole\Timer;
 
 /**
  * Class OnWorkerStart
@@ -26,7 +27,6 @@ class OnWorkerStart extends Callback
 	private int $signal = SIGUSR1 | SIGKILL | SIGKILL;
 
 
-
 	/**
 	 * @param Server $server
 	 * @param int $worker_id
@@ -44,9 +44,7 @@ class OnWorkerStart extends Callback
 		} else {
 			$this->onWorker($server, $worker_id);
 		}
-
 		$this->debug(sprintf('%s #%d Pid:%d start.', ucfirst(env('environmental')), $worker_id, $server->worker_pid));
-//		Coroutine\go([$this, 'onSignal'], $server, $worker_id);
 	}
 
 
@@ -85,7 +83,6 @@ class OnWorkerStart extends Callback
 	}
 
 
-
 	/**
 	 * @param $server
 	 * @param $worker_id

HttpServer/Events/OnWorkerStop.php

@@ -6,6 +6,8 @@ namespace HttpServer\Events;
 
 use Exception;
 use HttpServer\Abstracts\Callback;
+use Snowflake\Event;
+use Snowflake\Snowflake;
 
 /**
  * Class OnWorkerStop
@@ -22,6 +24,10 @@ class OnWorkerStop extends Callback
 	 */
 	public function onHandler($server, $worker_id)
 	{
+		$event = Snowflake::app()->getEvent();
+		$event->trigger(Event::SERVER_WORKER_STOP);
+		$event->offName(Event::SERVER_WORKER_STOP);
+
 		$this->clear($server, $worker_id, self::EVENT_STOP);
 	}
 

System/Abstracts/Pool.php

@@ -9,6 +9,7 @@ use Exception;
 use HttpServer\Http\Context;
 use JetBrains\PhpStorm\Pure;
 use Phalcon\Mvc\Model\Query\Lang;
+use Snowflake\Event;
 use Snowflake\Exception\ComponentException;
 use Snowflake\Exception\ConfigException;
 use Snowflake\Snowflake;
@@ -145,11 +146,18 @@ abstract class Pool extends Component
 	/**
 	 * @param $name
 	 * @param mixed $callback
+	 * @throws ComponentException
+	 * @throws Exception
 	 */
 	private function createByCallback($name, mixed $callback)
 	{
 		if ($this->creates === -1 && !is_callable($callback)) {
 			$this->creates = Timer::tick(1000, [$this, 'Heartbeat_detection']);
+
+			$event = Snowflake::app()->getEvent();
+			$event->on(Event::SERVER_WORKER_STOP, function () {
+				Timer::clear($this->creates);
+			});
 		}
 		if (!Context::hasContext('create::client::ing::' . $name)) {
 			$this->push($name, $this->createClient($name, $callback));