summaryrefslogtreecommitdiff
path: root/ext/standard/tests/general_functions/proc_open_sockets2.phpt
diff options
context:
space:
mode:
Diffstat (limited to 'ext/standard/tests/general_functions/proc_open_sockets2.phpt')
-rw-r--r--ext/standard/tests/general_functions/proc_open_sockets2.phpt48
1 files changed, 24 insertions, 24 deletions
diff --git a/ext/standard/tests/general_functions/proc_open_sockets2.phpt b/ext/standard/tests/general_functions/proc_open_sockets2.phpt
index 25f3153ec4..7f9e1a85c5 100644
--- a/ext/standard/tests/general_functions/proc_open_sockets2.phpt
+++ b/ext/standard/tests/general_functions/proc_open_sockets2.phpt
@@ -5,49 +5,49 @@ proc_open() with IO socketpairs
function poll($pipe, $read = true)
{
- $r = ($read == true) ? [$pipe] : null;
- $w = ($read == false) ? [$pipe] : null;
- $e = null;
-
- if (!stream_select($r, $w, $e, null, 0)) {
- throw new \Error("Select failed");
- }
+ $r = ($read == true) ? [$pipe] : null;
+ $w = ($read == false) ? [$pipe] : null;
+ $e = null;
+
+ if (!stream_select($r, $w, $e, null, 0)) {
+ throw new \Error("Select failed");
+ }
}
function read_pipe($pipe): string
{
- poll($pipe);
-
- if (false === ($chunk = @fread($pipe, 8192))) {
- throw new Error("Failed to read: " . (error_get_last()['message'] ?? 'N/A'));
- }
-
- return $chunk;
+ poll($pipe);
+
+ if (false === ($chunk = @fread($pipe, 8192))) {
+ throw new Error("Failed to read: " . (error_get_last()['message'] ?? 'N/A'));
+ }
+
+ return $chunk;
}
function write_pipe($pipe, $data)
{
- poll($pipe, false);
-
- if (false == @fwrite($pipe, $data)) {
- throw new Error("Failed to write: " . (error_get_last()['message'] ?? 'N/A'));
- }
+ poll($pipe, false);
+
+ if (false == @fwrite($pipe, $data)) {
+ throw new Error("Failed to write: " . (error_get_last()['message'] ?? 'N/A'));
+ }
}
$cmd = [
- getenv("TEST_PHP_EXECUTABLE"),
- __DIR__ . '/proc_open_sockets2.inc'
+ getenv("TEST_PHP_EXECUTABLE"),
+ __DIR__ . '/proc_open_sockets2.inc'
];
$spec = [
- ['socket'],
- ['socket']
+ ['socket'],
+ ['socket']
];
$proc = proc_open($cmd, $spec, $pipes);
foreach ($pipes as $pipe) {
- var_dump(stream_set_blocking($pipe, false));
+ var_dump(stream_set_blocking($pipe, false));
}
printf("STDOUT << %s\n", read_pipe($pipes[1]));