IDE documentation/stubs, updated and added examples mainly for Windows usage.

examples/fs.php

@@ -6,11 +6,12 @@
                 throw new Exception("read error");
             }
 
-            uv_fs_close(uv_default_loop(), $stream, function(){
-            });
-        } else {
-            echo $data;
-        }
+                uv_fs_close(uv_default_loop(), $stream, function () {
+                });
+            } else {
+                echo $data;
+            }
+        });
     });
 });
 

examples/listen.php

@@ -0,0 +1,59 @@
+<?php
+class TcpServer
+{
+    private $loop;
+    private $tcp;
+
+    public function __construct($loop)
+    {
+        $this->loop = $loop;
+        $this->tcp = uv_tcp_init($loop);
+    }
+
+    public function bind(string $address, int $port)
+    {
+        uv_tcp_bind($this->tcp, uv_ip4_addr($address, $port));
+    }
+
+    public function listen()
+    {
+        uv_listen($this->tcp, 128, function ($server, $status) {
+
+            $client = uv_tcp_init($this->loop);
+            uv_accept($server, $client);
+
+            uv_read_start($client, function ($socket, $buffer) {
+                echo 'OK', PHP_EOL;
+                uv_close($socket);
+            });
+        });
+    }
+
+    public function close()
+    {
+        if ($this->tcp instanceof UV) {
+            uv_close($this->tcp);
+        }
+    }
+}
+
+$loop = uv_loop_new();
+
+$tcpServer = new TcpServer($loop);
+$tcpServer->bind('127.0.0.1', 9876);
+$tcpServer->listen();
+
+$closed = 0;
+for ($i = 0; $i < 4; $i++) {
+    $c = uv_tcp_init($loop);
+    uv_tcp_connect($c, uv_ip4_addr('127.0.0.1', 9876), function ($stream, $stat) use (&$closed, $tcpServer) {
+        $closed++;
+        uv_close($stream);
+
+        if ($closed === 4) {
+            $tcpServer->close();
+        }
+    });
+}
+
+uv_run($loop, UV::RUN_DEFAULT);

examples/pipe.php

@@ -1,10 +1,11 @@
 <?php
 
-$pipe = uv_pipe_init(uv_default_loop(), 0);
-uv_pipe_open($pipe, 1);
+$pipe = uv_tty_init(uv_default_loop(), \STDOUT, 0);
+//$pipe = uv_pipe_init(uv_default_loop(), 0);
+//uv_pipe_open($pipe, 1);
 //uv_pipe_bind($pipe,"/tmp/hoge.sock");
 
