mirror of
https://github.com/predis/predis.git
synced 2026-10-10 22:07:31 +00:00
Daniele Alessandri
fb2d8a37c1
Supporting this feature has been problematic and leaded to some ugly code to make abstractions such as pipelines and transactions aware of these kind of response objects. Furthermore, it was not possible to add them to all the connection classes due to implementation limits. For such reasons Predis do not support them globally anymore, but the actual classes are still shipped within the library so that they can be used to build custom stuff at a level lower than client (that is, unless we decide to remove them for good before going stable).
57 lines
1.5 KiB
PHP
57 lines
1.5 KiB
PHP
<?php
|
|
|
|
/*
|
|
* This file is part of the Predis package.
|
|
*
|
|
* (c) Daniele Alessandri <suppakilla@gmail.com>
|
|
*
|
|
* For the full copyright and license information, please view the LICENSE
|
|
* file that was distributed with this source code.
|
|
*/
|
|
|
|
namespace Predis\Pipeline;
|
|
|
|
use SplQueue;
|
|
use Predis\CommunicationException;
|
|
use Predis\Connection\ConnectionInterface;
|
|
|
|
/**
|
|
* Implements a pipeline executor strategy that does not fail when an error is
|
|
* encountered, but adds the returned error in the replies array.
|
|
*
|
|
* @author Daniele Alessandri <suppakilla@gmail.com>
|
|
*/
|
|
class SafeExecutor implements PipelineExecutorInterface
|
|
{
|
|
/**
|
|
* {@inheritdoc}
|
|
*/
|
|
public function execute(ConnectionInterface $connection, SplQueue $commands)
|
|
{
|
|
$size = count($commands);
|
|
$values = array();
|
|
|
|
foreach ($commands as $command) {
|
|
try {
|
|
$connection->writeCommand($command);
|
|
} catch (CommunicationException $exception) {
|
|
return array_fill(0, $size, $exception);
|
|
}
|
|
}
|
|
|
|
for ($i = 0; $i < $size; $i++) {
|
|
$command = $commands->dequeue();
|
|
|
|
try {
|
|
$values[$i] = $connection->readResponse($command);
|
|
} catch (CommunicationException $exception) {
|
|
$toAdd = count($commands) - count($values);
|
|
$values = array_merge($values, array_fill(0, $toAdd, $exception));
|
|
break;
|
|
}
|
|
}
|
|
|
|
return $values;
|
|
}
|
|
}
|