* fix test stability

Author: EdmondDantes

tests/dns/004-concurrent_dns_lookups.phpt

@@ -15,34 +15,38 @@ for ($i = 0; $i < 5; $i++) {
     $coroutines[] = spawn(function() use ($i) {
         $hostname = $i % 2 == 0 ? 'localhost' : '127.0.0.1';
         $ip = gethostbyname($hostname);
-        echo "Coroutine $i: $hostname -> $ip\n";
-        return $ip;
+        return ['coroutine' => $i, 'input' => $hostname, 'output' => $ip];
     });
 }
 
 // Test concurrent gethostbyaddr
 for ($i = 5; $i < 8; $i++) {
     $coroutines[] = spawn(function() use ($i) {
         $hostname = gethostbyaddr('127.0.0.1');
-        echo "Coroutine $i: 127.0.0.1 -> $hostname\n";
-        return $hostname;
+        return ['coroutine' => $i, 'input' => '127.0.0.1', 'output' => $hostname];
     });
 }
 
 [$results, $exceptions] = awaitAll($coroutines);
+
+// Print results in deterministic order
+foreach ($results as $result) {
+    echo "Coroutine {$result['coroutine']}: {$result['input']} -> {$result['output']}\n";
+}
+
 echo "All DNS lookups completed\n";
 echo "Total results: " . count($results) . "\n";
 
 ?>
 --EXPECTF--
 Starting concurrent DNS lookups
-Coroutine %d: %s -> %s
-Coroutine %d: %s -> %s
-Coroutine %d: %s -> %s
-Coroutine %d: %s -> %s
-Coroutine %d: %s -> %s
-Coroutine %d: 127.0.0.1 -> %s
-Coroutine %d: 127.0.0.1 -> %s
-Coroutine %d: 127.0.0.1 -> %s
+Coroutine 0: localhost -> %s
+Coroutine 1: 127.0.0.1 -> %s
+Coroutine 2: localhost -> %s
+Coroutine 3: 127.0.0.1 -> %s
+Coroutine 4: localhost -> %s
+Coroutine 5: 127.0.0.1 -> %s
+Coroutine 6: 127.0.0.1 -> %s
+Coroutine 7: 127.0.0.1 -> %s
 All DNS lookups completed
 Total results: 8

tests/socket_ext/001-socket_read_async.phpt

@@ -15,77 +15,87 @@ use function Async\delay;
 
 echo "Start\n";
 
+// Array to collect output from spawn functions
+$output = [];
+
 // Shared variable for server port
 $port = null;
 
 // Server coroutine
