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.130.2.11 and 1.140

version 1.130.2.11, 2002/08/01 02:46:47

version 1.140, 2001/11/04 20:55:27

Line 3

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

* modification, are permitted provided that the following conditions

* are met:

Line 15

* 3. Neither the name of the project 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 PROJECT 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

Line 101

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

#include <sys/cdefs.h>

__KERNEL_RCSID(0, "$NetBSD$");

#include "opt_gateway.h"

#include "opt_pfil_hooks.h"

#include "opt_ipsec.h"

Line 139 __KERNEL_RCSID(0, "$NetBSD$");

Line 136 __KERNEL_RCSID(0, "$NetBSD$");

/* just for gif_ttl */

#include <netinet/in_gif.h>

#include "gif.h"

#include <net/if_gre.h>

#include "gre.h"

#ifdef MROUTING

#include <netinet/ip_mroute.h>

Line 168 __KERNEL_RCSID(0, "$NetBSD$");

Line 163 __KERNEL_RCSID(0, "$NetBSD$");

#define IPALLOWSRCRT 1 /* allow source-routed packets */

#endif

#ifndef IPMTUDISC

#define IPMTUDISC 1

#define IPMTUDISC 0

#endif

#ifndef IPMTUDISCTIMEOUT

#define IPMTUDISCTIMEOUT (10 * 60) /* as per RFC 1191 */

Line 201 struct rttimer_queue *ip_mtudisc_timeout

Line 196 struct rttimer_queue *ip_mtudisc_timeout

extern struct domain inetdomain;

int ipqmaxlen = IFQ_MAXLEN;

u_long in_ifaddrhash; /* size of hash table - 1 */

int in_ifaddrentries; /* total number of addrs */

struct in_ifaddrhead in_ifaddr;

struct in_ifaddrhashhead *in_ifaddrhashtbl;

struct ifqueue ipintrq;

Line 227 ipq_lock_try()

Line 220 ipq_lock_try()

int s;

* Use splvm() -- we're blocking things that would cause

* Use splvm() -- we're bloking things that would cause

* mbuf allocation.

s = splvm();

Line 320 ip_init()

Line 313 ip_init()

int i;

pool_init(&ipqent_pool, sizeof(struct ipqent), 0, 0, 0, "ipqepl",

NULL);

0, NULL, NULL, M_IPQ);

pr = pffindproto(PF_INET, IPPROTO_RAW, SOCK_RAW);

if (pr == 0)

Line 339 ip_init()

Line 332 ip_init()

in_ifaddrhashtbl = hashinit(IN_IFADDR_HASH_SIZE, HASH_LIST, M_IFADDR,

M_WAITOK, &in_ifaddrhash);

if (ip_mtudisc != 0)

ip_mtudisc_timeout_q =

rt_timer_queue_create(ip_mtudisc_timeout);

#ifdef GATEWAY

ipflow_init();

Line 420 ip_input(struct mbuf *m)

Line 413 ip_input(struct mbuf *m)

if (TAILQ_FIRST(&in_ifaddr) == 0)

goto bad;

ipstat.ips_total++;

