ip_input.c

VXWORKS源代码

/* ip_input.c - internet input routines */

/* Copyright 1984 - 2002 Wind River Systems, Inc. */
#include "copyright_wrs.h"

/*
 * Copyright (c) 1982, 1986, 1988, 1993
 *	The Regents of the University of California.  All rights reserved.
 *
 * 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. All advertising materials mentioning features or use of this software
 *    must display the following acknowledgement:
 *	This product includes software developed by the University of
 *	California, Berkeley and its contributors.
 * 4. Neither the name of the University nor the names of its contributors
 *    may be used to endorse or promote products derived from this software
 *    without specific prior written permission.
 *
 * THIS SOFTWARE IS PROVIDED BY THE REGENTS AND CONTRIBUTORS ``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 REGENTS OR CONTRIBUTORS 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.
 *
 *	@(#)ip_input.c	8.2 (Berkeley) 1/4/94
 */

/*
modification history
--------------------
01y,15apr02,wap  reinstate netJobAdd removal changes
01x,29mar02,wap  back out the previous change (needs more investigation)
01w,21mar02,rae  ipintr called directly (SPR #74604)
01v,03jan02,vvv  fixed reassembly problem for large packets with reordered
		 fragments (SPR #71746)
01u,12oct01,rae  merge from truestack ver 02f, base 01r (SPRs 69722,
                 69112, 27706, etc)
01t,07dec00,rae  added IPsec input hook
01s,27sep00,rae  fixed ping of death bug
01r,08nov99,pul  merging T2 cumulative patch 2
01q,04jun99,spm  corrected ip_forward() routine to handle source routing
                 options for hosts (SPR #27727)
01p,28feb99,ham  corrected comment below - (wrong)34040 -> (right)32767.
01o,28feb99,ham  fixed reassembly problem larger ip_off 34040, spr#23250.
01n,09jan98,vin  changed IP_CKSUM_RECV_MASK to IP_DO_CHECKSUM_RCV
01m,13nov97,vin  added HTONS(ip->ip_len) in ip_forward before icmp_error,
		 consolidated all flags into ipCfgFlags.
01l,28oct97,vin  reverted on the fix in version01j, what was vin thinking.
01k,15jul97,spm  made IP checksum calculation configurable (SPR #7836)
01j,05jun97,vin  fixed problem in ip_forward().HTONS(ip_len).
01i,17apr97,vin  added more functionality to the ipFilterHook.
01h,08mar97,vin  added mCastRouteFwdHook to access mcast routing code.
01g,11apr97,rjc  added ipFilter Hook and strongEnded flag processing.
01f,04mar97,vin  added fix to null domain pointer in ip_init SPR 8078.
01e,05feb97,rjc  tos routing changes
01d,31jan97,vin  changed declaration according to prototype decl in protosw.h
01c,07jan96,vin  moved iptime() from ip_icmp, added _icmpErrorHook instead
		 of icmp_error() for scalability, added ipfragttl. 
01b,30oct96,vin  re-worked ipreassembly, made it free from dtom macros.
		 added ipReAssembly, replace m_get(..) with mBufClGet(..)
01a,03mar96,vin  created from BSD4.4 stuff,integrated with 02r of ip_input.c
*/

#include "vxWorks.h"
#include "tickLib.h"
#include "netLib.h"
#include "net/systm.h"
#include "net/mbuf.h"
#include "net/domain.h"
#include "net/protosw.h"
#include "sys/socket.h"
#include "errno.h"

#include "net/if.h"
#include "net/route.h"

#include "netinet/in.h"
#include "netinet/in_pcb.h"
#include "netinet/in_systm.h"
#include "netinet/in_var.h"
#include "netinet/ip.h"
#include "netinet/ip_var.h"
#include "netinet/ip_icmp.h"

#ifdef WV_INSTRUMENTATION
#ifdef INCLUDE_WVNET
#include "wvNetLib.h"
#endif
#endif

#ifdef VIRTUAL_STACK
#include "netinet/vsLib.h"
#include "netinet/vsMcast.h"
#endif /* VIRTUAL_STACK */

