as2252258/kiri-core
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases 2 Wiki Activity

改名

Browse Source
This commit is contained in:
Mr·x
2020-09-11 01:26:36 +08:00
parent 9df3b56ec0
commit 00d64ec73d
1 changed files with 0 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files
System/Pool/Redis.php
-3
View File
@@ -40,7 +40,6 @@ class Redis extends Pool
if (Context::hasContext($coroutineName)) { if (Context::hasContext($coroutineName)) {
return Context::getContext($coroutineName); return Context::getContext($coroutineName);
} else if (!$this->hasItem($coroutineName)) { } else if (!$this->hasItem($coroutineName)) {
$this->success('create redis client -> ' . $config['host'] . ':' . $this->size($coroutineName));
return $this->saveClient($coroutineName, $this->createConnect($config)); return $this->saveClient($coroutineName, $this->createConnect($config));
} }
return $this->getByChannel($coroutineName, $config); return $this->getByChannel($coroutineName, $config);
@@ -55,9 +54,7 @@ class Redis extends Pool
*/ */
public function getByChannel($coroutineName, $config) public function getByChannel($coroutineName, $config)
{ {
$this->info('redis client has :' . $this->size($coroutineName));
if (!$this->hasItem($coroutineName)) { if (!$this->hasItem($coroutineName)) {
$this->success('create redis client -> ' . $config['host'] . ':' . $this->size($coroutineName));
return $this->saveClient($coroutineName, $this->createConnect($config)); return $this->saveClient($coroutineName, $this->createConnect($config));
} }
[$time, $client] = $this->get($coroutineName); [$time, $client] = $this->get($coroutineName);