-$server = spawn(function() use (&$port) {
-    echo "Server: creating socket\n";
+$server = spawn(function() use (&$port, &$output) {
+    $output[] = "Server: creating socket";
     $socket = socket_create(AF_INET, SOCK_STREAM, SOL_TCP);
     socket_set_option($socket, SOL_SOCKET, SO_REUSEADDR, 1);
     socket_bind($socket, '127.0.0.1', 0);
     socket_listen($socket);
 
     $addr = '';
     socket_getsockname($socket, $addr, $port);
-    echo "Server: listening on port $port\n";
+    $output[] = "Server: listening on port $port";
 
-    echo "Server: waiting for connection\n";
+    $output[] = "Server: waiting for connection";
     $client = socket_accept($socket);
-    echo "Server: client connected\n";
+    $output[] = "Server: client connected";
 
     $data = socket_read($client, 1024);
-    echo "Server: received '$data'\n";
+    $output[] = "Server: received '$data'";
 
     socket_write($client, "Hello from server");
-    echo "Server: response sent\n";
+    $output[] = "Server: response sent";
 
     socket_close($client);
     socket_close($socket);
 });
 
 // Client coroutine
-$client = spawn(function() use (&$port) {
+$client = spawn(function() use (&$port, &$output) {
     // Wait for the server to set the port
     while ($port === null) {
         delay(1);
     }
 
-    echo "Client: connecting\n";
+    $output[] = "Client: connecting";
     $socket = socket_create(AF_INET, SOCK_STREAM, SOL_TCP);
     if (!socket_connect($socket, '127.0.0.1', $port)) {
-        echo "Client: failed to connect\n";
+        $output[] = "Client: failed to connect";
         return;
     }
 
     socket_write($socket, "Hello from client");
-    echo "Client: sent request\n";
+    $output[] = "Client: sent request";
 
     $response = socket_read($socket, 1024);
-    echo "Client: received '$response'\n";
+    $output[] = "Client: received '$response'";
 
     socket_close($socket);
 });
 
 // Worker coroutine for parallel execution
-$worker = spawn(function() {
-    echo "Worker: doing work while server waits\n";
+$worker = spawn(function() use (&$output) {
+    $output[] = "Worker: doing work while server waits";
 });
 
 awaitAll([$server, $client, $worker]);
+
+// Sort and output results
+sort($output);
+foreach ($output as $line) {
+    echo $line . "\n";
+}
+
 echo "End\n";
 
 ?>
 --EXPECTF--
 Start
-Server: creating socket
-Server: listening on port %d
-Server: waiting for connection
 Client: connecting
-Worker: doing work while server waits
-Server: client connected
+Client: received 'Hello from server'
 Client: sent request
+Server: client connected
+Server: creating socket
+Server: listening on port %d
 Server: received 'Hello from client'
 Server: response sent
-Client: received 'Hello from server'
+Server: waiting for connection
+Worker: doing work while server waits
 End

tests/socket_ext/004-socket_connect_async.phpt

@@ -16,9 +16,10 @@ use function Async\delay;
 echo "Start\n";
 
 $port = null;
+$output = [];
 
 // Server coroutine
-$server = spawn(function() use (&$port) {
+$server = spawn(function() use (&$port, &$output) {
     echo "Server: creating socket\n";
     $socket = socket_create(AF_INET, SOCK_STREAM, SOL_TCP);
     socket_set_option($socket, SOL_SOCKET, SO_REUSEADDR, 1);
@@ -31,10 +32,10 @@ $server = spawn(function() use (&$port) {
 
     echo "Server: accepting connections\n";
     $client1 = socket_accept($socket);
-    echo "Server: client1 connected\n";
+    $output[] = "Server: client1 connected";
 
     $client2 = socket_accept($socket);
-    echo "Server: client2 connected\n";
+    $output[] = "Server: client2 connected";
 
     socket_write($client1, "Hello client1");
     socket_write($client2, "Hello client2");
@@ -45,45 +46,52 @@ $server = spawn(function() use (&$port) {
 });
 
 // Client coroutines
-$client1 = spawn(function() use (&$port) {
+$client1 = spawn(function() use (&$port, &$output) {
     while ($port === null) {
         delay(1);
     }
 
-    echo "Client1: connecting\n";
+    $output[] = "Client1: connecting";
     $socket = socket_create(AF_INET, SOCK_STREAM, SOL_TCP);
 
     if (socket_connect($socket, '127.0.0.1', $port)) {
-        echo "Client1: connected successfully\n";
+        $output[] = "Client1: connected successfully";
         $data = socket_read($socket, 1024);
-        echo "Client1: received '$data'\n";
+        $output[] = "Client1: received '$data'";
     } else {
-        echo "Client1: connection failed\n";
+        $output[] = "Client1: connection failed";
     }
 
     socket_close($socket);
 });
 
-$client2 = spawn(function() use (&$port) {
+$client2 = spawn(function() use (&$port, &$output) {
     while ($port === null) {
         delay(1);
     }
 
-    echo "Client2: connecting\n";
+    $output[] = "Client2: connecting";
     $socket = socket_create(AF_INET, SOCK_STREAM, SOL_TCP);
 
     if (socket_connect($socket, '127.0.0.1', $port)) {
-        echo "Client2: connected successfully\n";
+        $output[] = "Client2: connected successfully";
         $data = socket_read($socket, 1024);
-        echo "Client2: received '$data'\n";
+        $output[] = "Client2: received '$data'";
     } else {
-        echo "Client2: connection failed\n";
+        $output[] = "Client2: connection failed";
     }
 
     socket_close($socket);
 });
 
 awaitAll([$server, $client1, $client2]);
+
+// Sort output for deterministic results
+sort($output);
+foreach ($output as $message) {
+    echo $message . "\n";
+}
+
 echo "End\n";
 
 ?>
@@ -92,8 +100,12 @@ Start
 Server: creating socket
 Server: listening on port %d
 Server: accepting connections
+Client1: connected successfully
 Client1: connecting
+Client1: received 'Hello client1'
+Client2: connected successfully
 Client2: connecting
+Client2: received 'Hello client2'
 Server: client1 connected
-Client1: connected successfully
-%a
+Server: client2 connected
+End

tests/socket_ext/005-socket_accept_multiple.phpt

@@ -15,27 +15,30 @@ use function Async\delay;
 
 echo "Start\n";
 
+// Array to collect output from spawn functions
+$output = [];
+
 $port = null;
 
 // Server coroutine
-$server = spawn(function() use (&$port) {
-    echo "Server: creating socket\n";
+$server = spawn(function() use (&$port, &$output) {
+    $output[] = "Server: creating socket";
     $socket = socket_create(AF_INET, SOCK_STREAM, SOL_TCP);
     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);
-    echo "Server: listening on port $port\n";
+    $output[] = "Server: listening on port $port";
 
     $clients = [];
 
     // Accept 3 clients
     for ($i = 1; $i <= 3; $i++) {
-        echo "Server: waiting for client $i\n";
+        $output[] = "Server: waiting for client $i";
         $client = socket_accept($socket);
-        echo "Server: client $i connected\n";
+        $output[] = "Server: client $i connected";
         $clients[] = $client;
     }
 
@@ -52,35 +55,55 @@ $server = spawn(function() use (&$port) {
 // Multiple client coroutines
 $clients = [];
 for ($i = 1; $i <= 3; $i++) {
-    $clients[] = spawn(function() use (&$port, $i) {
+    $clients[] = spawn(function() use (&$port, $i, &$output) {
         while ($port === null) {
             delay(1);
         }
 
         // Small delay to stagger connections
         delay($i);
 
-        echo "Client$i: connecting\n";
+        $output[] = "Client$i: connecting";
         $socket = socket_create(AF_INET, SOCK_STREAM, SOL_TCP);
 
         if (socket_connect($socket, '127.0.0.1', $port)) {
-            echo "Client$i: connected\n";
+            $output[] = "Client$i: connected";
             $data = socket_read($socket, 1024);
-            echo "Client$i: received '$data'\n";
+            $output[] = "Client$i: received '$data'";
         }
 
         socket_close($socket);
     });
 }
 
 awaitAll(array_merge([$server], $clients));
+
+// Sort and output results
+sort($output);
+foreach ($output as $line) {
+    echo $line . "\n";
+}
+
 echo "End\n";
 
 ?>
 --EXPECTF--
 Start
+Client1: connected
+Client1: connecting
+Client1: received 'Response to client 1'
+Client2: connected
+Client2: connecting
+Client2: received 'Response to client 2'
+Client3: connected
+Client3: connecting
+Client3: received 'Response to client 3'
+Server: client 1 connected
+Server: client 2 connected
+Server: client 3 connected
 Server: creating socket
 Server: listening on port %d
 Server: waiting for client 1
-Client1: connecting
-%a
+Server: waiting for client 2
+Server: waiting for client 3
+End