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.75 and 1.75.2.2

version 1.75, 2001/01/24 09:04:16

version 1.75.2.2, 2001/08/24 00:12:33

Line 64

* @(#)udp_usrreq.c 8.6 (Berkeley) 5/23/95

#include "opt_inet.h"

#include "opt_ipsec.h"

#include "opt_inet_csum.h"

#include "opt_ipkdb.h"

#include <sys/param.h>

Line 110

Line 112

#endif

#include "faith.h"

#if defined(NFAITH) && NFAITH > 0

#include <net/if_faith.h>

#endif

#include <machine/stdarg.h>

#ifdef IPSEC

Line 154 static void udp_notify __P((struct inpcb

Line 161 static void udp_notify __P((struct inpcb

#endif

int udbhashsize = UDBHASHSIZE;

#ifdef UDP_CSUM_COUNTERS

#include <sys/device.h>

struct evcnt udp_hwcsum_bad = EVCNT_INITIALIZER(EVCNT_TYPE_MISC,

NULL, "udp", "hwcsum bad");

struct evcnt udp_hwcsum_ok = EVCNT_INITIALIZER(EVCNT_TYPE_MISC,

NULL, "udp", "hwcsum ok");

struct evcnt udp_hwcsum_data = EVCNT_INITIALIZER(EVCNT_TYPE_MISC,

NULL, "udp", "hwcsum data");

struct evcnt udp_swcsum = EVCNT_INITIALIZER(EVCNT_TYPE_MISC,

NULL, "udp", "swcsum");

#define UDP_CSUM_COUNTER_INCR(ev) (ev)->ev_count++

#else

#define UDP_CSUM_COUNTER_INCR(ev) /* nothing */

#endif /* UDP_CSUM_COUNTERS */

void

udp_init()

{

Line 161 udp_init()

Line 188 udp_init()

#ifdef INET

in_pcbinit(&udbtable, udbhashsize, udbhashsize);

#endif

#ifdef UDP_CSUM_COUNTERS

evcnt_attach_static(&udp_hwcsum_bad);

evcnt_attach_static(&udp_hwcsum_ok);

evcnt_attach_static(&udp_hwcsum_data);

evcnt_attach_static(&udp_swcsum);

#endif /* UDP_CSUM_COUNTERS */

}

#ifndef UDP6

Line 249 udp_input(m, va_alist)

Line 283 udp_input(m, va_alist)

* Checksum extended UDP header and data.

if (uh->uh_sum) {

if (in4_cksum(m, IPPROTO_UDP, iphlen, len) != 0) {

switch (m->m_pkthdr.csum_flags &

udpstat.udps_badsum++;

((m->m_pkthdr.rcvif->if_csum_flags & M_CSUM_UDPv4) |

m_freem(m);

M_CSUM_TCP_UDP_BAD | M_CSUM_DATA)) {

return;

case M_CSUM_UDPv4|M_CSUM_TCP_UDP_BAD:

UDP_CSUM_COUNTER_INCR(&udp_hwcsum_bad);

goto badcsum;

case M_CSUM_UDPv4|M_CSUM_DATA:

UDP_CSUM_COUNTER_INCR(&udp_hwcsum_data);

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

goto badcsum;

break;

case M_CSUM_UDPv4:

/* Checksum was okay. */

UDP_CSUM_COUNTER_INCR(&udp_hwcsum_ok);

break;

default:

/* Need to compute it ourselves. */

UDP_CSUM_COUNTER_INCR(&udp_swcsum);

if (in4_cksum(m, IPPROTO_UDP, iphlen, len) != 0)

goto badcsum;

break;

}

Line 316 udp_input(m, va_alist)

Line 370 udp_input(m, va_alist)

bad:

if (m)

m_freem(m);

return;

badcsum:

m_freem(m);

udpstat.udps_badsum++;

}

#endif

Line 332 udp6_input(mp, offp, proto)

Line 391 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

if (m->m_pkthdr.rcvif) {

if (faithprefix(&ip6->ip6_dst)) {

if (m->m_pkthdr.rcvif->if_type == IFT_FAITH) {

/* send icmp6 host unreach? */

m_freem(m);

return IPPROTO_DONE;

}

#endif

udp6stat.udp6s_ipackets++;

#ifndef PULLDOWN_TEST

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

#endif

ip6 = mtod(m, struct ip6_hdr *);

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

plen = m->m_pkthdr.len - off;

#ifndef PULLDOWN_TEST

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

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

m_freem(n);

if (opts)

m_freem(opts);

udpstat.udps_fullsock++;

} else

sorwakeup(so);

}

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

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

(SO_REUSEPORT|SO_REUSEADDR)) == 0)

break;

}

#if 0

if (last == NULL) {

* No matching pcb found; discard datagram.

* (No need to send an ICMP Port Unreachable

* for a broadcast or multicast datgram.)

udpstat.udps_noportbcast++;

goto bad;

}

#endif

} else {

* Locate pcb for datagram.

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

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

if (inp == 0) {

++udpstat.udps_pcbhashmiss;

inp = in_pcblookup_bind(&udbtable, *dst4, *dport);

if (inp == 0) {

if (inp == 0)

#if 0

struct mbuf *n;

if (m->m_flags & (M_BCAST | M_MCAST)) {

udpstat.udps_noportbcast++;

goto bad;

}

udpstat.udps_noport++;

#ifdef IPKDB

if (checkipkdb(src4, *sport, *dport, m, off,

m->m_pkthdr.len - off)) {

* It was a debugger connect packet,

* just drop it now

goto bad;

}

#endif

if ((n = m_copy(m, 0, M_COPYALL)) != NULL) {

icmp_error(n, ICMP_UNREACH,

ICMP_UNREACH_PORT, 0, 0);

}

#endif

return rcvcnt;

}

udp4_sendup(m, off, (struct sockaddr *)src, inp->inp_socket);

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

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

struct mbuf *m;

int off; /* offset of udphdr */

{

u_int16_t *sport, *dport;

u_int16_t sport, dport;

int rcvcnt;

struct in6_addr *src6, *dst6;

struct in6_addr src6, dst6;

struct in_addr *dst4;

const struct in_addr *dst4;

struct in6pcb *in6p;

rcvcnt = 0;

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

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

if (src->sin6_family != AF_INET6 || dst->sin6_family != AF_INET6)

goto bad;

src6 = &src->sin6_addr;

in6_embedscope(&src6, src, NULL, NULL);

sport = &src->sin6_port;

sport = src->sin6_port;

dst6 = &dst->sin6_addr;

in6_embedscope(&dst6, dst, NULL, NULL);

dport = &dst->sin6_port;

dport = dst->sin6_port;

dst4 = (struct in_addr *)&dst->sin6_addr.s6_addr32[12];

if (IN6_IS_ADDR_MULTICAST(dst6)

if (IN6_IS_ADDR_MULTICAST(&dst6) ||

|| (af == AF_INET && IN_MULTICAST(dst4->s_addr))) {

(af == AF_INET && IN_MULTICAST(dst4->s_addr))) {

struct in6pcb *last;

* Deliver a multicast or broadcast datagram to *all* sockets

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

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

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

in6p = in6p->in6p_next) {

if (in6p->in6p_lport != *dport)

if (in6p->in6p_lport != dport)

continue;

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

if (!IN6_ARE_ADDR_EQUAL(&in6p->in6p_laddr, dst6)

if (!IN6_ARE_ADDR_EQUAL(&in6p->in6p_laddr, &dst6) &&

&& !in6_mcmatch(in6p, dst6, m->m_pkthdr.rcvif))

!in6_mcmatch(in6p, &dst6, m->m_pkthdr.rcvif))

continue;

}

#ifndef INET6_BINDV6ONLY

else {

if (IN6_IS_ADDR_V4MAPPED(dst6)

if (IN6_IS_ADDR_V4MAPPED(&dst6) &&

&& (in6p->in6p_flags & IN6P_BINDV6ONLY))

(in6p->in6p_flags & IN6P_BINDV6ONLY))

continue;

}

#endif

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

if (!IN6_ARE_ADDR_EQUAL(&in6p->in6p_faddr, src6)

if (!IN6_ARE_ADDR_EQUAL(&in6p->in6p_faddr,

|| in6p->in6p_fport != *sport)

&src6) || in6p->in6p_fport != sport)

continue;

}

#ifndef INET6_BINDV6ONLY

else {

if (IN6_IS_ADDR_V4MAPPED(src6)

if (IN6_IS_ADDR_V4MAPPED(&src6) &&

&& (in6p->in6p_flags & IN6P_BINDV6ONLY))

(in6p->in6p_flags & IN6P_BINDV6ONLY))

continue;

}

#endif

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

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

(SO_REUSEPORT|SO_REUSEADDR)) == 0)

break;

}

#if 0

if (last == NULL) {

* No matching pcb found; discard datagram.

* (No need to send an ICMP Port Unreachable

* for a broadcast or multicast datgram.)

switch (af) {

case AF_INET:

udpstat.udps_noportbcast++;

break;

case AF_INET6:

udp6stat.udp6s_noportmcast++;

break;

}

goto bad;

}

#endif

} else {

* Locate pcb for datagram.

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

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

dst6, *dport, 0);

&dst6, dport, 0);

