socket module add SO_ATTACH_REUSEPORT_CPBF for Linux.

to be used in conjunction with SO_REUSPORT, giving a greater control
over how we bind a socket instead of the round robin workflow, we do
 instead attach to the processor id as :
- we assign the processor_id to A in the BPF filter.
- then returns A.

in other words, a more modern version of SO_INCOMING_CPU (ie can have a per
 worker notion we do not use here).

Author: devnexen

ext/sockets/config.m4

@@ -5,7 +5,7 @@ PHP_ARG_ENABLE([sockets],
 
 if test "$PHP_SOCKETS" != "no"; then
   AC_CHECK_FUNCS([hstrerror if_nametoindex if_indextoname])
-  AC_CHECK_HEADERS([netinet/tcp.h sys/un.h sys/sockio.h])
+  AC_CHECK_HEADERS([netinet/tcp.h sys/un.h sys/sockio.h linux/filter.h])
   AC_DEFINE([HAVE_SOCKETS], 1, [ ])
 
   dnl Check for fied ss_family in sockaddr_storage (missing in AIX until 5.3)

ext/sockets/sockets.c

@@ -1733,6 +1733,7 @@ PHP_FUNCTION(socket_get_option)
 				return;
 			}
 #endif
+
 		}
 	}
 
@@ -1952,6 +1953,26 @@ PHP_FUNCTION(socket_set_option)
 		}
 #endif
 
+#ifdef SO_ATTACH_REUSEPORT_CBPF
+		case SO_ATTACH_REUSEPORT_CBPF: {
+			convert_to_long(arg4);
+			if (!Z_LVAL_P(arg4)) {
+				RETURN_FALSE;
+			}
+			static struct sock_filter cbpf[] = {
+				BPF_STMT((BPF_LD|BPF_W|BPF_ABS), (uint32_t)(SKF_AD_OFF+SKF_AD_CPU)),
+				BPF_STMT((BPF_RET|BPF_A), 0),
+			};
+			static struct sock_fprog bpfprog = {
+				.len = (sizeof(cbpf) / sizeof(cbpf[0])),
+				.filter = cbpf,
+			};
+			optlen = sizeof(bpfprog);
+			opt_ptr = &bpfprog;
+			break;
+		}
+#endif
+
 		default:
 default_case:
 			convert_to_long(arg4);

ext/sockets/sockets.stub.php

@@ -1678,6 +1678,27 @@
  */
 const LOCAL_CREDS = UNKNOWN;
 #endif
+#if defined(SO_ATTACH_REUSEPORT_CBPF)
+/**
+ * @var int
+ * @cvalue SO_ATTACH_REUSEPORT_CBPF
+ */
+const SO_ATTACH_REUSEPORT_CBPF = UNKNOWN;
+#endif
+#if defined(SO_DETACH_FILTER)
+/**
+ * @var int
+ * @cvalue SO_DETACH_FILTER
+ */
+const SO_DETACH_FILTER = UNKNOWN;
+#endif
+#if defined(SO_DETACH_BPF)
+/**
+ * @var int
+ * @cvalue SO_DETACH_BPF
+ */
+const SO_DETACH_BPF = UNKNOWN;
+#endif
 
 /**
  * @strict-properties

ext/sockets/sockets_arginfo.h

@@ -0,0 +1,30 @@
+--TEST--
+Test if socket_set_option() works, option:SO_ATTACH_REUSEPORT_CBPF
+--EXTENSIONS--
+sockets
+--SKIPIF--
+<?php
+
+if (!defined("SO_ATTACH_REUSEPORT_CBPF")) {
+	die('SKIP on platforms not supporting SO_ATTACH_REUSEPORT_CBPF');
+}
+?>
+--FILE--
+<?php
+$socket = socket_create(AF_INET, SOCK_STREAM, SOL_TCP);
+
+if (!$socket) {
+        die('Unable to create AF_INET socket [socket]');
+}
+var_dump(socket_set_option( $socket, SOL_SOCKET, SO_REUSEADDR, true));
+var_dump(socket_set_option( $socket, SOL_SOCKET, SO_REUSEPORT, true));
+var_dump(socket_set_option( $socket, SOL_SOCKET, SO_ATTACH_REUSEPORT_CBPF, true));
+var_dump(socket_bind($socket, '0.0.0.0'));
+socket_listen($socket);
+socket_close($socket);
+?>
+--EXPECT--
+bool(true)
+bool(true)
+bool(true)
+bool(true)