src/sys/netinet/ip_input.c - diff

Return to ip_input.c CVS log

Up to [cvs.NetBSD.org] / src / sys / netinet

Please note that diffs are not public domain; they are subject to the copyright notices on the relevant files.

Diff for /src/sys/netinet/ip_input.c between version 1.12 and 1.14

version 1.12, 1994/02/14 21:45:53

version 1.14, 1994/06/29 06:38:19

Line 1

/* $NetBSD$ */

* Redistribution and use in source and binary forms, with or without

* modification, are permitted provided that the following conditions

Line 30

Line 32

* OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF

* SUCH DAMAGE.

* from: @(#)ip_input.c 7.19 (Berkeley) 5/25/91

* @(#)ip_input.c 8.2 (Berkeley) 1/4/94

* $Id$

#include <sys/param.h>

Line 55

Line 56

#include <netinet/in_var.h>

#include <netinet/ip_var.h>

#include <netinet/ip_icmp.h>

#include <netinet/ip_mroute.h>

#ifndef IPFORWARDING

#ifdef GATEWAY

Line 69

#endif

int ipforwarding = IPFORWARDING;

int ipsendredirects = IPSENDREDIRECTS;

int ip_defttl = IPDEFTTL;

#ifdef DIAGNOSTIC

int ipprintfs = 0;

#endif

Line 78 extern struct protosw inetsw[];

Line 79 extern struct protosw inetsw[];

u_char ip_protox[IPPROTO_MAX];

int ipqmaxlen = IFQ_MAXLEN;

struct in_ifaddr *in_ifaddr; /* first inet address */

struct ifqueue ipintrq;

* We need to save the IP options in case a protocol wants to respond

Line 99 extern int if_index;

Line 101 extern int if_index;

u_long *ip_ifmatrix;

#endif

static void ip_forward __P((struct mbuf *, int));

static void save_rte __P((u_char *, struct in_addr));

* IP initialization: fill in IP protocol switch table.

* All protocols not implemented in kernel go to raw IP protocol handler.

Line 127 ip_init()

ipintrq.ifq_maxlen = ipqmaxlen;

#ifdef GATEWAY

i = (if_index + 1) * (if_index + 1) * sizeof (u_long);

if ((ip_ifmatrix = (u_long *) malloc(i, M_RTABLE, M_WAITOK)) == 0)

ip_ifmatrix = (u_long *) malloc(i, M_RTABLE, M_WAITOK);

panic("no memory for ip_ifmatrix");

bzero((char *)ip_ifmatrix, i);

#endif

}

struct ip *ip_reass();

struct sockaddr_in ipaddr = { sizeof(ipaddr), AF_INET };

struct route ipforward_rt;

Line 148 ipintr()

Line 147 ipintr()

int hlen, s;

#ifdef DIAGNOSTIC

static int busy = 0;

if (busy)

panic("ipintr: called recursively\n");

++busy;

#endif

* Get next datagram off input queue and get IP header

Line 163 next:

Line 156 next:

s = splimp();

IF_DEQUEUE(&ipintrq, m);

splx(s);

if (m == 0) {

if (m == 0)

#ifdef DIAGNOSTIC

--busy;

#endif

return;

}

#ifdef DIAGNOSTIC

if ((m->m_flags & M_PKTHDR) == 0)

panic("ipintr no HDR");

Line 186 next:

Line 175 next:

goto next;

}

ip = mtod(m, struct ip *);

if (ip->ip_v != IPVERSION) {

ipstat.ips_badvers++;

goto bad;

}

hlen = ip->ip_hl << 2;

if (hlen < sizeof(struct ip)) { /* minimum header length */

ipstat.ips_badhlen++;

Line 300 next:

Line 293 next:

* ip_output().)

ip->ip_id = htons(ip->ip_id);

if (ip_mforward(ip, m->m_pkthdr.rcvif, m) != 0) {

if (ip_mforward(m, m->m_pkthdr.rcvif) != 0) {

ipstat.ips_cantforward++;

m_freem(m);

goto next;

}

Line 313 next:

Line 307 next:

if (ip->ip_p == IPPROTO_IGMP)

goto ours;

ipstat.ips_forward++;

}

#endif

Line 321 next:

Line 316 next:

IN_LOOKUP_MULTI(ip->ip_dst, m->m_pkthdr.rcvif, inm);

if (inm == NULL) {

ipstat.ips_cantforward++;

m_freem(m);

goto next;

}

Line 376 found:

Line 372 found:

* convert offset of this to bytes.

ip->ip_len -= hlen;

((struct ipasfrag *)ip)->ipf_mff = 0;

((struct ipasfrag *)ip)->ipf_mff &= ~1;

if (ip->ip_off & IP_MF)

((struct ipasfrag *)ip)->ipf_mff = 1;

((struct ipasfrag *)ip)->ipf_mff |= 1;

ip->ip_off <<= 3;

Line 386 found:

Line 382 found:

* or if this is not the first fragment,

* attempt reassembly; if it succeeds, proceed.