if (m->m_len < sizeof (struct ip) &&

* If the IP header is not aligned, slurp it up into a new

(m = m_pullup(m, sizeof (struct ip))) == 0) {

* mbuf with space for link headers, in the event we forward

ipstat.ips_toosmall++;

* it. Otherwise, if it is aligned, make sure the entire

return;

* base IP header is in the first mbuf of the chain.

if (IP_HDR_ALIGNED_P(mtod(m, caddr_t)) == 0) {

if ((m = m_copyup(m, sizeof(struct ip),

(max_linkhdr + 3) & ~3)) == NULL) {

/* XXXJRT new stat, please */

ipstat.ips_toosmall++;

return;

}

} else if (__predict_false(m->m_len < sizeof (struct ip))) {

if ((m = m_pullup(m, sizeof (struct ip))) == NULL) {

ipstat.ips_toosmall++;

return;

}

ip = mtod(m, struct ip *);

if (ip->ip_v != IPVERSION) {

Line 525 ip_input(struct mbuf *m)

Line 504 ip_input(struct mbuf *m)

}

#ifdef IPSEC

/* ipflow (IP fast forwarding) is not compatible with IPsec. */

/* ipflow (IP fast fowarding) is not compatible with IPsec. */

m->m_flags &= ~M_CANFASTFWD;

#else

Line 559 ip_input(struct mbuf *m)

Line 538 ip_input(struct mbuf *m)

if (m == NULL)

return;

ip = mtod(m, struct ip *);

hlen = ip->ip_hl << 2;

}

#endif /* PFIL_HOOKS */

Line 632 ip_input(struct mbuf *m)

Line 610 ip_input(struct mbuf *m)

#ifdef MROUTING

extern struct socket *ip_mrouter;

if (M_READONLY(m)) {

if (m->m_flags & M_EXT) {

if ((m = m_pullup(m, hlen)) == 0) {

ipstat.ips_toosmall++;

return;

Line 703 ip_input(struct mbuf *m)

Line 681 ip_input(struct mbuf *m)

ipstat.ips_cantforward++;

return;

}

#ifdef IPSEC

if (ipsec4_in_reject(m, NULL)) {

ipsecstat.in_polvio++;

goto bad;

}

#endif

ip_forward(m, 0);

}

return;

Line 874 ip_reass(ipqe, fp)

Line 845 ip_reass(ipqe, fp)

fp->ipq_ttl = IPFRAGTTL;

fp->ipq_p = ipqe->ipqe_ip->ip_p;

fp->ipq_id = ipqe->ipqe_ip->ip_id;

TAILQ_INIT(&fp->ipq_fragq);

LIST_INIT(&fp->ipq_fragq);

fp->ipq_src = ipqe->ipqe_ip->ip_src;

fp->ipq_dst = ipqe->ipqe_ip->ip_dst;

p = NULL;

Line 884 ip_reass(ipqe, fp)

Line 855 ip_reass(ipqe, fp)

* Find a segment which begins after this one does.

for (p = NULL, q = TAILQ_FIRST(&fp->ipq_fragq); q != NULL;

for (p = NULL, q = LIST_FIRST(&fp->ipq_fragq); q != NULL;

p = q, q = TAILQ_NEXT(q, ipqe_q))

p = q, q = LIST_NEXT(q, ipqe_q))

if (q->ipqe_ip->ip_off > ipqe->ipqe_ip->ip_off)

break;

Line 920 ip_reass(ipqe, fp)

Line 891 ip_reass(ipqe, fp)

m_adj(q->ipqe_m, i);

break;

}

nq = TAILQ_NEXT(q, ipqe_q);

nq = LIST_NEXT(q, ipqe_q);

m_freem(q->ipqe_m);

TAILQ_REMOVE(&fp->ipq_fragq, q, ipqe_q);

LIST_REMOVE(q, ipqe_q);

pool_put(&ipqent_pool, q);

}

Line 932 insert:

Line 903 insert:

* check for complete reassembly.

if (p == NULL) {

TAILQ_INSERT_HEAD(&fp->ipq_fragq, ipqe, ipqe_q);

LIST_INSERT_HEAD(&fp->ipq_fragq, ipqe, ipqe_q);

} else {

TAILQ_INSERT_AFTER(&fp->ipq_fragq, p, ipqe, ipqe_q);

LIST_INSERT_AFTER(p, ipqe, ipqe_q);

}

next = 0;

