From 744acdc82638ccaf480431e8fda0508ae8f5ca37 Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?=E5=90=91=E6=9E=97?= <as2252258@163.com>
Date: Fri, 17 Jun 2022 14:11:26 +0800
Subject: [PATCH] modify plugin name

---
 DatabasesProviders.php | 18 +++++++++++++++++-
 1 file changed, 17 insertions(+), 1 deletion(-)

diff --git a/DatabasesProviders.php b/DatabasesProviders.php
index bf7eea4..acb7eba 100644
--- a/DatabasesProviders.php
+++ b/DatabasesProviders.php
@@ -16,6 +16,7 @@ use Kiri\Annotation\Inject;
 use Kiri\Server\Events\OnWorkerStart;
 use Kiri\Server\Events\OnTaskerStart;
 use Psr\Log\LoggerInterface;
+use Kiri\Server\Events\OnWorkerExit;
 
 /**
  * Class DatabasesProviders
@@ -46,12 +47,26 @@ class DatabasesProviders extends Providers
 		}
 		$this->provider->on(OnWorkerStart::class, [$this, 'check']);
 		$this->provider->on(OnTaskerStart::class, [$this, 'check']);
+		$this->provider->on(OnWorkerExit::class, [$this, 'exit']);
 		foreach ($databases as $key => $database) {
 			$application->set($key, $this->_settings($database));
 		}
 	}
 
 
+	/**
+	 * @param OnWorkerExit $exit
+	 * @return void
+	 */
+	public function exit(OnWorkerExit $exit): void
+	{
+		$id = (int)Kiri\Context::getContext('db.loop.id');
+		if (!empty($id)) {
+			$exit->server->clearTimer($id);
+		}
+	}
+
+
 	/**
 	 * @param $name
 	 * @return Connection
@@ -69,7 +84,7 @@ class DatabasesProviders extends Providers
 	 */
 	public function check(OnTaskerStart|OnWorkerStart $start): void
 	{
-		$start->server->tick(50 * 1000, static function () use ($start) {
+		$timerTick = $start->server->tick(50 * 1000, static function () use ($start) {
 			$databases = Config::get('databases.connections', []);
 			$logger = Kiri::getDi()->get(LoggerInterface::class);
 			$logger->alert('db size ' . count($databases) . ' ticker ' . date('Y-m-d H:i:s'));
@@ -98,6 +113,7 @@ class DatabasesProviders extends Providers
 				$logger->alert($message);
 			}
 		});
+		Kiri\Context::setContext('db.loop.id', $timerTick);
 	}