#16 Try running with a small cluster of redis instances

Author: Willem Stuursma

.travis.yml

@@ -16,7 +16,7 @@ php:
 env: 
   global:
     - MEMCACHE_HOST=localhost
-    - REDIS_URIS=redis://localhost,redis://localhost:63791
+    - REDIS_URIS=redis://localhost:63791,redis://localhost:63792,redis://localhost:63793
     - MYSQL_DSN="mysql:host=localhost;dbname=test"
     - MYSQL_USER=travis
     - PGSQL_DSN="pgsql:host=localhost;dbname=test;"
@@ -36,6 +36,8 @@ matrix:
 before_install:
   - phpenv config-add tests/php-travis.ini
   - redis-server --port 63791 &
+  - redis-server --port 63792 &
+  - redis-server --port 63793 &
 
 install:
   - composer install --no-scripts --no-suggest --no-interaction

tests/mutex/PHPRedisMutexTest.php

@@ -21,10 +21,10 @@
 class PHPRedisMutexTest extends \PHPUnit_Framework_TestCase
 {
     /**
-     * @var Redis The Redis API.
+     * @var Redis[]
      */
-    private $redis;
-    
+    private $connections = [];
+
     /**
      * @var PHPRedisMutex The SUT.
      */
@@ -34,19 +34,34 @@ protected function setUp()
     {
         parent::setUp();
 
-        $this->redis = new Redis();
-
         $uris = explode(",", getenv("REDIS_URIS") ?: "redis://localhost");
-        $uri  = parse_url($uris[0]);
-        if (!empty($uri["port"])) {
-            $this->redis->connect($uri["host"], $uri["port"]);
-        } else {
-            $this->redis->connect($uri["host"]);
+
+        foreach ($uris as $redisUri) {
+            $uri  = parse_url($redisUri);
+
+            $connection = new Redis();
+
+            if (!empty($uri["port"])) {
+                $connection->connect($uri["host"], $uri["port"]);
+            } else {
+                $connection->connect($uri["host"]);
+            }
+
+            $connection->flushAll(); // Clear any existing locks.
+
+            $this->connections[] = $connection;
         }
 
-        $this->redis->flushAll(); // Clear any existing locks.
+        $this->mutex = new PHPRedisMutex($this->connections, "test");
+    }
+
+    private function closeMajorityConnections()
+    {
+        $numberToClose = ceil(count($this->connections) / 2);
 
-        $this->mutex = new PHPRedisMutex([$this->redis], "test");
+        foreach (array_rand($this->connections, $numberToClose) as $keyToClose) {
+            $this->connections[$keyToClose]->close();
+        }
     }
 
     /**
@@ -58,7 +73,8 @@ protected function setUp()
      */
     public function testAddFails()
     {
-        $this->redis->close();
+        $this->closeMajorityConnections();
+
         $this->mutex->synchronized(function () {
             $this->fail("Code execution is not expected");
         });
@@ -73,7 +89,7 @@ public function testAddFails()
     public function testEvalScriptFails()
     {
         $this->mutex->synchronized(function () {
-            $this->redis->close();
+            $this->closeMajorityConnections();
         });
     }
 
@@ -83,7 +99,9 @@ public function testEvalScriptFails()
      */
     public function testSyncronizedWorks($serialization)
     {
-        $this->redis->setOption(Redis::OPT_SERIALIZER, $serialization);
+        foreach ($this->connections as $connection) {
+            $connection->setOption(Redis::OPT_SERIALIZER, $serialization);
+        }
 
         $this->mutex->synchronized(function () {
             $this->assertTrue(true);