extern void _insque();
extern void _remque();
extern int sysClkRateGet();
extern int routeDrain();

#ifndef VIRTUAL_STACK
extern VOIDFUNCPTR _icmpErrorHook;
extern FUNCPTR _mCastRouteFwdHook;	/* WRS mcast forward command hook */
#endif /* VIRTUAL_STACK */

extern FUNCPTR _ipFilterHook;           /* ipFilter hook defined in netLib.c */

/*IPsec input hook defined in /target/src/wrn/ipsec/ipsec_io.c */
typedef int     (*IPSEC_INPUT_FUNCPTR)  (struct mbuf** m, int hlen, struct ip** ip);
IPSEC_INPUT_FUNCPTR             _func_ipsecInput;


/*IPsec filter hook is defined in /target/src/wrn/ipsec/ipsec_io.c */ 

typedef int    (*IPSEC_FILTER_HOOK_FUNCPTR) (struct mbuf** m, struct ip** ip, int hlen);

IPSEC_FILTER_HOOK_FUNCPTR       _func_ipsecFilterHook; 

/* globals */

#ifndef	IPFORWARDING
#ifdef GATEWAY
#define	IPFORWARDING	1	/* forward IP packets not for us */
#else /* GATEWAY */
#define	IPFORWARDING	0	/* don't forward IP packets not for us */
#endif /* GATEWAY */
#endif /* IPFORWARDING */
#ifndef	IPSENDREDIRECTS
#define	IPSENDREDIRECTS	1
#endif

#define FORWARD_BROADCASTS

#ifdef FORWARD_BROADCASTS
#define DIRECTED_BROADCAST
FUNCPTR	proxyBroadcastHook = NULL;
#endif

#ifndef VIRTUAL_STACK
int	_ipCfgFlags;			/* ip configurations, bit field flag */
int	ip_defttl = IPDEFTTL;		/* default IP ttl */
int	ipfragttl = IPFRAGTTL;		/* default IP fragment timeout */
#ifdef DIAGNOSTIC
int	ipprintfs = 0;
#endif
int     ipStrongEnded = FALSE;             /* default ip ended'ness */

extern	struct domain inetdomain;
extern	struct protosw inetsw[];

u_char	ip_protox[IPPROTO_MAX];

int	ipqmaxlen = IFQ_MAXLEN;
struct	in_ifaddr *in_ifaddr;		/* first inet address */
struct	ipstat	ipstat;
struct	ipq	ipq;			/* ip reass. queue */
u_short	ip_id;				/* ip packet ctr, for ids */

int	ip_nhops = 0;
#endif /* VIRTUAL_STACK */

#ifdef WV_INSTRUMENTATION
#ifdef INCLUDE_WVNET
    /* Set common fields of event identifiers for this module. */

LOCAL UCHAR wvNetModuleId = WV_NET_IPINPUT_MODULE;   /* Value for ip_input.c */
LOCAL UCHAR wvNetLocalFilter = WV_NET_NONE;     /* Available event filter */

LOCAL ULONG wvNetEventId;       /* Event identifier: see wvNetLib.h */
#endif    /* INCLUDE_WVNET */
#endif

struct	ifqueue ipintrq;

/* forward declarations */

#ifdef SRCRT
static void save_rte (u_char *, struct in_addr);
#endif /* SRCRT */
LOCAL struct mbuf * ipReAssemble (FAST struct mbuf * pMbuf, 
				  FAST struct ipq *  pIpFragQueue); 
#ifdef SYSCTL_SUPPORT
/* ipforwarding set to on or off depending upon compile time flag */
int ipforwarding = IPFORWARDING;
#endif /* SYSCTL_SUPPORT */

struct rtentry *rtalloc2 (struct sockaddr *);

/*
 * IP initialization: fill in IP protocol switch table.
 * All protocols not implemented in kernel go to raw IP protocol handler.
 */