-uv_write($pipe, "Hello", function($pipe, $buf) {
+uv_write($pipe, "Hello", function ($pipe, $buf) {
     echo 1;
     uv_close($pipe);
 });

examples/poll.php

@@ -1,23 +1,23 @@
 <?php
 
-$socket = stream_socket_server("tcp://0.0.0.0:9999", $errno, $errstr);
+$socket = stream_socket_server("tcp://127.0.0.1:9999", $errno, $errstr);
 stream_set_blocking($socket, 0);
 
 $poll = uv_poll_init(uv_default_loop(), $socket);
 
-uv_poll_start($poll, UV::READABLE, function($poll, $stat, $ev, $socket) {
+uv_poll_start($poll, UV::READABLE, function ($poll, $stat, $ev, $socket) {
     echo "parent poll:\n";
     var_dump($stat);
     $conn = stream_socket_accept($socket);
 
     $pp = uv_poll_init(uv_default_loop(), $conn);
-    uv_poll_start($pp, UV::WRITABLE, function($poll, $stat, $ev, $conn) {
+    uv_poll_start($pp, UV::WRITABLE, function ($poll, $stat, $ev, $conn) {
         echo "  cb";
         var_dump($stat);
         var_dump($conn);
 
         uv_poll_stop($poll);
-        uv_fs_write(uv_default_loop(), $conn, "Hello World", -1, function($conn, $nwrite) {
+        uv_fs_write(uv_default_loop(), $conn, "Hello World", -1, function ($conn, $nwrite) {
             var_dump($conn);
             fclose($conn);
         });

examples/poll_sendfile.php

@@ -0,0 +1,35 @@
+<?php
+
+$socket = stream_socket_server("tcp://127.0.0.1:9999", $errno, $errstr);
+
+$poll = uv_poll_init(uv_default_loop(), $socket);
+
+uv_poll_start($poll, UV::READABLE, function ($poll, $stat, $ev, $socket) {
+    echo "parent poll:\n";
+    var_dump($stat);
+    $conn = stream_socket_accept($socket);
+
+    $pp = uv_poll_init(uv_default_loop(), $conn);
+    uv_poll_start($pp, UV::WRITABLE, function ($poll, $stat, $ev, $conn) {
+        echo "  connected callback has: stat -";
+        print_r($stat);
+        echo "  event -";
+        print_r($ev);
+        echo "  poll -";
+        print_r($poll);
+
+        echo "  stream_get_meta_data(conn) -";
+        print_r(\stream_get_meta_data($conn));
+        uv_poll_stop($poll);
+        uv_fs_open(uv_default_loop(), __FILE__, UV::O_RDONLY, 0, function ($read_fd) use ($conn) {
+            uv_fs_fstat(uv_default_loop(), $read_fd, function ($r, $stat) use ($conn) {
+                uv_fs_sendfile(uv_default_loop(), $conn, $r, 0, $stat['size'], function ($conn) {
+                    fclose($conn);
+                    uv_stop(uv_default_loop());
+                });
+            });
+        });
+    });
+});
+
+uv_run();

examples/process_kill.php

@@ -0,0 +1,40 @@
+<?php
+
+$in  = uv_pipe_init(uv_default_loop(), ('/' == \DIRECTORY_SEPARATOR));
+$out = uv_pipe_init(uv_default_loop(), ('/' == \DIRECTORY_SEPARATOR));
+
+echo "Hello, ";
+
+$stdio = array();
+$stdio[] = uv_stdio_new($in, UV::CREATE_PIPE | UV::READABLE_PIPE);
+$stdio[] = uv_stdio_new($out, UV::CREATE_PIPE | UV::WRITABLE_PIPE);
+
+$flags = 0;
+$pid = uv_spawn(
+    uv_default_loop(),
+    "php",
+    array('-r', 'echo "World! ";'),
+    $stdio,
+    __DIR__,
+    [],
+    function ($process, $stat, $signal) {
+        if ($signal == 9) {
+            echo "The process was terminated with 'SIGKILL' or '9' signal!";
+        }
+
+        uv_close($process, function () {
+        });
+    },
+    $flags
+);
+
+uv_process_kill($pid, 9);
+
+uv_read_start($out, function ($out, $nread, $buffer) {
+    echo $buffer;
+
+    uv_close($out, function () {
+    });
+});
+
+uv_run();

examples/queue.php

@@ -1,12 +1,11 @@
 <?php
 $loop = uv_default_loop();
 
-$queue = uv_queue_work($loop, function(){
+$queue = uv_queue_work($loop, function () {
     echo "[queue]";
-}, function(){
+}, function () {
     echo "[finished]";
 });
 
 
-uv_run();
-
+uv_run($loop);

examples/queue_2_threads.php

@@ -0,0 +1,33 @@
+<?php
+
+$loop = uv_default_loop();
+$completed = false;
+uv_queue_work($loop, function () use (&$completed) {
+    while (!$completed) {
+        echo "[queue2]";
+        usleep(1);
+    }
+}, function () {
+    echo "[finished]";
+});
+
+uv_queue_work($loop, function () use (&$completed) {
+    while (!$completed) {
+        echo "[queue1]";
+        $completed = true;
+        usleep(2);
+    }
+}, function () {
+    echo "[finished]";
+});
+
+while (true) {
+    if ($completed) {
+        echo ' --finish-- ';
+        var_dump($completed);
+        uv_run($loop);
+        break;
+    }
+
+    uv_run($loop, UV::RUN_NOWAIT);
+}

examples/queue_channel.php

@@ -0,0 +1,24 @@
+<?php
+$loop = \uv_default_loop();
+[$read, $write] = \stream_socket_pair((\stripos(\PHP_OS, "win") === 0 ? \STREAM_PF_INET : \STREAM_PF_UNIX),
+    \STREAM_SOCK_STREAM,
+    \STREAM_IPPROTO_IP
+);
+
+$function = function () use ($write) {
+    echo "[queue1]";
+    \fwrite($write, "Thread 1\n");
+    \usleep(1);
+};
+
+\uv_queue_work($loop, $function, function () {
+});
+
+\uv_queue_work($loop, function () use ($read) {
+    echo "[queue2] ";
+    echo "Thread 2 Got " . \fgets($read);
+}, function () {
+});
+
+\uv_run($loop);
+\fclose($write);

examples/readlink.php

@@ -1,6 +1,6 @@
 <?php
 
-uv_fs_readlink(uv_default_loop(), "linkPath", function($buffer){
+uv_fs_readlink(uv_default_loop(), "linkPath", function ($buffer) {
     var_dump($buffer);
 });
 

examples/signal.php

@@ -0,0 +1,53 @@
+<?php
+
+$in  = uv_pipe_init(uv_default_loop(), ('/' == \DIRECTORY_SEPARATOR));
+$out = uv_pipe_init(uv_default_loop(), ('/' == \DIRECTORY_SEPARATOR));
+
+$signal = uv_signal_init();
+
+uv_signal_start($signal, function ($signal) {
+    print_r($signal);
+    echo PHP_EOL . 'The CTRL+C signal received, click the [X] to close the window.' . PHP_EOL;
+    uv_signal_stop($signal);
+}, 2);
+
+$signal = uv_signal_init();
+
+uv_signal_start($signal, function ($signal) {
+    print_r($signal);
+    echo PHP_EOL . 'The SIGHUP signal received, the OS will close this session window!' . PHP_EOL;
+}, 1);
+
+echo "Hello, ";
+
+$stdio = array();
+$stdio[] = uv_stdio_new($in, UV::CREATE_PIPE | UV::READABLE_PIPE);
+$stdio[] = uv_stdio_new($out, UV::CREATE_PIPE | UV::WRITABLE_PIPE);
+
+$flags = 0;
+$pid = uv_spawn(
+    uv_default_loop(),
+    "php",
+    array('-r', 'echo "World! " . PHP_EOL;'),
+    $stdio,
+    __DIR__,
+    [],
+    function ($process, $stat, $signal) {
+        if ($signal == 9) {
+            echo "The process was terminated with 'SIGKILL' or '9' signal!" . PHP_EOL;
+        }
+
+        uv_close($process, function () {
+        });
+    },
+    $flags
+);
+
+uv_read_start($out, function ($out, $nread, $buffer) {
+    echo $buffer;
+
+    uv_close($out, function () {
+    });
+});
+
+uv_run();

examples/spawn.php

@@ -1,7 +1,7 @@
 <?php
 
-$in  = uv_pipe_init(uv_default_loop(), true);
-$out = uv_pipe_init(uv_default_loop(), true);
+$in  = uv_pipe_init(uv_default_loop(), ('/' == \DIRECTORY_SEPARATOR));
+$out = uv_pipe_init(uv_default_loop(), ('/' == \DIRECTORY_SEPARATOR));
 
 echo "HELLO ";
 
@@ -10,8 +10,8 @@
 $stdio[] = uv_stdio_new($out, UV::CREATE_PIPE | UV::WRITABLE_PIPE);
 
 $flags = 0;
-uv_spawn(uv_default_loop(), "php", array('-r','var_dump($_ENV);'), $stdio, "/usr/bin/", 
-    array("KEY"=>"hello"), 
+uv_spawn(uv_default_loop(), "php", array('-r','var_dump($_ENV);'), $stdio, "/usr/bin/",
+    array("KEY"=>"hello"),
     function($process, $stat, $signal){
 	    uv_close($process,function(){});
 
@@ -20,7 +20,8 @@ function($process, $stat, $signal){
 uv_read_start($out, function($out, $buffer){
     echo $buffer;
 
-    uv_close($out,function(){});
+    uv_close($out, function () {
+    });
 });
 
 uv_run();

examples/spawn_fd.php

@@ -1,6 +1,6 @@
 <?php
 
-$in  = uv_pipe_init(uv_default_loop(), true);
+$in  = uv_pipe_init(uv_default_loop(), ('/' == \DIRECTORY_SEPARATOR));
 
 echo "HELLO ";
 
@@ -11,8 +11,8 @@
 $stdio[] = uv_stdio_new($fp, UV::INHERIT_FD | UV::WRITABLE_PIPE);
 
 $flags = 0;
-uv_spawn(uv_default_loop(), "php", ['-r', 'var_dump($_ENV);'], $stdio, "/usr/bin/", 
-    ["key" => "hello"], 
+uv_spawn(uv_default_loop(), "php", ['-r', 'var_dump($_ENV);'], $stdio, "/usr/bin/",
+    ["key" => "hello"],
     function($process, $stat, $signal){
 	    uv_close($process,function(){});