From fdbf891fad0e848173b555b87c1b6402adbfdedd Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?=E5=90=91=E6=9E=97?= Date: Fri, 31 Mar 2023 10:37:15 +0800 Subject: [PATCH] =?UTF-8?q?=E5=8F=98=E6=9B=B4?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- kiri-engine/Pool/Connection.php | 12 +++++++----- 1 file changed, 7 insertions(+), 5 deletions(-) diff --git a/kiri-engine/Pool/Connection.php b/kiri-engine/Pool/Connection.php index 5784b9da..23efb45f 100644 --- a/kiri-engine/Pool/Connection.php +++ b/kiri-engine/Pool/Connection.php @@ -100,12 +100,14 @@ class Connection extends Component if (!$this->pool->hasChannel($name)) { $this->pool->initConnections($name, $config['pool']['max']); } - - return $this->pool->get($name, $this->generate($config)); - if (!Context::hasContext($name)) { - return Context::setContext($name, $this->pool->get($name, $this->generate($config))); + if ($isMaster) { + if (!Context::hasContext($name)) { + return Context::setContext($name, $this->pool->get($name, $this->generate($config))); + } else { + return Context::getContext($name); + } } else { - return Context::getContext($name); + return $this->pool->get($name, $this->generate($config)); } }