amphp/sql
1
0
Fork 0
Code Issues Pull Requests Releases Wiki Activity

Fail pending deferred if pool closed

Browse Source
This commit is contained in:
Aaron Piotrowski 2018-09-26 12:27:31 -05:00
parent 480e90cba8
commit 79e9b849ad
No known key found for this signature in database
GPG Key ID: ADD1EF783EDE9EEB
1 changed files with 6 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
src/AbstractPool.php
View File

@ -197,8 +197,13 @@ abstract class AbstractPool implements Pool
$connection->close(); $connection->close();
} }
$this->idle = new \SplQueue; $this->idle = new \SplQueue;
$this->connections = new \SplObjectStorage;
$this->prepare = null; $this->prepare = null;
if ($this->deferred instanceof Deferred) {
$deferred = $this->deferred;
$this->deferred = null;
$deferred->fail(new FailureException("Connection pool closed"));
}
} }
/** /**