Add the async. prefix stream protocol, unlike runtime hooks, the async. protocol is always available

Author: matyhtf

ext-src/swoole_runtime.cc

@@ -101,6 +101,17 @@ static int socket_close(php_stream *stream, int close_handle);
 static int socket_stat(php_stream *stream, php_stream_statbuf *ssb);
 static int socket_cast(php_stream *stream, int castas, void **ret);
 static bool socket_ssl_set_options(Socket *sock, php_stream_context *context);
+
+static php_stream *socket_create(const char *proto,
+ size_t protolen,
+ const char *resourcename,
+ size_t resourcenamelen,
+ const char *persistent_id,
+ int options,
+ int flags,
+ struct timeval *timeout,
+ php_stream_context *context STREAMS_DC);
+
 // clang-format off
 static zend_class_entry *swoole_runtime_ce;
 
@@ -284,6 +295,13 @@ void php_swoole_runtime_minit(int module_number) {
 #endif
  swoole_proc_open_init(module_number);
 
+ php_stream_xport_register("async.tcp", socket_create);
+ php_stream_xport_register("async.udp", socket_create);
+ php_stream_xport_register("async.unix", socket_create);
+ php_stream_xport_register("async.udg", socket_create);
+ php_stream_xport_register("async.ssl", socket_create);
+ php_stream_xport_register("async.tls", socket_create);
+
  php_register_url_stream_wrapper(SW_ASYNC_FILE_PROTOCOL, &sw_php_plain_files_wrapper);
 }
 
@@ -1214,6 +1232,11 @@ static php_stream *socket_create(const char *proto,
  proto, protolen, resourcename, resourcenamelen, persistent_id, options, flags, timeout, context STREAMS_CC);
  }
 
+ if (SW_STR_STARTS_WITH(proto, protolen, "async.")) {
+ proto += sizeof("async.") - 1;
+ protolen -= sizeof("async.") - 1;
+ }
+
  if (SW_STREQ(proto, protolen, "tcp")) {
  sock = new Socket(resourcename[0] == '[' ? SW_SOCK_TCP6 : SW_SOCK_TCP);
  } else if (SW_STREQ(proto, protolen, "ssl") || SW_STREQ(proto, protolen, "tls")) {

tests/swoole_runtime/async_protocol.phpt

@@ -0,0 +1,43 @@
+--TEST--
+swoole_runtime: async protocol
+--SKIPIF--
+<?php
+require __DIR__ . '/../include/skipif.inc';
+?>
+--FILE--
+<?php
+require __DIR__ . '/../include/bootstrap.php';
+
+Swoole\Runtime::enableCoroutine(0);
+const N = 5;
+
+go(function () {
+ $socket = new Swoole\Coroutine\Socket(AF_UNIX, SOCK_DGRAM, 0);
+ $socket->bind(__DIR__ . '/test.sock');
+
+ for ($i = 0; $i < N; $i++) {
+ $peer = null;
+ $data = $socket->recvfrom($peer);
+ echo "[Server] recv : $data\n";
+ }
+});
+
+go(function () {
+ $fp = stream_socket_client("async.udg://".__DIR__."/test.sock", $errno, $errstr, 30);
+ if (!$fp) {
+ echo "$errstr ($errno)<br />\n";
+ } else {
+ for ($i = 0; $i < N; $i++) {
+ fwrite($fp, "hello-{$i}");
+ }
+ fclose($fp);
+ }
+});
+Swoole\Event::wait();
+?>
+--EXPECT--
+[Server] recv : hello-0
+[Server] recv : hello-1
+[Server] recv : hello-2
+[Server] recv : hello-3
+[Server] recv : hello-4