danog/postgres
1
0
Fork 0
mirror of https://github.com/danog/postgres.git synced 2024-11-30 04:29:12 +01:00
Code Issues Projects Releases Wiki Activity

Fix pool connection waiting at max connections

Browse Source
This commit is contained in:
Aaron Piotrowski 2017-12-15 11:08:02 -06:00
parent d979278204
commit b644e8cc7f
No known key found for this signature in database
GPG Key ID: ADD1EF783EDE9EEB
1 changed files with 17 additions and 10 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

27
lib/AbstractPool.php
View File

@ -106,19 +106,26 @@ abstract class AbstractPool implements Pool {
}
while ($this->idle->isEmpty()) { // While loop to ensure an idle connection is available after promises below are resolved.
try {
if ($this->connections->count() + $this->pending >= $this->getMaxConnections()) {
// All possible connections busy, so wait until one becomes available.
if ($this->connections->count() + $this->pending >= $this->getMaxConnections()) {
// All possible connections busy, so wait until one becomes available.
try {
$this->deferred = new Deferred;
yield $this->promise = $this->deferred->promise(); // May be resolved with defunct connection.
} else {
// Max connection count has not been reached, so open another connection.
$this->promise = $this->createConnection();
$this->addConnection(yield $this->promise);
} finally {
$this->deferred = null;
$this->promise = null;
}
} finally {
$this->deferred = null;
$this->promise = null;
} else {
// Max connection count has not been reached, so open another connection.
++$this->pending;
try {
$connection = yield $this->createConnection();
} finally {
--$this->pending;
}
$this->connections->attach($connection);
return $connection;
}
}