if (((struct ipasfrag *)ip)->ipf_mff || ip->ip_off) {

if (((struct ipasfrag *)ip)->ipf_mff & 1 || ip->ip_off) {

ipstat.ips_fragments++;

ip = ip_reass((struct ipasfrag *)ip, fp);

if (ip == 0)

goto next;

else

ipstat.ips_reassembled++;

m = dtom(ip);

} else

if (fp)

Line 505 insert:

Line 500 insert:

return (0);

next += q->ip_len;

}

if (q->ipf_prev->ipf_mff)

if (q->ipf_prev->ipf_mff & 1)

return (0);

Line 531 insert:

Line 526 insert:

ip = fp->ipq_next;

ip->ip_len = next;

ip->ipf_mff &= ~1;

((struct ip *)ip)->ip_src = fp->ipq_src;

((struct ip *)ip)->ip_dst = fp->ipq_dst;

remque(fp);

Line 639 ip_drain()

Line 635 ip_drain()

}

extern struct in_ifaddr *ifptoia();

struct in_ifaddr *ip_rtaddr();

* Do option processing on a datagram,

* possibly discarding it if bad options are encountered,

Line 658 ip_dooptions(m)

Line 651 ip_dooptions(m)

int opt, optlen, cnt, off, code, type = ICMP_PARAMPROB, forward = 0;

struct in_addr *sin;

struct in_addr *sin, dst;

n_time ntime;

dst = ip->ip_dst;

cp = (u_char *)(ip + 1);

cnt = (ip->ip_hl << 2) - sizeof (struct ip);

for (; cnt > 0; cnt -= optlen, cp += optlen) {

Line 728 ip_dooptions(m)

Line 722 ip_dooptions(m)

#define INA struct in_ifaddr *

#define SA struct sockaddr *

if ((ia = (INA)ifa_ifwithdstaddr((SA)&ipaddr)) == 0)

ia = in_iaonnetof(in_netof(ipaddr.sin_addr));

ia = (INA)ifa_ifwithnet((SA)&ipaddr);

} else

ia = ip_rtaddr(ipaddr.sin_addr);

if (ia == 0) {

Line 740 ip_dooptions(m)

Line 734 ip_dooptions(m)

bcopy((caddr_t)&(IA_SIN(ia)->sin_addr),

(caddr_t)(cp + off), sizeof(struct in_addr));

cp[IPOPT_OFFSET] += sizeof(struct in_addr);

forward = 1;

* Let ip_intr's mcast routing check handle mcast pkts

forward = !IN_MULTICAST(ntohl(ip->ip_dst.s_addr));

break;

case IPOPT_RR:

Line 791 ip_dooptions(m)

Line 788 ip_dooptions(m)

if (ipt->ipt_ptr + sizeof(n_time) +

sizeof(struct in_addr) > ipt->ipt_len)

goto bad;

ia = ifptoia(m->m_pkthdr.rcvif);

ipaddr.sin_addr = dst;

ia = (INA)ifaof_ifpforaddr((SA)&ipaddr,

m->m_pkthdr.rcvif);

if (ia == 0)

continue;

bcopy((caddr_t)&IA_SIN(ia)->sin_addr,

(caddr_t)sin, sizeof(struct in_addr));

ipt->ipt_ptr += sizeof(struct in_addr);

Line 820 ip_dooptions(m)

Line 821 ip_dooptions(m)

if (forward) {

ip_forward(m, 1);

return (1);

} else

}

return (0);

bad:

{

ip->ip_len -= ip->ip_hl << 2; /* XXX icmp_error adds in hdr length */

icmp_error(m, type, code, 0, 0);

icmp_error(m, type, code, foo);

ipstat.ips_badoptions++;

}

return (1);

}

Line 862 ip_rtaddr(dst)

* Save incoming source route for use in replies,

* to be picked up later by ip_srcroute if the receiver is interested.

static void

void

save_rte(option, dst)

u_char *option;

struct in_addr dst;

Line 898 ip_srcroute()

if (m == 0)

return ((struct mbuf *)0);

#define OPTSIZ (sizeof(ip_srcrt.nop) + sizeof(ip_srcrt.srcopt))

/* length is (nhops+1)*sizeof(addr) + sizeof(nop + srcrt header) */

m->m_len = ip_nhops * sizeof(struct in_addr) + sizeof(struct in_addr) +

