Add tests

Author: mpyw

examples/fast_hello.php

@@ -0,0 +1,25 @@
+<?php
+
+header('Cache-Control: no-store'); // Very important role for Google Chrome
+header('Content-Type: text/event-stream; charset=UTF-8');
+
+while (ob_get_level()) ob_end_clean();
+
+var_dump(compact('_GET', '_POST'));
+var_dump($_SERVER['SERVER_PORT']);
+flush();
+
+usleep(50000);
+
+echo "Hello (1)\n";
+flush();
+
+usleep(50000);
+
+echo "Hello (2)\n";
+flush();
+
+usleep(50000);
+
+echo "Hello (3)\n";
+flush();

tests/unit/RemoteSimpleTest.php

@@ -11,12 +11,19 @@ class RemoteSimpleTest extends \Codeception\TestCase\Test
 
     public function _before()
     {
+        Co::setDefaultOptions(['concurrency' => 0]);
     }
 
     public function _after()
     {
     }
 
+    private function assertInRange($min, $actual, $max)
+    {
+        $this->assertGreaterThanOrEqual($min, $actual);
+        $this->assertLessThanOrEqual($max, $actual);
+    }
+
     private static function curlInitWith($url, array $params = [])
     {
         $ch = curl_init();
@@ -29,17 +36,112 @@ private static function curlInitWith($url, array $params = [])
         return $ch;
     }
 
-    public function testDownload()
+    private function curlsInitWith($n, $url, array $params = [])
     {
-        $ch = self::curlInitWith('http://localhost:8080/upload_form.php');
-        Co::wait($ch);
-        $this->assertEquals(200, curl_getinfo($ch, CURLINFO_HTTP_CODE));
+        $curls = [];
+        for ($i = 0; $i < $n; ++$i) {
+            $curls[] = $this->curlInitWith($url, $params);
+        }
+        return $curls;
     }
 
-    public function testRunSecure()
+    private function curlAssert200OK($ch)
     {
-        $ch = self::curlInitWith('https://localhost:8081/upload_form.php');
-        Co::wait($ch);
         $this->assertEquals(200, curl_getinfo($ch, CURLINFO_HTTP_CODE));
     }
+
+    private function curlsAssert200OK(array $curls)
+    {
+        foreach ($curls as $ch) {
+            $this->assertEquals(200, curl_getinfo($ch, CURLINFO_HTTP_CODE));
+        }
+    }
+
+    public function testSimple()
+    {
+        Co::wait($ch = $this->curlInitWith('http://localhost:8080/upload_form.php'));
+        $this->curlAssert200OK($ch);
+    }
+
+    public function testSimpleSecure()
+    {
+        Co::wait($ch = $this->curlInitWith('https://localhost:8081/upload_form.php'));
+        $this->curlAssert200OK($ch);
+    }
+
+    public function testDelayed()
+    {
+        $start = microtime(true);
+        Co::wait($ch = $this->curlInitWith('http://localhost:8080/fast_hello.php'));
+        $end = microtime(true);
+        $this->curlAssert200OK($ch);
+        $this->assertInRange(0.1, $end - $start, 0.2);
+    }
+
+    public function testDelayedSecure()
+    {
+        $start = microtime(true);
+        Co::wait($ch = $this->curlInitWith('https://localhost:8081/fast_hello.php'));
+        $end = microtime(true);
+        $this->curlAssert200OK($ch);
+        $this->assertInRange(0.11, $end - $start, 0.21);
+    }
+
+    public function testDelayedGroupSingle()
+    {
+        $start = microtime(true);
+        Co::wait($chs = $this->curlsInitWith(5, 'http://localhost:8080/fast_hello.php'));
+        $end = microtime(true);
+        $this->curlsAssert200OK($chs);
+        $this->assertInRange(0.12, $end - $start, 0.22);
+    }
+
+    public function testDelayedGroupSingleSecure()
+    {
+        $start = microtime(true);
+        Co::wait($chs = $this->curlsInitWith(5, 'https://localhost:8081/fast_hello.php'));
+        $end = microtime(true);
+        $this->curlsAssert200OK($chs);
+        $this->assertInRange(0.12, $end - $start, 0.22);
+    }
+
+    public function testDelayedGroupDouble()
+    {
+        $start = microtime(true);
+        Co::wait($chs = $this->curlsInitWith(10, 'http://localhost:8080/fast_hello.php'));
+        $end = microtime(true);
+        $this->curlsAssert200OK($chs);
+        $this->assertInRange(0.28, $end - $start, 0.38);
+    }
+
+    public function testDelayedGroupDoubleSecure()
+    {
+        $start = microtime(true);
+        Co::wait($chs = $this->curlsInitWith(10, 'https://localhost:8081/fast_hello.php'));
+        $end = microtime(true);
+        $this->curlsAssert200OK($chs);
+        $this->assertInRange(0.32, $end - $start, 0.42);
+    }
+
+    public function testDelayedGroupDoubleAtOnce()
+    {
+        $start = microtime(true);
+        Co::wait($chs = $this->curlsInitWith(10, 'http://localhost:8080/fast_hello.php'), [
+            'concurrency' => 0,
+        ]);
+        $end = microtime(true);
+        $this->curlsAssert200OK($chs);
+        $this->assertInRange(0.28, $end - $start, 0.38);
+    }
+
+    public function testDelayedGroupDoubleAtOnceSecure()
+    {
+        $start = microtime(true);
+        Co::wait($chs = $this->curlsInitWith(10, 'https://localhost:8081/fast_hello.php'), [
+            'concurrency' => 0,
+        ]);
+        $end = microtime(true);
+        $this->curlsAssert200OK($chs);
+        $this->assertInRange(0.32, $end - $start, 0.42);
+    }
 }