src/sys/netinet/udp_usrreq.c - diff

Return to udp_usrreq.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/udp_usrreq.c between version 1.97 and 1.109

version 1.97, 2003/01/20 00:05:46

version 1.109, 2003/09/04 09:17:03

Line 41

* 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

* 3. Neither the name of the University nor the names of its contributors

* 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.

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

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

#include "opt_ipsec.h"

#include "opt_inet_csum.h"

#include "opt_ipkdb.h"

#include "opt_mbuftrace.h"

#include <sys/param.h>

#include <sys/malloc.h>

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

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

#include <netinet6/udp6_var.h>

#endif

#ifdef PULLDOWN_TEST

#ifndef INET6

/* always need ip6.h for IP6_EXTHDR_GET */

#include <netinet/ip6.h>

#endif

#include "faith.h"

#if defined(NFAITH) && NFAITH > 0

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

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

#include <machine/stdarg.h>

#ifdef FAST_IPSEC

#include <netipsec/ipsec.h>

#ifdef INET6

#include <netipsec/ipsec6.h>

#endif

#endif /* FAST_IPSEC*/

#ifdef IPSEC

#include <netinet6/ipsec.h>

#include <netkey/key.h>

Line 163 static void udp_notify __P((struct inpcb

Line 165 static void udp_notify __P((struct inpcb

#endif

int udbhashsize = UDBHASHSIZE;

#ifdef MBUFTRACE

struct mowner udp_mowner = { "udp" };

struct mowner udp_rx_mowner = { "udp", "rx" };

struct mowner udp_tx_mowner = { "udp", "tx" };

#endif

#ifdef UDP_CSUM_COUNTERS

#include <sys/device.h>

Line 187 void

Line 195 void

udp_init()

{

#ifdef INET

in_pcbinit(&udbtable, udbhashsize, udbhashsize);

#endif

#ifdef UDP_CSUM_COUNTERS

evcnt_attach_static(&udp_hwcsum_bad);

Line 197 udp_init()

Line 203 udp_init()

evcnt_attach_static(&udp_hwcsum_data);

evcnt_attach_static(&udp_swcsum);

#endif /* UDP_CSUM_COUNTERS */

MOWNER_ATTACH(&udp_tx_mowner);

MOWNER_ATTACH(&udp_rx_mowner);

MOWNER_ATTACH(&udp_mowner);

}

#ifdef INET

Line 223 udp_input(m, va_alist)

Line 233 udp_input(m, va_alist)

(void)va_arg(ap, int); /* ignore value, advance ap */

va_end(ap);

MCLAIM(m, &udp_rx_mowner);

udpstat.udps_ipackets++;

#ifndef PULLDOWN_TEST

* Strip IP options, if any; should skip this,

* make available to user, and use on returned packets,

* but we don't yet have a way to check the checksum

* with options still present.

if (iphlen > sizeof (struct ip)) {

ip_stripoptions(m, (struct mbuf *)0);

iphlen = sizeof(struct ip);

}

#else

* we may enable the above code if we save and pass IPv4 options

* to the userland.

#endif

* Get IP and UDP header together in first mbuf.

ip = mtod(m, struct ip *);

#ifndef PULLDOWN_TEST

if (m->m_len < iphlen + sizeof(struct udphdr)) {

if ((m = m_pullup(m, iphlen + sizeof(struct udphdr))) == 0) {

udpstat.udps_hdrops++;

return;

}

ip = mtod(m, struct ip *);

}

uh = (struct udphdr *)((caddr_t)ip + iphlen);

#else

IP6_EXTHDR_GET(uh, struct udphdr *, m, iphlen, sizeof(struct udphdr));

if (uh == NULL) {

udpstat.udps_hdrops++;

return;

}

#endif

KASSERT(UDP_HDR_ALIGNED_P(uh));

/* destination port of 0 is illegal, based on RFC768. */

Line 294 udp_input(m, va_alist)

Line 276 udp_input(m, va_alist)

UDP_CSUM_COUNTER_INCR(&udp_hwcsum_bad);

goto badcsum;

case M_CSUM_UDPv4|M_CSUM_DATA:

case M_CSUM_UDPv4|M_CSUM_DATA: {

u_int32_t hw_csum = m->m_pkthdr.csum_data;

UDP_CSUM_COUNTER_INCR(&udp_hwcsum_data);

if ((m->m_pkthdr.csum_data ^ 0xffff) != 0)

if (m->m_pkthdr.csum_flags & M_CSUM_NO_PSEUDOHDR)

hw_csum = in_cksum_phdr(ip->ip_src.s_addr, ip->ip_dst.s_addr,

htonl(hw_csum + ntohs(ip->ip_len) + IPPROTO_UDP));

if ((hw_csum ^ 0xffff) != 0)

goto badcsum;

break;

}

case M_CSUM_UDPv4:

/* Checksum was okay. */

Line 395 udp6_input(mp, offp, proto)

Line 382 udp6_input(mp, offp, proto)

struct udphdr *uh;

u_int32_t plen, ulen;

#ifndef PULLDOWN_TEST

IP6_EXTHDR_CHECK(m, off, sizeof(struct udphdr), IPPROTO_DONE);

#endif

ip6 = mtod(m, struct ip6_hdr *);

#if defined(NFAITH) && 0 < NFAITH

Line 412 udp6_input(mp, offp, proto)

Line 396 udp6_input(mp, offp, proto)

/* check for jumbogram is done in ip6_input. we can trust pkthdr.len */

plen = m->m_pkthdr.len - off;

#ifndef PULLDOWN_TEST

uh = (struct udphdr *)((caddr_t)ip6 + off);

#else

IP6_EXTHDR_GET(uh, struct udphdr *, m, off, sizeof(struct udphdr));

if (uh == NULL) {

ip6stat.ip6s_tooshort++;

return IPPROTO_DONE;

}

#endif

KASSERT(UDP_HDR_ALIGNED_P(uh));

ulen = ntohs((u_short)uh->uh_ulen);

Line 516 udp4_sendup(m, off, src, so)

Line 496 udp4_sendup(m, off, src, so)

return;

}

#ifdef IPSEC

#if defined(IPSEC) || defined(FAST_IPSEC)

/* check AH/ESP integrity. */

if (so != NULL && ipsec4_in_reject_so(m, so)) {

ipsecstat.in_polvio++;

Line 562 udp6_sendup(m, off, src, so)

Line 542 udp6_sendup(m, off, src, so)

return;

in6p = sotoin6pcb(so);

#ifdef IPSEC

#if defined(IPSEC) || defined(FAST_IPSEC)

/* check AH/ESP integrity. */

if (so != NULL && ipsec6_in_reject_so(m, so)) {

ipsec6stat.in_polvio++;

Line 600 udp4_realinput(src, dst, m, off)

Line 580 udp4_realinput(src, dst, m, off)

u_int16_t *sport, *dport;

int rcvcnt;

struct in_addr *src4, *dst4;

struct inpcb_hdr *inph;

struct inpcb *inp;

rcvcnt = 0;

Line 638 udp4_realinput(src, dst, m, off)

Line 619 udp4_realinput(src, dst, m, off)

* Locate pcb(s) for datagram.

CIRCLEQ_FOREACH(inp, &udbtable.inpt_queue, inp_queue) {

CIRCLEQ_FOREACH(inph, &udbtable.inpt_queue, inph_queue) {

inp = (struct inpcb *)inph;

if (inp->inp_af != AF_INET)

continue;

if (inp->inp_lport != *dport)

continue;

if (!in_nullhost(inp->inp_laddr)) {

Line 701 udp6_realinput(af, src, dst, m, off)

Line 686 udp6_realinput(af, src, dst, m, off)

int rcvcnt;

struct in6_addr src6, dst6;

const struct in_addr *dst4;

struct inpcb_hdr *inph;

struct in6pcb *in6p;

rcvcnt = 0;

Line 742 udp6_realinput(af, src, dst, m, off)

Line 728 udp6_realinput(af, src, dst, m, off)

* Locate pcb(s) for datagram.

for (in6p = udb6.in6p_next; in6p != &udb6;

CIRCLEQ_FOREACH(inph, &udbtable.inpt_queue, inph_queue) {

in6p = in6p->in6p_next) {

in6p = (struct in6pcb *)inph;

if (in6p->in6p_af != AF_INET6)

continue;

if (in6p->in6p_lport != dport)

continue;

if (!IN6_IS_ADDR_UNSPECIFIED(&in6p->in6p_laddr)) {

Line 784 udp6_realinput(af, src, dst, m, off)

Line 773 udp6_realinput(af, src, dst, m, off)

* Locate pcb for datagram.

in6p = in6_pcblookup_connect(&udb6, &src6, sport,

in6p = in6_pcblookup_connect(&udbtable, &src6, sport,

&dst6, dport, 0);

if (in6p == 0) {

++udpstat.udps_pcbhashmiss;

in6p = in6_pcblookup_bind(&udb6, &dst6, dport, 0);

in6p = in6_pcblookup_bind(&udbtable, &dst6, dport, 0);

if (in6p == 0)

return rcvcnt;

}

Line 868 udp_output(m, va_alist)

Line 857 udp_output(m, va_alist)

int error = 0;

va_list ap;

MCLAIM(m, &udp_tx_mowner);

va_start(ap, m);

inp = va_arg(ap, struct inpcb *);

va_end(ap);

Line 923 udp_output(m, va_alist)

Line 913 udp_output(m, va_alist)

((struct ip *)ui)->ip_tos = inp->inp_ip.ip_tos; /* XXX */

udpstat.udps_opackets++;

#ifdef IPSEC

if (ipsec_setsocket(m, inp->inp_socket) != 0) {

error = ENOBUFS;

goto release;

}

#endif /*IPSEC*/

return (ip_output(m, inp->inp_options, &inp->inp_route,

inp->inp_socket->so_options & (SO_DONTROUTE | SO_BROADCAST),

inp->inp_moptions));

inp->inp_moptions, inp->inp_socket));

release:

m_freem(m);

Line 988 udp_usrreq(so, req, m, nam, control, p)

Line 971 udp_usrreq(so, req, m, nam, control, p)

error = EISCONN;

break;

}

#ifdef MBUFTRACE

so->so_mowner = &udp_mowner;

so->so_rcv.sb_mowner = &udp_rx_mowner;

so->so_snd.sb_mowner = &udp_tx_mowner;

#endif

if (so->so_snd.sb_hiwat == 0 || so->so_rcv.sb_hiwat == 0) {

error = soreserve(so, udp_sendspace, udp_recvspace);

if (error)

Line 1028 udp_usrreq(so, req, m, nam, control, p)

Line 1016 udp_usrreq(so, req, m, nam, control, p)

so->so_state &= ~SS_ISCONNECTED; /* XXX */

in_pcbdisconnect(inp);

inp->inp_laddr = zeroin_addr; /* XXX */

if (inp->inp_ia != NULL) {

LIST_REMOVE(inp, inp_ialink);

IFAFREE(&inp->inp_ia->ia_ifa);

inp->inp_ia = NULL;

}

in_pcbstate(inp, INP_BOUND); /* XXX */

break;

Line 1056 udp_usrreq(so, req, m, nam, control, p)

Line 1049 udp_usrreq(so, req, m, nam, control, p)

goto die;

}

error = in_pcbconnect(inp, nam);

if (error) {

if (error)

die:

goto die;

m_freem(m);

break;

}

} else {

if ((so->so_state & SS_ISCONNECTED) == 0) {

error = ENOTCONN;

Line 1068 udp_usrreq(so, req, m, nam, control, p)

Line 1058 udp_usrreq(so, req, m, nam, control, p)

}

error = udp_output(m, inp);

m = NULL;

if (nam) {

in_pcbdisconnect(inp);

inp->inp_laddr = laddr; /* XXX */

in_pcbstate(inp, INP_BOUND); /* XXX */

}

die:

if (inp->inp_ia != NULL && in_nullhost(inp->inp_laddr)) {

LIST_REMOVE(inp, inp_ialink);

IFAFREE(&inp->inp_ia->ia_ifa);

inp->inp_ia = NULL;

}

if (m)

m_freem(m);

}

break;

CVSweb <webmaster@jp.NetBSD.org>