void
ip_init()
{
	register struct protosw *pr;
	register int i;

#ifdef WV_INSTRUMENTATION
#ifdef INCLUDE_WVNET    /* WV_NET_VERBOSE event */
    WV_NET_MARKER_0 (NET_AUX_EVENT, WV_NET_VERBOSE, 27, 20,
                     WV_NETEVENT_IPINIT_START)
#endif  /* INCLUDE_WVNET */
#endif

#ifdef VIRTUAL_STACK
        ip_defttl = IPDEFTTL;
        ipfragttl = IPFRAGTTL;
#ifdef DIAGNOSTIC
        ipprintfs = 0;
#endif
        ipStrongEnded = FALSE;
        ipqmaxlen = IFQ_MAXLEN;
        ip_nhops = 0;
        input_ipaddr.sin_len = sizeof (struct sockaddr_in);
        input_ipaddr.sin_family = AF_INET;
#endif /* VIRTUAL_STACK */

	pr = pffindproto(PF_INET, IPPROTO_RAW, SOCK_RAW);
	if (pr == 0)
            {
#ifdef WV_INSTRUMENTATION
#ifdef INCLUDE_WVNET    /* WV_NET_EMERGENCY event */
            WV_NET_MARKER_0 (NET_AUX_EVENT, WV_NET_EMERGENCY, 15, 1,
                             WV_NETEVENT_IPINIT_PANIC)
#endif  /* INCLUDE_WVNET */
#endif

            panic("ip_init");
            }
	for (i = 0; i < IPPROTO_MAX; i++)
		ip_protox[i] = pr - inetsw;
	for (pr = inetdomain.dom_protosw;
	    pr < inetdomain.dom_protoswNPROTOSW; pr++)
                if ((pr->pr_domain != NULL) &&
                    pr->pr_domain->dom_family == PF_INET &&
                    pr->pr_protocol && pr->pr_protocol != IPPROTO_RAW)
                    ip_protox[pr->pr_protocol] = pr - inetsw;
#ifdef VIRTUAL_STACK
	_ipq.next = _ipq.prev = &_ipq;
	_ip_id = iptime() & 0xffff;
#else
	ipq.next = ipq.prev = &ipq;
	ip_id = iptime() & 0xffff;
#endif
	ipintrq.ifq_maxlen = ipqmaxlen;
	return;
}

#ifndef VIRTUAL_STACK
struct	sockaddr_in input_ipaddr = { sizeof(input_ipaddr), AF_INET };
struct	route ipforward_rt;
#endif /* VIRTUAL_STACK */

/*
 * Job entry point for net task.
 * Ip input routine.  Checksum and byte swap header.  If fragmented
 * try to reassemble.  Process options.  Pass to next level.
 */