for (p = NULL, q = TAILQ_FIRST(&fp->ipq_fragq); q != NULL;

for (p = NULL, q = LIST_FIRST(&fp->ipq_fragq); q != NULL;

p = q, q = TAILQ_NEXT(q, ipqe_q)) {

p = q, q = LIST_NEXT(q, ipqe_q)) {

if (q->ipqe_ip->ip_off != next)

return (0);

next += q->ipqe_ip->ip_len;

Line 950 insert:

Line 921 insert:

* Reassembly is complete. Check for a bogus message size and

* concatenate fragments.

q = TAILQ_FIRST(&fp->ipq_fragq);

q = LIST_FIRST(&fp->ipq_fragq);

ip = q->ipqe_ip;

if ((next + (ip->ip_hl << 2)) > IP_MAXPACKET) {

ipstat.ips_toolong++;

Line 961 insert:

Line 932 insert:

t = m->m_next;

m->m_next = 0;

m_cat(m, t);

nq = TAILQ_NEXT(q, ipqe_q);

nq = LIST_NEXT(q, ipqe_q);

pool_put(&ipqent_pool, q);

for (q = nq; q != NULL; q = nq) {

t = q->ipqe_m;

nq = TAILQ_NEXT(q, ipqe_q);

nq = LIST_NEXT(q, ipqe_q);

pool_put(&ipqent_pool, q);

m_cat(m, t);

}

Line 1012 ip_freef(fp)

Line 983 ip_freef(fp)

IPQ_LOCK_CHECK();

for (q = TAILQ_FIRST(&fp->ipq_fragq); q != NULL; q = p) {

for (q = LIST_FIRST(&fp->ipq_fragq); q != NULL; q = p) {

p = TAILQ_NEXT(q, ipqe_q);

p = LIST_NEXT(q, ipqe_q);

m_freem(q->ipqe_m);

TAILQ_REMOVE(&fp->ipq_fragq, q, ipqe_q);

LIST_REMOVE(q, ipqe_q);

pool_put(&ipqent_pool, q);

}

LIST_REMOVE(fp, ipq_q);

Line 1676 ip_forward(m, srcrt)

Line 1647 ip_forward(m, srcrt)

ro = &sp->req->sav->sah->sa_route;

if (ro->ro_rt && ro->ro_rt->rt_ifp) {

dummyifp.if_mtu =

ro->ro_rt->rt_rmx.rmx_mtu ?

ro->ro_rt->rt_rmx.rmx_mtu :

ro->ro_rt->rt_ifp->if_mtu;

dummyifp.if_mtu -= ipsechdr;

destifp = &dummyifp;

Line 1692 ip_forward(m, srcrt)

Line 1661 ip_forward(m, srcrt)

break;

case ENOBUFS:

#if 1

* a router should not generate ICMP_SOURCEQUENCH as

* required in RFC1812 Requirements for IP Version 4 Routers.

* source quench could be a big problem under DoS attacks,

* or if the underlying interface is rate-limited.

if (mcopy)

m_freem(mcopy);

return;

#else

type = ICMP_SOURCEQUENCH;

code = 0;

break;

#endif

}

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

}

Line 1821 ip_sysctl(name, namelen, oldp, oldlenp,

Line 1778 ip_sysctl(name, namelen, oldp, oldlenp,

error = sysctl_int(oldp, oldlenp, newp, newlen,

&ip_mtudisc);

if (ip_mtudisc != 0 && ip_mtudisc_timeout_q == NULL) {

ip_mtudisc_timeout_q =

rt_timer_queue_create(ip_mtudisc_timeout);

} else if (ip_mtudisc == 0 && ip_mtudisc_timeout_q != NULL) {

rt_timer_queue_destroy(ip_mtudisc_timeout_q, TRUE);

Line 1858 ip_sysctl(name, namelen, oldp, oldlenp,

Line 1815 ip_sysctl(name, namelen, oldp, oldlenp,

error = sysctl_int(oldp, oldlenp, newp, newlen,

&ip_mtudisc_timeout);

if (ip_mtudisc_timeout_q != NULL)

rt_timer_queue_change(ip_mtudisc_timeout_q,

ip_mtudisc_timeout);

return (error);

#ifdef GATEWAY

Line 1883 ip_sysctl(name, namelen, oldp, oldlenp,

Line 1840 ip_sysctl(name, namelen, oldp, oldlenp,

&ip_gif_ttl));

#endif

#if NGRE > 0

case IPCTL_GRE_TTL:

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

&ip_gre_ttl));

#endif

#ifndef IPNOPRIVPORTS

case IPCTL_LOWPORTMIN:

old = lowportmin;

CVSweb <webmaster@jp.NetBSD.org>