vendor/elasticsearch/elasticsearch/src/Elasticsearch/ConnectionPool/StaticNoPingConnectionPool.php line 47

Open in your IDE?
  1. <?php
  2. /**
  3.  * Elasticsearch PHP client
  4.  *
  5.  * @link      https://github.com/elastic/elasticsearch-php/
  6.  * @copyright Copyright (c) Elasticsearch B.V (https://www.elastic.co)
  7.  * @license   http://www.apache.org/licenses/LICENSE-2.0 Apache License, Version 2.0
  8.  * @license   https://www.gnu.org/licenses/lgpl-2.1.html GNU Lesser General Public License, Version 2.1
  9.  *
  10.  * Licensed to Elasticsearch B.V under one or more agreements.
  11.  * Elasticsearch B.V licenses this file to you under the Apache 2.0 License or
  12.  * the GNU Lesser General Public License, Version 2.1, at your option.
  13.  * See the LICENSE file in the project root for more information.
  14.  */
  17. declare(strict_types = 1);
  19. namespace Elasticsearch\ConnectionPool;
  21. use Elasticsearch\Common\Exceptions\NoNodesAvailableException;
  22. use Elasticsearch\ConnectionPool\Selectors\SelectorInterface;
  23. use Elasticsearch\Connections\Connection;
  24. use Elasticsearch\Connections\ConnectionInterface;
  25. use Elasticsearch\Connections\ConnectionFactoryInterface;
  27. class StaticNoPingConnectionPool extends AbstractConnectionPool implements ConnectionPoolInterface
  28. {
  29.     /**
  30.      * @var int
  31.      */
  32.     private $pingTimeout    = 60;
  34.     /**
  35.      * @var int
  36.      */
  37.     private $maxPingTimeout = 3600;
  39.     /**
  40.      * {@inheritdoc}
  41.      */
  42.     public function __construct($connections, SelectorInterface $selector, ConnectionFactoryInterface $factory, $connectionPoolParams)
  43.     {
  44.         parent::__construct($connections, $selector, $factory, $connectionPoolParams);
  45.     }
  47.     public function nextConnection(bool $force = false): ConnectionInterface
  48.     {
  49.         $total = count($this->connections);
  50.         while ($total--) {
  51.             /**
  52.  * @var Connection $connection
  53. */
  54.             $connection = $this->selector->select($this->connections);
  55.             if ($connection->isAlive() === true) {
  56.                 return $connection;
  57.             }
  59.             if ($this->readyToRevive($connection) === true) {
  60.                 return $connection;
  61.             }
  62.         }
  64.         throw new NoNodesAvailableException("No alive nodes found in your cluster");
  65.     }
  67.     public function scheduleCheck(): void
  68.     {
  69.     }
  71.     private function readyToRevive(Connection $connection): bool
  72.     {
  73.         $timeout = min(
  74.             $this->pingTimeout * pow(2, $connection->getPingFailures()),
  75.             $this->maxPingTimeout
  76.         );
  78.         if ($connection->getLastPing() + $timeout < time()) {
  79.             return true;
  80.         } else {
  81.             return false;
  82.         }
  83.     }
  84. }