123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172 |
- <?php
- namespace Predis\Pipeline;
- use SplQueue;
- use Predis\CommunicationException;
- use Predis\Connection\ConnectionInterface;
- class SafeClusterExecutor implements PipelineExecutorInterface
- {
-
- public function execute(ConnectionInterface $connection, SplQueue $commands)
- {
- $size = count($commands);
- $values = array();
- $connectionExceptions = array();
- foreach ($commands as $command) {
- $cmdConnection = $connection->getConnection($command);
- if (isset($connectionExceptions[spl_object_hash($cmdConnection)])) {
- continue;
- }
- try {
- $cmdConnection->writeCommand($command);
- } catch (CommunicationException $exception) {
- $connectionExceptions[spl_object_hash($cmdConnection)] = $exception;
- }
- }
- for ($i = 0; $i < $size; $i++) {
- $command = $commands->dequeue();
- $cmdConnection = $connection->getConnection($command);
- $connectionObjectHash = spl_object_hash($cmdConnection);
- if (isset($connectionExceptions[$connectionObjectHash])) {
- $values[$i] = $connectionExceptions[$connectionObjectHash];
- continue;
- }
- try {
- $response = $cmdConnection->readResponse($command);
- $values[$i] = $response instanceof \Iterator ? iterator_to_array($response) : $response;
- } catch (CommunicationException $exception) {
- $values[$i] = $exception;
- $connectionExceptions[$connectionObjectHash] = $exception;
- }
- }
- return $values;
- }
- }
|