#53: * change 005-socket_accept_multiple.phpt

Author: EdmondDantes

tests/socket_ext/005-socket_accept_multiple.phpt

@@ -10,7 +10,7 @@ if (!extension_loaded('sockets')) {
 <?php
 
 use function Async\spawn;
-use function Async\awaitAll;
+use function Async\awaitAllOrFail;
 use function Async\delay;
 
 echo "Start\n";
@@ -27,56 +27,61 @@ $server = spawn(function() use (&$port, &$output) {
     socket_set_option($socket, SOL_SOCKET, SO_REUSEADDR, 1);
     socket_bind($socket, '127.0.0.1', 0);
     socket_listen($socket, 5);
-    
+
     $addr = '';
     socket_getsockname($socket, $addr, $port);
     $output[] = "Server: listening on port $port";
-    
+
     $clients = [];
-    
+
     // Accept 3 clients
     for ($i = 1; $i <= 3; $i++) {
         $output[] = "Server: waiting for client $i";
         $client = socket_accept($socket);
         $output[] = "Server: client $i connected";
         $clients[] = $client;
     }
-    
+
     // Send responses to all clients
     foreach ($clients as $i => $client) {
         $clientNum = $i + 1;
         socket_write($client, "Response to client $clientNum");
         socket_close($client);
     }
-    
+
     socket_close($socket);
 });
 
 // Multiple client coroutines
 $clients = [];
 for ($i = 1; $i <= 3; $i++) {
     $clients[] = spawn(function() use (&$port, $i, &$output) {
-        while ($port === null) {
-            delay(1);
+
+        for ($i = 0; $i < 3 && $port === null; $i++) {
+            delay(10);
         }
-        
+
+        if(empty($port)) {
+            throw new Exception("Server port is not provided...");
+        }
+
         // Small delay to stagger connections
         delay($i);
-        
+
         $output[] = "Client$i: connecting";
         $socket = socket_create(AF_INET, SOCK_STREAM, SOL_TCP);
-        
+
         if (socket_connect($socket, '127.0.0.1', $port)) {
             $output[] = "Client$i: connected";
             $data = socket_read($socket, 1024);
             $output[] = "Client$i: received '$data'";
         }
-        
+
         socket_close($socket);
     });
 }
 
-awaitAll(array_merge([$server], $clients));
+awaitAllOrFail(array_merge([$server], $clients));
 
 // Sort and output results
 sort($output);
@@ -106,4 +111,4 @@ Server: listening on port %d
 Server: waiting for client 1
 Server: waiting for client 2
 Server: waiting for client 3
-End
+End

tests/stream/027-ssl_concurrent_accept.phpt

@@ -74,13 +74,13 @@ $monitor = spawn(function() use (&$servers_ready, &$servers_completed) {
     echo "Monitor: waiting for servers to be ready\n";
 
     while ($servers_ready < 3) {
-        delay(50);
+        delay(10);
     }
 
     echo "Monitor: all servers ready, waiting for completion\n";
 
     while ($servers_completed < 3) {
-        delay(50);
+        delay(10);
     }
 
     echo "Monitor: all servers completed\n";