sockets introduces socket_set_option SO_ZEROCOPY and MSG_ZEROCOPY for the socket_send* functions. it avoids copy b/w userland and kernel for both TCP and UDP protocols.

Author: devnexen

ext/sockets/sockets.c

@@ -511,6 +511,9 @@ static PHP_MINIT_FUNCTION(sockets)
 #ifdef MSG_CMSG_CLOEXEC
 	REGISTER_LONG_CONSTANT("MSG_CMSG_CLOEXEC",MSG_CMSG_CLOEXEC,CONST_CS | CONST_PERSISTENT);
 #endif
+#ifdef MSG_ZEROCOPY
+	REGISTER_LONG_CONSTANT("MSG_ZEROCOPY",  MSG_ZEROCOPY,   CONST_CS | CONST_PERSISTENT);
+#endif
 
 	REGISTER_LONG_CONSTANT("SO_DEBUG",		SO_DEBUG,		CONST_CS | CONST_PERSISTENT);
 	REGISTER_LONG_CONSTANT("SO_REUSEADDR",	SO_REUSEADDR,	CONST_CS | CONST_PERSISTENT);
@@ -630,6 +633,9 @@ static PHP_MINIT_FUNCTION(sockets)
 #ifdef TCP_CONGESTION
 	REGISTER_LONG_CONSTANT("TCP_CONGESTION",   TCP_CONGESTION,    CONST_CS | CONST_PERSISTENT);
 #endif
+#ifdef SO_ZEROCOPY
+	REGISTER_LONG_CONSTANT("SO_ZEROCOPY", SO_ZEROCOPY,  CONST_CS | CONST_PERSISTENT);
+#endif
 #ifdef TCP_NODELAY
 	REGISTER_LONG_CONSTANT("TCP_NODELAY",   TCP_NODELAY,    CONST_CS | CONST_PERSISTENT);
 #endif

ext/sockets/tests/socket_sendto_zerocopy.phpt

@@ -0,0 +1,47 @@
+--TEST--
+Test socket_sendto with MSG_ZEROCOPY
+--EXTENSIONS--
+sockets
+--SKIPIF--
+<?php
+if (!defined("SO_ZEROCOPY")) {
+    die('skip SO_ZEROCOPY');
+}
+--FILE--
+<?php
+$socket = socket_create(AF_INET, SOCK_DGRAM, SOL_UDP);
+if (!$socket) {
+    die('Unable to create AF_UNIX socket');
+}
+$s = socket_create(AF_INET, SOCK_DGRAM, SOL_UDP);
+if (!$s) {
+    die('Unable to create AF_UNIX socket');
+}
+if (!socket_set_option($socket, SOL_SOCKET, SO_ZEROCOPY, 1)) {
+    die("Unable to set the socket option to SO_ZEROCOPY");
+}
+if (!socket_set_nonblock($s)) {
+    die('Unable to set nonblocking mode for socket');
+}
+$address = '127.0.0.1';
+$port = 3001;
+if (!socket_bind($s, $address, $port)) {
+    die("Unable to bind to $address");
+}
+
+$msg = str_repeat("0123456789abcdef", 1024);
+$len = strlen($msg);
+$bytes_recv = 0;
+$bytes_sent = socket_sendto($socket, $msg, $len, MSG_ZEROCOPY, $address, $port);
+if (socket_recvfrom($s, $resp, 0, MSG_ERRQUEUE, $address, $port) == -1) die ("recvfrom MSG_ERRQUEUE");
+$bytes_recv = socket_recvfrom($s, $resp, 16, 0, $address, $port);
+echo "$bytes_sent sent!\n";
+echo "$bytes_recv received!\n";
+echo "Received $resp!";
+socket_close($s);
+socket_close($socket);
+?>
+--EXPECTF--
+16384 sent!
+16 received!
+Received 0123456789abcdef!