ext/sockets: follow-up on AF_PACKET support.

devnexen · devnexen · commit de018aa2c5fa · 2025-02-24T22:09:29.000Z
support from socket_recvfrom and exposing basic PHP userland type. close phpGH-17657
diff --git a/NEWS b/NEWS
@@ -145,6 +145,8 @@ PHP                                                                        NEWS
   . socket_getsockname/socket_create/socket_bind handled AF_PACKET family socket.
     (David Carlier)
   . Added IP_BINDANY for a socket to bind to any address. (David Carlier)
+  . Added support for ethernet frames data for socket_sendto/socket_recvfrom
+    for SOCK_RAW sockets. (David Carlier)
 
 - Sodium:
   . Fix overall theorical overflows on zend_string buffer allocations.
diff --git a/ext/sockets/config.m4 b/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 sockatmark])
-  AC_CHECK_HEADERS([sys/sockio.h linux/filter.h linux/if_packet.h linux/if_ether.h])
+  AC_CHECK_HEADERS([sys/sockio.h linux/filter.h linux/if_packet.h linux/if_ether.h netinet/ether.h])
   AC_DEFINE([HAVE_SOCKETS], [1],
     [Define to 1 if the PHP extension 'sockets' is available.])
 
diff --git a/ext/sockets/php_sockets.h b/ext/sockets/php_sockets.h
@@ -77,6 +77,10 @@ typedef struct {
 
 extern PHP_SOCKETS_API zend_class_entry *socket_ce;
 
+#ifdef AF_PACKET
+extern PHP_SOCKETS_API zend_class_entry *socket_ethinfo_ce;
+#endif
+
 static inline php_socket *socket_from_obj(zend_object *obj) {
 	return (php_socket *)((char *)(obj) - XtOffsetOf(php_socket, std));
 }
diff --git a/ext/sockets/sockets.c b/ext/sockets/sockets.c
@@ -41,6 +41,7 @@
 # include <netdb.h>
 # include <netinet/in.h>
 # include <netinet/tcp.h>
+# include <netinet/udp.h>
 # include <sys/un.h>
 # include <arpa/inet.h>
 # include <sys/time.h>
@@ -54,6 +55,11 @@
 # ifdef HAVE_IF_NAMETOINDEX
 #  include <net/if.h>
 # endif
+# ifdef HAVE_NETINET_ETHER_H
+#  include <netinet/ether.h>
+#  include <netinet/ip.h>
+#  include <linux/ipv6.h>
+# endif
 # if defined(HAVE_LINUX_SOCK_DIAG_H)
 #  include <linux/sock_diag.h>
 # else
@@ -120,6 +126,9 @@ static PHP_RSHUTDOWN_FUNCTION(sockets);
 
 zend_class_entry *socket_ce;
 static zend_object_handlers socket_object_handlers;
+#ifdef AF_PACKET
+zend_class_entry *socket_ethinfo_ce;
+#endif
 
 static zend_object *socket_create_object(zend_class_entry *class_type) {
 	php_socket *intern = zend_object_alloc(sizeof(php_socket), class_type);
@@ -482,6 +491,9 @@ static PHP_MINIT_FUNCTION(sockets)
 	socket_object_handlers.get_gc = socket_get_gc;
 	socket_object_handlers.compare = zend_objects_not_comparable;
 
+#if defined(AF_PACKET)
+	socket_ethinfo_ce = register_class_SocketEthernetInfo();
+#endif
 	address_info_ce = register_class_AddressInfo();
 	address_info_ce->create_object = address_info_create_object;
 	address_info_ce->default_object_handlers = &address_info_object_handlers;
@@ -1388,7 +1400,7 @@ PHP_FUNCTION(socket_bind)
 				struct sockaddr_ll *sa = (struct sockaddr_ll *) sock_type;
 				socklen_t sa_len = sizeof(sa);
 
-				if (getsockname(php_sock->bsd_socket, sock_type, &sa_len) < 0) {
+				if (getsockname(php_sock->bsd_socket, (struct sockaddr *)sa, &sa_len) < 0) {
 					zend_value_error("invalid AF_PACKET socket");
 					RETURN_THROWS();
 				}
@@ -1503,7 +1515,9 @@ PHP_FUNCTION(socket_recvfrom)
 	struct sockaddr_in6	sin6;
 #endif
 #ifdef AF_PACKET
-	//struct sockaddr_ll     sll;
+	struct sockaddr_ll     sll;
+	int protoid;
+	socklen_t protoidlen = sizeof(protoid);
 #endif
 	char				addrbuf[INET6_ADDRSTRLEN];
 	socklen_t			slen;
@@ -1532,6 +1546,15 @@ PHP_FUNCTION(socket_recvfrom)
 		RETURN_FALSE;
 	}
 
+#ifdef AF_PACKET
+	// ethernet header + payload
+	// possibly follow-up PR SOCK_DGRAM
+	if (php_sock->type == AF_PACKET && arg3 < 60) {
+		zend_argument_value_error(3, "must be at least 60 for AF_PACKET");
+		RETURN_THROWS();
+	}
+#endif
+
 	recv_buf = zend_string_alloc(arg3 + 1, 0);
 
 	switch (php_sock->type) {
@@ -1610,14 +1633,19 @@ PHP_FUNCTION(socket_recvfrom)
 			break;
 #endif
 #ifdef AF_PACKET
-			/*
 		case AF_PACKET:
-			// TODO expose and use proper ethernet frame type instead i.e. src mac, dst mac and payload to userland
-			// ditto for socket_sendto
+			getsockopt(php_sock->bsd_socket, SOL_SOCKET, SO_TYPE, (char *) &protoid, &protoidlen);
+
+			// TODO: SOCK_DGRAM support
+			if (protoid != SOCK_RAW) {
+				zend_argument_value_error(1, "must be SOCK_RAW socket type");
+				RETURN_THROWS();
+			}
 			slen = sizeof(sll);
 			memset(&sll, 0, sizeof(sll));
 			sll.sll_family = AF_PACKET;
 			char ifrname[IFNAMSIZ];
+			zval zpayload;
 
 			retval = recvfrom(php_sock->bsd_socket, ZSTR_VAL(recv_buf), arg3, arg4, (struct sockaddr *)&sll, (socklen_t *)&slen);
 
@@ -1626,20 +1654,93 @@ PHP_FUNCTION(socket_recvfrom)
 				zend_string_efree(recv_buf);
 				RETURN_FALSE;
 			}
-			ZSTR_LEN(recv_buf) = retval;
-			ZSTR_VAL(recv_buf)[ZSTR_LEN(recv_buf)] = '\0';
 
 			if (UNEXPECTED(!if_indextoname(sll.sll_ifindex, ifrname))) {
 				PHP_SOCKET_ERROR(php_sock, "unable to get the interface name", errno);
 				zend_string_efree(recv_buf);
 				RETURN_FALSE;
 			}
 
-			ZEND_TRY_ASSIGN_REF_NEW_STR(arg2, recv_buf);
+			struct ethhdr *e = (struct ethhdr *)ZSTR_VAL(recv_buf);
+			unsigned short protocol = ntohs(e->h_proto);
+			unsigned char *payload;
+
+			zval obj;
+			object_init_ex(&obj, socket_ethinfo_ce);
+			array_init(&zpayload);
+
+			switch (protocol) {
+				case ETH_P_IP: {
+					payload = ((unsigned char *)e + sizeof(struct ethhdr));
+					struct iphdr *ip = (struct iphdr *)payload;
+					unsigned char *ipdata = payload + (ip->ihl * 4);
+					struct in_addr s, d;
+					s.s_addr = ip->saddr;
+					d.s_addr = ip->daddr;
+					add_assoc_string(&zpayload, "ipsrc", inet_ntoa(s));
+					add_assoc_string(&zpayload, "ipdst", inet_ntoa(d));
+
+					switch (ip->protocol) {
+						case IPPROTO_TCP: {
+							struct tcphdr *tcp = (struct tcphdr *)ipdata;
+							add_assoc_long(&zpayload, "portsrc", ntohs(tcp->th_sport));
+							add_assoc_long(&zpayload, "portdst", ntohs(tcp->th_dport));
+							break;
+						}
+						case IPPROTO_UDP: {
+							struct udphdr *udp = (struct udphdr *)ipdata;
+							add_assoc_long(&zpayload, "portsrc", ntohs(udp->uh_sport));
+							add_assoc_long(&zpayload, "portdst", ntohs(udp->uh_dport));
+							break;
+						}
+						default:
+							zend_string_efree(recv_buf);
+							zval_ptr_dtor(&zpayload);
+							zval_ptr_dtor(&obj);
+							zend_value_error("unsupported ip header protocol");
+							RETURN_THROWS();
+					}
+					break;
+				}
+				case ETH_P_IPV6: {
+					payload = ((unsigned char *)e + sizeof(struct ethhdr));
+					struct ipv6hdr *ip = (struct ipv6hdr *)payload;
+					char s[INET6_ADDRSTRLEN], d[INET6_ADDRSTRLEN];
+					inet_ntop(AF_INET6, &ip->saddr, s, sizeof(s));
+					inet_ntop(AF_INET6, &ip->daddr, d, sizeof(d));
+					add_assoc_string(&zpayload, "ipsrc", s);
+					add_assoc_string(&zpayload, "ipdst", d);
+					break;
+				}
+				case ETH_P_LOOP: {
+					struct ethhdr *innere = (struct ethhdr *)((unsigned char *)e + ETH_HLEN);
+					add_assoc_string(&zpayload, "macsrc", ether_ntoa((struct ether_addr *)innere->h_source));
+					add_assoc_string(&zpayload, "macdst", ether_ntoa((struct ether_addr *)innere->h_dest));
+					break;
+				}
+				default:
+					zend_string_efree(recv_buf);
+					zval_ptr_dtor(&zpayload);
+					zval_ptr_dtor(&obj);
+					zend_value_error("unsupported ethernet protocol");
+					RETURN_THROWS();
+			}
+
+			Z_DELREF(zpayload);
+			zend_string_efree(recv_buf);
+			zend_update_property(Z_OBJCE(obj), Z_OBJ(obj), ZEND_STRL("socket"), arg1);
+			zend_update_property_string(Z_OBJCE(obj), Z_OBJ(obj), ZEND_STRL("macsrc"), ether_ntoa((struct ether_addr *)e->h_source));
+			zend_update_property_string(Z_OBJCE(obj), Z_OBJ(obj), ZEND_STRL("macdst"), ether_ntoa((struct ether_addr *)e->h_dest));
+			zend_update_property_long(Z_OBJCE(obj), Z_OBJ(obj), ZEND_STRL("ethprotocol"), protocol);
+			zend_update_property(Z_OBJCE(obj), Z_OBJ(obj), ZEND_STRL("payload"), &zpayload);
+
+			ZEND_TRY_ASSIGN_REF_VALUE(arg2, &obj);
 			ZEND_TRY_ASSIGN_REF_STRING(arg5, ifrname);
-			ZEND_TRY_ASSIGN_REF_LONG(arg6, sll.sll_ifindex);
+
+			if (arg6) {
+				ZEND_TRY_ASSIGN_REF_LONG(arg6, sll.sll_ifindex);
+			}
 			break;
-			*/
 #endif
 		default:
 			zend_argument_value_error(1, "must be one of AF_UNIX, AF_INET, or AF_INET6");
@@ -1661,7 +1762,10 @@ PHP_FUNCTION(socket_sendto)
 	struct sockaddr_in6	sin6;
 #endif
 #ifdef AF_PACKET
-	//struct sockaddr_ll      sll;
+	struct sockaddr_ll      sll;
+	unsigned char           halen;
+	int protoid;
+	socklen_t protoidlen = sizeof(protoid);
 #endif
 	int					retval;
 	size_t              buf_len;
@@ -1694,6 +1798,15 @@ PHP_FUNCTION(socket_sendto)
 		RETURN_THROWS();
 	}
 
+#ifdef AF_PACKET
+	// ether header + payload
+	// TODO dealing with SOCK_DGRAM
+	if (php_sock->type == AF_PACKET && len < 60) {
+		zend_argument_value_error(3, "must be at least 64 for AF_PACKET");
+		RETURN_THROWS();
+	}
+#endif
+
 	switch (php_sock->type) {
 		case AF_UNIX:
 			memset(&s_un, 0, sizeof(s_un));
@@ -1738,23 +1851,33 @@ PHP_FUNCTION(socket_sendto)
 			break;
 #endif
 #ifdef AF_PACKET
-			/*
 		case AF_PACKET:
+			getsockopt(php_sock->bsd_socket, SOL_SOCKET, SO_TYPE, (char *) &protoid, &protoidlen);
+
+			// TODO: SOCK_DGRAM support
+			if (protoid != SOCK_RAW) {
+				zend_argument_value_error(1, "must be SOCK_RAW socket type");
+				RETURN_THROWS();
+			}
 			if (port_is_null) {
 				zend_argument_value_error(6, "cannot be null when the socket type is AF_PACKET");
 				RETURN_THROWS();
 			}
 
+			halen = ZSTR_LEN(addr) > ETH_ALEN ? ETH_ALEN : (unsigned char)ZSTR_LEN(addr);
+
 			memset(&sll, 0, sizeof(sll));			
+			memcpy(sll.sll_addr, addr, halen);
 			sll.sll_family = AF_PACKET;
 			sll.sll_ifindex = port;
+			sll.sll_halen = halen;
 
-			retval = sendto(php_sock->bsd_socket, buf, ((size_t)len > buf_len) ? buf_len : (size_t)len, flags, (struct sockaddr *) &sin, sizeof(sin));
+			// TODO allows to use more user friendly type to replace raw buffer usage
+			retval = sendto(php_sock->bsd_socket, buf, ((size_t)len > buf_len) ? buf_len : (size_t)len, flags, (struct sockaddr *) &sll, sizeof(sll));
 			break;
-		*/
 #endif
 		default:
-			zend_argument_value_error(1, "must be one of AF_UNIX, AF_INET, or AF_INET6");
+			zend_argument_value_error(1, "must be one of AF_UNIX, AF_INET, AF_PACKET or AF_INET6");
 			RETURN_THROWS();
 	}
 
@@ -2880,8 +3003,6 @@ PHP_FUNCTION(socket_addrinfo_connect)
 
 	ai = Z_ADDRESS_INFO_P(arg1);
 
-	PHP_ETH_PROTO_CHECK(ai->addrinfo.ai_protocol, ai->addrinfo.ai_family);
-
 	object_init_ex(return_value, socket_ce);
 	php_sock = Z_SOCKET_P(return_value);
 
diff --git a/ext/sockets/sockets.stub.php b/ext/sockets/sockets.stub.php
@@ -2013,6 +2013,11 @@
  * @cvalue ETH_P_ALL
  */
 const ETH_P_ALL = UNKNOWN;
+/**
+ * @var int
+ * @cvalue ETH_FRAME_LEN
+ */
+const ETH_FRAME_LEN = UNKNOWN;
 #endif
 
 /**
@@ -2156,3 +2161,19 @@ function socket_wsaprotocol_info_import(string $info_id): Socket|false {}
 
 function socket_wsaprotocol_info_release(string $info_id): bool {}
 #endif
+
+#ifdef AF_PACKET
+final class SocketEthernetInfo
+{
+    /** @readonly **/
+    public Socket $socket;
+    /** @readonly **/
+    public int $ethprotocol;
+    /** @readonly **/
+    public string $macsrc;
+    /** @readonly **/
+    public string $macdst;
+    /** @readonly **/
+    public array $payload;
+}
+#endif
diff --git a/ext/sockets/sockets_arginfo.h b/ext/sockets/sockets_arginfo.h
diff --git a/ext/sockets/tests/socket_afpacket.phpt b/ext/sockets/tests/socket_afpacket.phpt

Original file line number	Diff line number	Diff line change
`@@ -77,6 +77,10 @@ typedef struct {`
`77`	`77`
`78`	`78`	`extern PHP_SOCKETS_API zend_class_entry *socket_ce;`
`79`	`79`
	`80`	`+#ifdef AF_PACKET`
	`81`	`+extern PHP_SOCKETS_API zend_class_entry *socket_ethinfo_ce;`
	`82`	`+#endif`
	`83`	`+`
`80`	`84`	`static inline php_socket socket_from_obj(zend_object obj) {`
`81`	`85`	`return (php_socket )((char )(obj) - XtOffsetOf(php_socket, std));`
`82`	`86`	`}`