Line 1000 u_char inetctlerrmap[PRC_NCMDS] = {

* The srcrt parameter indicates whether the packet is being forwarded

* via a source route.

static void

void

ip_forward(m, srcrt)

struct mbuf *m;

int srcrt;

Line 1010 ip_forward(m, srcrt)

int error, type = 0, code;

struct mbuf *mcopy;

struct in_addr dest;

n_long dest;

struct ifnet *destifp;

dest.s_addr = 0;

dest = 0;

#ifdef DIAGNOSTIC

if (ipprintfs)

printf("forward: src %x dst %x ttl %x\n", ip->ip_src,

Line 1025 ip_forward(m, srcrt)

Line 1026 ip_forward(m, srcrt)

}

HTONS(ip->ip_id);

if (ip->ip_ttl <= IPTTLDEC) {

icmp_error(m, ICMP_TIMXCEED, ICMP_TIMXCEED_INTRANS, dest);

icmp_error(m, ICMP_TIMXCEED, ICMP_TIMXCEED_INTRANS, dest, 0);

return;

}

ip->ip_ttl -= IPTTLDEC;

Line 1043 ip_forward(m, srcrt)

Line 1044 ip_forward(m, srcrt)

rtalloc(&ipforward_rt);

if (ipforward_rt.ro_rt == 0) {

icmp_error(m, ICMP_UNREACH, ICMP_UNREACH_HOST, dest);

icmp_error(m, ICMP_UNREACH, ICMP_UNREACH_HOST, dest, 0);

return;

}

rt = ipforward_rt.ro_rt;

Line 1072 ip_forward(m, srcrt)

Line 1073 ip_forward(m, srcrt)

(rt->rt_flags & (RTF_DYNAMIC|RTF_MODIFIED)) == 0 &&

satosin(rt_key(rt))->sin_addr.s_addr != 0 &&

ipsendredirects && !srcrt) {

struct in_ifaddr *ia;

#define RTA(rt) ((struct in_ifaddr *)(rt->rt_ifa))

u_long src = ntohl(ip->ip_src.s_addr);

u_long dst = ntohl(ip->ip_dst.s_addr);

if ((ia = ifptoia(m->m_pkthdr.rcvif)) &&

if (RTA(rt) &&

(src & ia->ia_subnetmask) == ia->ia_subnet) {

(src & RTA(rt)->ia_subnetmask) == RTA(rt)->ia_subnet) {

if (rt->rt_flags & RTF_GATEWAY)

dest = satosin(rt->rt_gateway)->sin_addr;

dest = satosin(rt->rt_gateway)->sin_addr.s_addr;

else

dest = ip->ip_dst;

dest = ip->ip_dst.s_addr;

/* Router requirements says to only send host redirects */

* If the destination is reached by a route to host,

* is on a subnet of a local net, or is directly

* on the attached net (!), use host redirect.

* (We may be the correct first hop for other subnets.)

#define RTA(rt) ((struct in_ifaddr *)(rt->rt_ifa))

type = ICMP_REDIRECT;

if ((rt->rt_flags & RTF_HOST) ||

code = ICMP_REDIRECT_HOST;

(rt->rt_flags & RTF_GATEWAY) == 0)

code = ICMP_REDIRECT_HOST;

else if (RTA(rt)->ia_subnetmask != RTA(rt)->ia_netmask &&

(dst & RTA(rt)->ia_netmask) == RTA(rt)->ia_net)

code = ICMP_REDIRECT_HOST;

else

code = ICMP_REDIRECT_NET;

#ifdef DIAGNOSTIC

if (ipprintfs)

printf("redirect (%d) to %x\n", code, dest.s_addr);

printf("redirect (%d) to %lx\n", code, (u_long)dest);

#endif

}

error = ip_output(m, NULL, &ipforward_rt, IP_FORWARDING

error = ip_output(m, (struct mbuf *)0, &ipforward_rt, IP_FORWARDING

#ifdef DIRECTED_BROADCAST

| IP_ALLOWBROADCAST

#endif

, NULL);

, 0);

if (error)

ipstat.ips_cantforward++;

else {

Line 1124 ip_forward(m, srcrt)

Line 1111 ip_forward(m, srcrt)

}

if (mcopy == NULL)

return;

destifp = NULL;

switch (error) {

case 0: /* forwarded, but need redirect */

Line 1142 ip_forward(m, srcrt)

Line 1131 ip_forward(m, srcrt)

case EMSGSIZE:

type = ICMP_UNREACH;

code = ICMP_UNREACH_NEEDFRAG;

if (ipforward_rt.ro_rt)

destifp = ipforward_rt.ro_rt->rt_ifp;

ipstat.ips_cantfrag++;

break;

Line 1150 ip_forward(m, srcrt)

Line 1141 ip_forward(m, srcrt)

code = 0;

break;

}

icmp_error(mcopy, type, code, dest);

icmp_error(mcopy, type, code, dest, destifp);

}

int

ip_sysctl(name, namelen, oldp, oldlenp, newp, newlen)

int *name;

u_int namelen;

void *oldp;

size_t *oldlenp;

void *newp;

size_t newlen;

{

/* All sysctl names at this level are terminal. */

if (namelen != 1)

return (ENOTDIR);

switch (name[0]) {

case IPCTL_FORWARDING:

return (sysctl_int(oldp, oldlenp, newp, newlen, &ipforwarding));

case IPCTL_SENDREDIRECTS:

return (sysctl_int(oldp, oldlenp, newp, newlen,

&ipsendredirects));

case IPCTL_DEFTTL:

return (sysctl_int(oldp, oldlenp, newp, newlen, &ip_defttl));

#ifdef notyet

case IPCTL_DEFMTU:

return (sysctl_int(oldp, oldlenp, newp, newlen, &ip_mtu));

#endif

default:

return (EOPNOTSUPP);

}

/* NOTREACHED */

}

CVSweb <webmaster@jp.NetBSD.org>