Merge pull request #568 from sakuraovq/master

igr close connection error
swoft-cloud · Apr 12, 2020 · 7aac80d · 7aac80d
2 parents 52cf587 + 0b3b7bd
commit 7aac80d
Showing 1 changed file with 12 additions and 3 deletions.
diff --git a/src/connection-pool/src/AbstractPool.php b/src/connection-pool/src/AbstractPool.php
@@ -164,7 +164,12 @@ public function close(): int
                 continue;
             }
 
-            $connection->close();
+            try {
+                // May be disconnected
+                $connection->close();
+            } catch (Throwable $e) {
+                CLog::warning('Pool close connection error ' . $e->getMessage());
+            }
         }
 
         return $this->count;
@@ -275,8 +280,12 @@ private function popByChannel(): ?ConnectionInterface
             // Out of `maxIdleTime`
             if ($time - $lastTime > $this->maxIdleTime) {
 
-                // Fix expired connection not released
-                $connection->close();
+                try {
+                    // Fix expired connection not released, May be disconnected
+                    $connection->close();
+                } catch (Throwable $e) {
+                    CLog::warning('popByChannel close connection error ' . $e->getMessage());
+                }
 
                 $this->count--;
                 continue;