IP forwarding: Add missing ICMP support.
This commit is contained in:
parent
04716a65a5
commit
efdc5b0c29
@ -156,7 +156,7 @@ static int ipv4_decr_ttl(FAR struct ipv4_hdr_s *ipv4)
|
||||
{
|
||||
#ifdef CONFIG_NET_ICMP
|
||||
/* Return an ICMP error packet back to the sender. */
|
||||
#warning Missing logic
|
||||
# warning Missing logic
|
||||
#endif
|
||||
|
||||
/* Return zero which must cause the packet to be dropped */
|
||||
@ -413,7 +413,16 @@ static int ipv4_dev_forward(FAR struct net_driver_s *dev,
|
||||
break;
|
||||
#endif
|
||||
|
||||
case IP_PROTO_ICMP: /* Not yet supported */
|
||||
#ifdef CONFIG_NET_ICMP
|
||||
case IP_PROTO_ICMP:
|
||||
{
|
||||
/* Forward an ICMP packet */
|
||||
|
||||
ret = icmp_forward(fwd);
|
||||
}
|
||||
break;
|
||||
#endif
|
||||
|
||||
default:
|
||||
nwarn("WARNING: Unrecognized proto: %u\n", ipv4->proto);
|
||||
ret = -EPROTONOSUPPORT;
|
||||
|
@ -218,7 +218,7 @@ static int ipv6_decr_ttl(FAR struct ipv6_hdr_s *ipv6)
|
||||
{
|
||||
#ifdef CONFIG_NET_ICMPv6
|
||||
/* Return an ICMPv6 error packet back to the sender. */
|
||||
#warning Missing logic
|
||||
# warning Missing logic
|
||||
#endif
|
||||
|
||||
/* Return zero which must cause the packet to be dropped */
|
||||
|
@ -43,6 +43,14 @@ ifeq ($(CONFIG_NET_ICMP_PING),y)
|
||||
NET_CSRCS += icmp_ping.c icmp_poll.c icmp_send.c
|
||||
endif
|
||||
|
||||
# IP forwarding
|
||||
|
||||
ifeq ($(CONFIG_NET_IPFORWARD),y)
|
||||
ifeq ($(CONFIG_NETDEV_MULTINIC),y)
|
||||
NET_CSRCS += icmp_forward.c
|
||||
endif
|
||||
endif
|
||||
|
||||
# Include ICMP build support
|
||||
|
||||
DEPPATH += --dep-path icmp
|
||||
|
297
net/icmp/icmp_foward.c
Normal file
297
net/icmp/icmp_foward.c
Normal file
@ -0,0 +1,297 @@
|
||||
/****************************************************************************
|
||||
* net/icmp/icmp_forward.c
|
||||
*
|
||||
* Copyright (C) 2017 Gregory Nutt. All rights reserved.
|
||||
* Author: Gregory Nutt <gnutt@nuttx.org>
|
||||
*
|
||||
* Redistribution and use in source and binary forms, with or without
|
||||
* modification, are permitted provided that the following conditions
|
||||
* are met:
|
||||
*
|
||||
* 1. Redistributions of source code must retain the above copyright
|
||||
* notice, this list of conditions and the following disclaimer.
|
||||
* 2. Redistributions in binary form must reproduce the above copyright
|
||||
* notice, this list of conditions and the following disclaimer in the
|
||||
* documentation and/or other materials provided with the distribution.
|
||||
* 3. The name of the author may not be used to endorse or promote
|
||||
* products derived from this software without specific prior
|
||||
* written permission.
|
||||
*
|
||||
* THIS SOFTWARE IS PROVIDED BY THE AUTHOR ``AS IS'' AND ANY EXPRESS
|
||||
* OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE IMPLIED
|
||||
* WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE
|
||||
* ARE DISCLAIMED. IN NO EVENT SHALL THE AUTHOR BE LIABLE FOR ANY
|
||||
* DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL
|
||||
* DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE
|
||||
* GOODS OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS
|
||||
* INTERRUPTION) HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY,
|
||||
* WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT (INCLUDING
|
||||
* NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE OF THIS
|
||||
* SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.
|
||||
*
|
||||
****************************************************************************/
|
||||
|
||||
/****************************************************************************
|
||||
* Included Files
|
||||
****************************************************************************/
|
||||
|
||||
#include <nuttx/config.h>
|
||||
|
||||
#include <assert.h>
|
||||
#include <errno.h>
|
||||
#include <debug.h>
|
||||
|
||||
#include <net/if.h>
|
||||
|
||||
#include <nuttx/mm/iob.h>
|
||||
#include <nuttx/net/net.h>
|
||||
#include <nuttx/net/netdev.h>
|
||||
#include <nuttx/net/ip.h>
|
||||
#include <nuttx/net/netstats.h>
|
||||
|
||||
#include "devif/ip_forward.h"
|
||||
#include "devif/devif.h"
|
||||
#include "netdev/netdev.h"
|
||||
#include "arp/arp.h"
|
||||
#include "neighbor/neighbor.h"
|
||||
#include "icmp/icmp.h"
|
||||
|
||||
#if defined(CONFIG_NET_IPFORWARD) && defined(CONFIG_NET_ICMP) && \
|
||||
defined(CONFIG_NETDEV_MULTINIC)
|
||||
|
||||
/****************************************************************************
|
||||
* Public Functions
|
||||
****************************************************************************/
|
||||
|
||||
/****************************************************************************
|
||||
* Name: icmp_forward_addrchck
|
||||
*
|
||||
* Description:
|
||||
* Check if the destination IP address is in the IPv4 ARP table. If not,
|
||||
* then the send won't actually make it out... it will be replaced with an
|
||||
* ARP request (IPv4).
|
||||
*
|
||||
* NOTE 1: This could be an expensive check if there are a lot of
|
||||
* entries in the ARP table.
|
||||
*
|
||||
* NOTE 2: If we are actually harvesting IP addresses on incoming IP
|
||||
* packets, then this check should not be necessary; the MAC mapping
|
||||
* should already be in the ARP table in many cases.
|
||||
*
|
||||
* NOTE 3: If CONFIG_NET_ARP_SEND then we can be assured that the IP
|
||||
* address mapping is already in the ARP table.
|
||||
*
|
||||
* Parameters:
|
||||
* fwd - The forwarding state structure
|
||||
*
|
||||
* Returned Value:
|
||||
* true - The Ethernet MAC address is in the ARP table (OR the network
|
||||
* device is not Ethernet).
|
||||
*
|
||||
* Assumptions:
|
||||
* The network is locked.
|
||||
*
|
||||
****************************************************************************/
|
||||
|
||||
#ifdef CONFIG_NET_ETHERNET
|
||||
static inline bool icmp_forward_addrchck(FAR struct forward_s *fwd)
|
||||
{
|
||||
/* REVISIT: Could the MAC address not also be in a routing table? */
|
||||
|
||||
#ifdef CONFIG_NET_MULTILINK
|
||||
if (fwd->f_dev->d_lltype != NET_LL_ETHERNET)
|
||||
{
|
||||
return true;
|
||||
}
|
||||
#endif
|
||||
|
||||
#if !defined(CONFIG_NET_ARP_IPIN) && !defined(CONFIG_NET_ARP_SEND)
|
||||
return (arp_find(fwd->f_hdr.ipv4.l2.destipaddr) != NULL);
|
||||
#else
|
||||
return true;
|
||||
#endif
|
||||
}
|
||||
|
||||
#else /* CONFIG_NET_ETHERNET */
|
||||
# define icmp_forward_addrchck(fwd) (true)
|
||||
#endif /* CONFIG_NET_ETHERNET */
|
||||
|
||||
/****************************************************************************
|
||||
* Name: icmp_dropstats
|
||||
*
|
||||
* Description:
|
||||
* Update statistics for a dropped packet.
|
||||
*
|
||||
* Input Parameters:
|
||||
* fwd - The forwarding state structure
|
||||
*
|
||||
* Returned Value:
|
||||
* None
|
||||
*
|
||||
****************************************************************************/
|
||||
|
||||
#ifdef CONFIG_NET_STATISTICS
|
||||
static inline void icmp_dropstats(FAR struct forward_s *fwd)
|
||||
{
|
||||
/* Increment the count of dropped ICMP packets */
|
||||
|
||||
g_netstats.icmp.drop++;
|
||||
g_netstats.ipv4.drop++;
|
||||
}
|
||||
#else
|
||||
# define icmp_dropstats(fwd)
|
||||
#endif
|
||||
|
||||
/****************************************************************************
|
||||
* Name: icmp_forward_interrupt
|
||||
*
|
||||
* Description:
|
||||
* This function is called from the interrupt level to perform the actual
|
||||
* send operation when polled by the lower, device interfacing layer.
|
||||
*
|
||||
* Parameters:
|
||||
* dev The structure of the network driver that caused the interrupt
|
||||
* conn An instance of the ICMP connection structure cast to void *
|
||||
* pvpriv An instance of struct forward_s cast to void*
|
||||
* flags Set of events describing why the callback was invoked
|
||||
*
|
||||
* Returned Value:
|
||||
* Modified value of the input flags
|
||||
*
|
||||
* Assumptions:
|
||||
* The network is locked
|
||||
*
|
||||
****************************************************************************/
|
||||
|
||||
static uint16_t icmp_forward_interrupt(FAR struct net_driver_s *dev,
|
||||
FAR void *conn, FAR void *pvpriv,
|
||||
uint16_t flags)
|
||||
{
|
||||
FAR struct forward_s *fwd = (FAR struct forward_s *)pvpriv;
|
||||
|
||||
ninfo("flags: %04x\n", flags);
|
||||
DEBUGASSERT(fwd != NULL);
|
||||
|
||||
/* Make sure that this is from the forwarding device */
|
||||
|
||||
if (dev == fwd->f_dev)
|
||||
{
|
||||
/* If the network device has gone down, then we will have terminate
|
||||
* the wait now with an error.
|
||||
*/
|
||||
|
||||
if ((flags & NETDEV_DOWN) != 0)
|
||||
{
|
||||
/* Terminate the transfer with an error. */
|
||||
|
||||
nwarn("WARNING: Network is down... Dropping\n");
|
||||
icmp_dropstats(fwd);
|
||||
}
|
||||
|
||||
/* Check if the outgoing packet is available. It may have been claimed
|
||||
* by another send interrupt serving a different thread -OR- if the output
|
||||
* buffer currently contains unprocessed incoming data. In these cases
|
||||
* we will just have to wait for the next polling cycle.
|
||||
*/
|
||||
|
||||
else if (dev->d_sndlen > 0 || (flags & ICMP_NEWDATA) != 0)
|
||||
{
|
||||
/* Another thread has beat us sending data or the buffer is busy,
|
||||
* Wait for the next polling cycle and check again.
|
||||
*/
|
||||
|
||||
return flags;
|
||||
}
|
||||
|
||||
/* It looks like we are good to forward the data */
|
||||
|
||||
else
|
||||
{
|
||||
/* Copy the ICMP data into driver's packet buffer and send it. */
|
||||
|
||||
devif_forward(fwd);
|
||||
|
||||
/* Check if the destination IP address is in the ARP or Neighbor
|
||||
* table. If not, then the send won't actually make it out... it
|
||||
* will be replaced with an ARP request or Neighbor Solicitation.
|
||||
*/
|
||||
|
||||
if (!icmp_forward_addrchck(fwd))
|
||||
{
|
||||
return flags;
|
||||
}
|
||||
}
|
||||
|
||||
/* Free the allocated callback structure */
|
||||
|
||||
fwd->f_cb->flags = 0;
|
||||
fwd->f_cb->priv = NULL;
|
||||
fwd->f_cb->event = NULL;
|
||||
|
||||
icmp_callback_free(dev, fwd->f_cb);
|
||||
|
||||
/* Free any IOBs */
|
||||
|
||||
if (fwd->f_iob != NULL)
|
||||
{
|
||||
iob_free_chain(fwd->f_iob);
|
||||
}
|
||||
|
||||
/* And release the forwarding state structure */
|
||||
|
||||
ip_forward_free(fwd);
|
||||
}
|
||||
|
||||
return flags;
|
||||
}
|
||||
|
||||
/****************************************************************************
|
||||
* Public Functions
|
||||
****************************************************************************/
|
||||
|
||||
/****************************************************************************
|
||||
* Name: icmp_forward
|
||||
*
|
||||
* Description:
|
||||
* Called by the IP forwarding logic when an ICMP packet is received on
|
||||
* one network device, but must be forwarded on another network device.
|
||||
*
|
||||
* Set up to forward the ICMP packet on the specified device. This
|
||||
* function will set up a send "interrupt" handler that will perform the
|
||||
* actual send asynchronously and must return without waiting for the
|
||||
* send to complete.
|
||||
*
|
||||
* Input Parameters:
|
||||
* fwd - An initialized instance of the common forwarding structure that
|
||||
* includes everything needed to perform the forwarding operation.
|
||||
*
|
||||
* Returned Value:
|
||||
* Zero is returned if the packet was successfully forwarded; A negated
|
||||
* errno value is returned if the packet is not forwardable. In that
|
||||
* latter case, the caller should free the IOB list and drop the packet.
|
||||
*
|
||||
****************************************************************************/
|
||||
|
||||
int icmp_forward(FAR struct forward_s *fwd)
|
||||
{
|
||||
DEBUGASSERT(fwd != NULL && fwd->f_dev != NULL);
|
||||
|
||||
/* Set up the callback in the connection */
|
||||
|
||||
fwd->f_cb = icmp_callback_alloc(fwd->f_dev);
|
||||
if (fwd->f_cb != NULL)
|
||||
{
|
||||
fwd->f_cb->flags = (ICMP_POLL | NETDEV_DOWN);
|
||||
fwd->f_cb->priv = (FAR void *)fwd;
|
||||
fwd->f_cb->event = icmp_forward_interrupt;
|
||||
|
||||
/* Notify the device driver of the availability of TX data */
|
||||
|
||||
netdev_txnotify_dev(fwd->f_dev);
|
||||
return OK;
|
||||
}
|
||||
|
||||
return -EBUSY;
|
||||
}
|
||||
|
||||
#endif /* CONFIG_NET_IPFORWARD && CONFIG_NET_ICMP && CONFIG_NETDEV_MULTINIC */
|
@ -1,7 +1,7 @@
|
||||
############################################################################
|
||||
# net/icmpv6/Make.defs
|
||||
#
|
||||
# Copyright (C) 2015 Gregory Nutt. All rights reserved.
|
||||
# Copyright (C) 2015, 2017 Gregory Nutt. All rights reserved.
|
||||
# Author: Gregory Nutt <gnutt@nuttx.org>
|
||||
#
|
||||
# Redistribution and use in source and binary forms, with or without
|
||||
|
@ -67,26 +67,22 @@
|
||||
* Name: icmpv6_forward_addrchck
|
||||
*
|
||||
* Description:
|
||||
* Check if the destination IP address is in the IPv4 ARP or IPv6 Neighbor
|
||||
* tables. If not, then the send won't actually make it out... it will be
|
||||
* replaced with an ARP request (IPv4) or a Neighbor Solicitation (IPv6).
|
||||
* Check if the destination IP address is in the Pv6 Neighbor table. If
|
||||
* not, then the send won't actually make it out... it will be replaced
|
||||
* with a Neighbor Solicitation.
|
||||
*
|
||||
* NOTE 1: This could be an expensive check if there are a lot of
|
||||
* entries in the ARP or Neighbor tables.
|
||||
* entries in the Neighbor table.
|
||||
*
|
||||
* NOTE 2: If we are actually harvesting IP addresses on incoming IP
|
||||
* packets, then this check should not be necessary; the MAC mapping
|
||||
* should already be in the ARP table in many cases (IPv4 only).
|
||||
*
|
||||
* NOTE 3: If CONFIG_NET_ARP_SEND then we can be assured that the IP
|
||||
* NOTE 2: If CONFIG_NET_ARP_SEND then we can be assured that the IP
|
||||
* address mapping is already in the ARP table.
|
||||
*
|
||||
* Parameters:
|
||||
* fwd - The forwarding state structure
|
||||
*
|
||||
* Returned Value:
|
||||
* true - The Ethernet MAC address is in the ARP or Neighbor table (OR
|
||||
* the network device is not Ethernet).
|
||||
* true - The Ethernet MAC address is in the Neighbor table (OR the
|
||||
* network device is not Ethernet).
|
||||
*
|
||||
* Assumptions:
|
||||
* The network is locked.
|
||||
@ -105,35 +101,15 @@ static inline bool icmpv6_forward_addrchck(FAR struct forward_s *fwd)
|
||||
}
|
||||
#endif
|
||||
|
||||
#ifdef CONFIG_NET_IPv4
|
||||
#ifdef CONFIG_NET_IPv6
|
||||
if ((fwd->f_hdr.ipv4.l2.vhl & IP_VERSION_MASK) == IPv4_VERSION)
|
||||
#endif
|
||||
{
|
||||
#if !defined(CONFIG_NET_ARP_IPIN) && !defined(CONFIG_NET_ARP_SEND)
|
||||
return (arp_find(fwd->f_hdr.ipv4.l2.destipaddr) != NULL);
|
||||
#else
|
||||
return true;
|
||||
#endif
|
||||
}
|
||||
#endif /* CONFIG_NET_IPv4 */
|
||||
|
||||
#ifdef CONFIG_NET_IPv6
|
||||
#ifdef CONFIG_NET_IPv4
|
||||
else
|
||||
#endif
|
||||
{
|
||||
#if !defined(CONFIG_NET_ICMPv6_NEIGHBOR)
|
||||
return (neighbor_findentry(fwd->f_hdr.ipv6.l2.destipaddr) != NULL);
|
||||
#else
|
||||
return true;
|
||||
#endif
|
||||
}
|
||||
#endif /* CONFIG_NET_IPv6 */
|
||||
}
|
||||
|
||||
#else /* CONFIG_NET_ETHERNET */
|
||||
# define icmpv6_forward_addrchck(r) (true)
|
||||
# define icmpv6_forward_addrchck(fwd) (true)
|
||||
#endif /* CONFIG_NET_ETHERNET */
|
||||
|
||||
/****************************************************************************
|
||||
@ -151,33 +127,15 @@ static inline bool icmpv6_forward_addrchck(FAR struct forward_s *fwd)
|
||||
****************************************************************************/
|
||||
|
||||
#ifdef CONFIG_NET_STATISTICS
|
||||
static void icmpv6_dropstats(FAR struct forward_s *fwd)
|
||||
static inline void icmpv6_dropstats(FAR struct forward_s *fwd)
|
||||
{
|
||||
/* Increment the count of dropped ICMPV6 packets */
|
||||
/* Increment the count of dropped ICMPv6 packets */
|
||||
|
||||
g_netstats.icmpv6.drop++;
|
||||
|
||||
/* Increment the count of dropped IPv4 or IPv6 packets */
|
||||
|
||||
#ifdef CONFIG_NET_IPv4
|
||||
#ifdef CONFIG_NET_IPv6
|
||||
if ((fwd->f_hdr.ipv4.l2.vhl & IP_VERSION_MASK) == IPv4_VERSION)
|
||||
#endif
|
||||
{
|
||||
g_netstats.ipv4.drop++;
|
||||
}
|
||||
#endif
|
||||
#ifdef CONFIG_NET_IPv6
|
||||
#ifdef CONFIG_NET_IPv4
|
||||
else
|
||||
#endif
|
||||
{
|
||||
g_netstats.ipv6.drop++;
|
||||
}
|
||||
#endif
|
||||
}
|
||||
#else
|
||||
# define icmpv6_dropstats(ipv6)
|
||||
# define icmpv6_dropstats(fwd)
|
||||
#endif
|
||||
|
||||
/****************************************************************************
|
||||
@ -189,7 +147,7 @@ static void icmpv6_dropstats(FAR struct forward_s *fwd)
|
||||
*
|
||||
* Parameters:
|
||||
* dev The structure of the network driver that caused the interrupt
|
||||
* conn An instance of the ICMPV6 connection structure cast to void *
|
||||
* conn An instance of the ICMPv6 connection structure cast to void *
|
||||
* pvpriv An instance of struct forward_s cast to void*
|
||||
* flags Set of events describing why the callback was invoked
|
||||
*
|
||||
@ -291,10 +249,10 @@ static uint16_t icmpv6_forward_interrupt(FAR struct net_driver_s *dev,
|
||||
* Name: icmpv6_forward
|
||||
*
|
||||
* Description:
|
||||
* Called by the IP forwarding logic when an ICMPV6 packet is received on
|
||||
* Called by the IP forwarding logic when an ICMPv6 packet is received on
|
||||
* one network device, but must be forwarded on another network device.
|
||||
*
|
||||
* Set up to forward the ICMPV6 packet on the specified device. This
|
||||
* Set up to forward the ICMPv6 packet on the specified device. This
|
||||
* function will set up a send "interrupt" handler that will perform the
|
||||
* actual send asynchronously and must return without waiting for the
|
||||
* send to complete.
|
||||
|
Loading…
Reference in New Issue
Block a user