if (in6p == 0) {

++udpstat.udps_pcbhashmiss;

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

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

if (in6p == 0) {

if (in6p == 0)

#if 0

struct mbuf *n;

n = m_copy(m, 0, M_COPYALL);

switch (af) {

case AF_INET:

if (m->m_flags & (M_BCAST | M_MCAST)) {

udpstat.udps_noportbcast++;

goto bad;

}

udpstat.udps_noport++;

if (n != NULL)

icmp_error(n, ICMP_UNREACH,

ICMP_UNREACH_PORT, 0, 0);

break;

case AF_INET6:

if (m->m_flags & M_MCAST) {

udp6stat.udp6s_noportmcast++;

goto bad;

}

udp6stat.udp6s_noport++;

if (n != NULL)

icmp6_error(n, ICMP6_DST_UNREACH,

ICMP6_DST_UNREACH_NOPORT, 0);

break;

}

#endif

return rcvcnt;

}

udp6_sendup(m, off, (struct sockaddr *)src, in6p->in6p_socket);

Line 942 udp_input(m, va_alist)

Line 917 udp_input(m, va_alist)

* Checksum extended UDP header and data.

if (uh->uh_sum) {

bzero(((struct ipovly *)ip)->ih_x1,

switch (m->m_pkthdr.csum_flags &

sizeof ((struct ipovly *)ip)->ih_x1);

((m->m_pkthdr.rcvif->if_csum_flags & M_CSUM_UDPv4) |

((struct ipovly *)ip)->ih_len = uh->uh_ulen;

M_CSUM_TCP_UDP_BAD | M_CSUM_DATA)) {

if (in_cksum(m, len + sizeof (struct ip)) != 0) {

case M_CSUM_UDPv4|M_CSUM_TCP_UDP_BAD:

udpstat.udps_badsum++;

UDP_CSUM_COUNTER_INCR(&udp_hwcsum_bad);

m_freem(m);

goto badcsum;

return;

case M_CSUM_UDPv4|M_CSUM_DATA:

UDP_CSUM_COUNTER_INCR(&udp_hwcsum_data);

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

goto badcsum;

break;

case M_CSUM_UDPv4:

/* Checksum was okay. */

UDP_CSUM_COUNTER_INCR(&udp_hwcsum_ok);

break;

default:

/* Need to compute it ourselves. */

UDP_CSUM_COUNTER_INCR(&udp_swcsum);

bzero(((struct ipovly *)ip)->ih_x1,

sizeof ((struct ipovly *)ip)->ih_x1);

((struct ipovly *)ip)->ih_len = uh->uh_ulen;

if (in_cksum(m, len + sizeof (struct ip)) != 0)

goto badcsum;

break;

}

Line 1030 udp_input(m, va_alist)

Line 1025 udp_input(m, va_alist)

m_freem(n);

if (opts)

m_freem(opts);

udpstat.udps_fullsock++;

} else

sorwakeup(last->inp_socket);

opts = 0;

Line 1136 bad:

Line 1132 bad:

m_freem(m);

if (opts)

m_freem(opts);

return;

badcsum:

udpstat.udps_badsum++;

m_freem(m);

}

#endif /*UDP6*/

Line 1233 udp_output(m, va_alist)

Line 1234 udp_output(m, va_alist)

* and addresses and length put into network format.

ui = mtod(m, struct udpiphdr *);

bzero(ui->ui_x1, sizeof ui->ui_x1);

ui->ui_pr = IPPROTO_UDP;

ui->ui_len = htons((u_int16_t)len + sizeof (struct udphdr));

ui->ui_src = inp->inp_laddr;

ui->ui_dst = inp->inp_faddr;

ui->ui_sport = inp->inp_lport;

ui->ui_dport = inp->inp_fport;

ui->ui_ulen = ui->ui_len;

ui->ui_ulen = htons((u_int16_t)len + sizeof(struct udphdr));

* Stuff checksum and output datagram.

* Set up checksum and output datagram.

ui->ui_sum = 0;

if (udpcksum) {

if ((ui->ui_sum = in_cksum(m, sizeof (struct udpiphdr) + len)) == 0)

ui->ui_sum = 0xffff;

* XXX Cache pseudo-header checksum part for

}

* XXX "connected" UDP sockets.

ui->ui_sum = in_cksum_phdr(ui->ui_src.s_addr,

ui->ui_dst.s_addr, htons((u_int16_t)len +

sizeof(struct udphdr) + IPPROTO_UDP));

m->m_pkthdr.csum_flags = M_CSUM_UDPv4;

m->m_pkthdr.csum_data = offsetof(struct udphdr, uh_sum);

} else

ui->ui_sum = 0;

((struct ip *)ui)->ip_len = sizeof (struct udpiphdr) + len;

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

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

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

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

(struct ifnet *)control, p));

if (req == PRU_PURGEIF) {

in_pcbpurgeif0(&udbtable, (struct ifnet *)control);

in_purgeif((struct ifnet *)control);

in_pcbpurgeif(&udbtable, (struct ifnet *)control);

return (0);

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

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

break;

inp = sotoinpcb(so);

inp->inp_ip.ip_ttl = ip_defttl;

#ifdef IPSEC

error = ipsec_init_policy(so, &inp->inp_sp);

if (error != 0) {

in_pcbdetach(inp);

break;

}

#endif /*IPSEC*/

break;

case PRU_DETACH:

CVSweb <webmaster@jp.NetBSD.org>