void
ipintr(struct mbuf *m)
{
	struct ip *ip;
	register struct ipq *fp;
	register struct in_ifaddr *ia;
	int hlen, s;

        if (m==0)
            return;
        s = splnet();

#ifdef	DIAGNOSTIC
	if ((m->m_flags & M_PKTHDR) == 0)
            {
#ifdef WV_INSTRUMENTATION
#ifdef INCLUDE_WVNET    /* WV_NET_EMERGENCY event */
            WV_NET_EVENT_0 (NET_CORE_EVENT, WV_NET_EMERGENCY, 16, 2, 
                            WV_NETEVENT_IPIN_PANIC, WV_NET_RECV)
#endif  /* INCLUDE_WVNET */
#endif

            panic("ipintr no HDR");
            }
#endif

	/*
	 * If no IP addresses have been set yet but the interfaces
	 * are receiving, can't do anything with incoming packets yet.
	 */
#ifdef VIRTUAL_STACK
	if (_in_ifaddr == NULL)
#else
	if (in_ifaddr == NULL)
#endif /* VIRTUAL_STACK */
		goto bad;
#ifdef VIRTUAL_STACK
	_ipstat.ips_total++;
#else
	ipstat.ips_total++;
#endif /* VIRTUAL_STACK */
	if (m->m_len < sizeof (struct ip) &&
	    (m = m_pullup(m, sizeof (struct ip))) == 0) {
#ifdef WV_INSTRUMENTATION
#ifdef INCLUDE_WVNET    /* WV_NET_CRITICAL event */
                WV_NET_EVENT_0 (NET_CORE_EVENT, WV_NET_CRITICAL, 12, 3, 
                                WV_NETEVENT_IPIN_SHORTMSG, WV_NET_RECV)
#endif  /* INCLUDE_WVNET */
#endif

#ifdef VIRTUAL_STACK
		_ipstat.ips_toosmall++;
#else
		ipstat.ips_toosmall++;
#endif /* VIRTUAL_STACK */
		goto done;
	}
	ip = mtod(m, struct ip *);
	if (ip->ip_v != IPVERSION) {
#ifdef WV_INSTRUMENTATION
#ifdef INCLUDE_WVNET    /* WV_NET_CRITICAL event */
        WV_NET_EVENT_1 (NET_CORE_EVENT, WV_NET_CRITICAL, 13, 4, 
                        WV_NETEVENT_IPIN_BADVERS, WV_NET_RECV, ip->ip_v)
#endif  /* INCLUDE_WVNET */
#endif

#ifdef VIRTUAL_STACK
		_ipstat.ips_badvers++;
#else
		ipstat.ips_badvers++;
#endif /* VIRTUAL_STACK */
		goto bad;
	}
	hlen = ip->ip_hl << 2;
	if (hlen < sizeof(struct ip)) {	/* minimum header length */
#ifdef WV_INSTRUMENTATION
#ifdef INCLUDE_WVNET    /* WV_NET_CRITICAL event */
        WV_NET_EVENT_1 (NET_CORE_EVENT, WV_NET_CRITICAL, 14, 5, 
                        WV_NETEVENT_IPIN_BADHLEN, WV_NET_RECV, hlen)
#endif  /* INCLUDE_WVNET */
#endif

#ifdef VIRTUAL_STACK
		_ipstat.ips_badhlen++;
#else
		ipstat.ips_badhlen++;
#endif /* VIRTUAL_STACK */
		goto bad;
	}
	if (hlen > m->m_len) {
		if ((m = m_pullup(m, hlen)) == 0) {

#ifdef WV_INSTRUMENTATION
#ifdef INCLUDE_WVNET    /* WV_NET_CRITICAL event */
            WV_NET_EVENT_1 (NET_CORE_EVENT, WV_NET_CRITICAL, 14, 5, 
                            WV_NETEVENT_IPIN_BADHLEN, WV_NET_RECV, hlen)
#endif  /* INCLUDE_WVNET */
#endif

#ifdef VIRTUAL_STACK
			_ipstat.ips_badhlen++;
#else
			ipstat.ips_badhlen++;
#endif /* VIRTUAL_STACK */
			goto done;
		}
		ip = mtod(m, struct ip *);
	}

        if (_ipCfgFlags & IP_DO_CHECKSUM_RCV)
            {
	    if ( (ip->ip_sum = in_cksum(m, hlen)) != 0) 
                {
#ifdef WV_INSTRUMENTATION
#ifdef INCLUDE_WVNET    /* WV_NET_CRITICAL event */
                WV_NET_EVENT_0 (NET_CORE_EVENT, WV_NET_CRITICAL, 15, 6, 
                                WV_NETEVENT_IPIN_BADSUM, WV_NET_RECV)
#endif  /* INCLUDE_WVNET */
#endif

#ifdef VIRTUAL_STACK
		_ipstat.ips_badsum++;
#else
		ipstat.ips_badsum++;
#endif /* VIRTUAL_STACK */
		goto bad;
	        }
            }

	/*
	 * Convert fields to host representation.
	 */
	NTOHS(ip->ip_len);
	if (ip->ip_len < hlen) {
#ifdef WV_INSTRUMENTATION
#ifdef INCLUDE_WVNET    /* WV_NET_CRITICAL event */
        WV_NET_ADDRIN_EVENT_2 (NET_CORE_EVENT, WV_NET_CRITICAL, 16, 7, 
                               ip->ip_src.s_addr, ip->ip_dst.s_addr,
                               WV_NETEVENT_IPIN_BADLEN, WV_NET_RECV,
                               ip->ip_len, hlen)
#endif  /* INCLUDE_WVNET */
#endif

#ifdef VIRTUAL_STACK
		_ipstat.ips_badlen++;
#else
		ipstat.ips_badlen++;
#endif /* VIRTUAL_STACK */
		goto bad;