* * For the full copyright and license information, please view the LICENSE * file that was distributed with this source code. */ namespace Predis\Pipeline; use Predis\ServerException; use Predis\Connection\ConnectionInterface; use Predis\Connection\ReplicationConnectionInterface; /** * Implements the standard pipeline executor strategy used * to write a list of commands and read their replies over * a connection to Redis. * * @author Daniele Alessandri */ class StandardExecutor implements PipelineExecutorInterface { /** * Allows the pipeline executor to perform operations on the * connection before starting to execute the commands stored * in the pipeline. * * @param ConnectionInterface Connection instance. */ protected function checkConnection(ConnectionInterface $connection) { if ($connection instanceof ReplicationConnectionInterface) { $connection->switchTo('master'); } } /** * {@inheritdoc} */ public function execute(ConnectionInterface $connection, &$commands) { $sizeofPipe = count($commands); $values = array(); $this->checkConnection($connection); foreach ($commands as $command) { $connection->writeCommand($command); } try { for ($i = 0; $i < $sizeofPipe; $i++) { $response = $connection->readResponse($commands[$i]); $values[] = $response instanceof \Iterator ? iterator_to_array($response) : $response; unset($commands[$i]); } } catch (ServerException $exception) { // Force disconnection to prevent protocol desynchronization. $connection->disconnect(); throw $exception; } return $values; } }