net_core: Decide about l2-processing based on l2_processed-flag

Use the l2_processed-flag to decide whether a network packet needs to be
processed by an L2-handler. This could be used in the future to requeue
packets for later processing by a different traffic class queue.
Introduce a loopback-flag to aoivd passing the information around as
argument.

Signed-off-by: Cla Mattia Galliard <clamattia@gmail.com>

Author: ClaCodes

subsys/net/ip/ipv4_fragment.c

@@ -206,6 +206,11 @@ static void reassemble_packet(struct net_ipv4_reassembly *reass)
 	net_pkt_set_data(pkt, &ipv4_access);
 	net_pkt_set_ip_reassembled(pkt, true);
 
+	/* If the packet is reassembled, then do not pass it to L2 as the
+	 * packet does not have link layer headers in it.
+	 */
+	net_pkt_set_l2_processed(pkt, true);
+
 	LOG_DBG("New pkt %p IPv4 len is %zd bytes", pkt, net_pkt_get_len(pkt));
 
 	/* We need to use the queue when feeding the packet back into the

subsys/net/ip/ipv6_fragment.c

@@ -340,6 +340,11 @@ static void reassemble_packet(struct net_ipv6_reassembly *reass)
 	net_pkt_set_data(pkt, &ipv6_access);
 	net_pkt_set_ip_reassembled(pkt, true);
 
+	/* If the packet is reassembled, then do not pass it to L2 as the
+	 * packet does not have link layer headers in it.
+	 */
+	net_pkt_set_l2_processed(pkt, true);
+
 	NET_DBG("New pkt %p IPv6 len is %d bytes", pkt,
 		len + NET_IPV6H_LEN);
 

subsys/net/ip/net_core.c

@@ -67,23 +67,13 @@ LOG_MODULE_REGISTER(net_core, CONFIG_NET_CORE_LOG_LEVEL);
 static inline enum net_verdict process_data(struct net_pkt *pkt)
 {
 	int ret;
-	bool locally_routed = false;
-
-	net_pkt_set_l2_processed(pkt, false);
 
 	/* Initial call will forward packets to SOCK_RAW packet sockets. */
 	ret = net_packet_socket_input(pkt, ETH_P_ALL);
 	if (ret != NET_CONTINUE) {
 		return ret;
 	}
 
-	/* If the packet is routed back to us when we have reassembled an IPv4 or IPv6 packet,
-	 * then do not pass it to L2 as the packet does not have link layer headers in it.
-	 */
-	if (net_pkt_is_ip_reassembled(pkt)) {
-		locally_routed = true;
-	}
-
 	/* If there is no data, then drop the packet. */
 	if (!pkt->frags) {
 		NET_DBG("Corrupted packet (frags %p)", pkt->frags);
@@ -92,8 +82,9 @@ static inline enum net_verdict process_data(struct net_pkt *pkt)
 		return NET_DROP;
 	}
 
-	if (!net_pkt_is_loopback(pkt) && !locally_routed) {
+	if (!net_pkt_is_l2_processed(pkt)) {
 		ret = net_if_recv_data(net_pkt_iface(pkt), pkt);
+		net_pkt_set_l2_processed(pkt, true);
 		if (ret != NET_CONTINUE) {
 			if (ret == NET_DROP) {
 				NET_DBG("Packet %p discarded by L2", pkt);
@@ -105,8 +96,6 @@ static inline enum net_verdict process_data(struct net_pkt *pkt)
 		}
 	}
 
-	net_pkt_set_l2_processed(pkt, true);
-
 	/* L2 has modified the buffer starting point, it is easier
 	 * to re-initialize the cursor rather than updating it.
 	 */
@@ -421,6 +410,7 @@ int net_try_send_data(struct net_pkt *pkt, k_timeout_t timeout)
 		 */
 		NET_DBG("Loopback pkt %p back to us", pkt);
 		net_pkt_set_loopback(pkt, true);
+		net_pkt_set_l2_processed(pkt, true);
 		processing_data(pkt);
 		ret = 0;
 		goto err;
@@ -493,6 +483,7 @@ static void net_rx(struct net_if *iface, struct net_pkt *pkt)
 #ifdef CONFIG_NET_L2_DUMMY
 		if (net_if_l2(iface) == &NET_L2_GET_NAME(DUMMY)) {
 			net_pkt_set_loopback(pkt, true);
+			net_pkt_set_l2_processed(pkt, true);
 		}
 #endif
 	}