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.52.8.1 and 1.66.4.4

version 1.52.8.1, 1999/12/27 18:36:21

version 1.66.4.4, 2001/04/06 00:26:54

Line 65

#include "opt_ipsec.h"

#include "opt_ipkdb.h"

#include "ipkdb.h"

#include <sys/param.h>

#include <sys/malloc.h>

Line 119

Line 118

#include <netkey/key_debug.h>

#endif /*IPSEC*/

#ifdef IPKDB

#include <ipkdb/ipkdb.h>

#endif

* UDP protocol implementation.

* Per RFC 768, August, 1980.

Line 155 udp_init()

Line 158 udp_init()

in_pcbinit(&udbtable, udbhashsize, udbhashsize);

}

#ifndef UDP6

void

#if __STDC__

udp_input(struct mbuf *m, ...)

Line 218 udp_input(m, va_alist)

Line 222 udp_input(m, va_alist)

}

#endif

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

if (uh->uh_dport == 0)

goto bad;

* Make mbuf data length reflect UDP length.

* If not enough data to reflect UDP length, drop.

len = ntohs((u_int16_t)uh->uh_ulen);

if (ip->ip_len != iphlen + len) {

if (ip->ip_len < iphlen + len) {

if (ip->ip_len < iphlen + len || len < sizeof(struct udphdr)) {

udpstat.udps_badlen++;

goto bad;

}

Line 235 udp_input(m, va_alist)

Line 243 udp_input(m, va_alist)

* Checksum extended UDP header and data.

if (uh->uh_sum) {

#ifndef PULLDOWN_TEST

struct ip save_ip;

* Save a copy of the IP header in case we want restore it

* for sending an ICMP error message in response.

save_ip = *ip;

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) {

udpstat.udps_badsum++;

m_freem(m);

return;

}

*ip = save_ip;

#else

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

udpstat.udps_badsum++;

m_freem(m);

return;

}

#endif

}

/* construct source and dst sockaddrs. */

Line 300 udp_input(m, va_alist)

Line 287 udp_input(m, va_alist)

#endif

if (n == 0) {

udpstat.udps_noport++;

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

udpstat.udps_noportbcast++;

goto bad;

}

#if NIPKDB > 0

udpstat.udps_noport++;

#ifdef IPKDB

if (checkipkdb(&ip->ip_src, uh->uh_sport, uh->uh_dport,

m, iphlen + sizeof(struct udphdr),

m->m_pkthdr.len - iphlen - sizeof(struct udphdr))) {

Line 375 udp6_input(mp, offp, proto)

Line 362 udp6_input(mp, offp, proto)

goto bad;

}

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

if (uh->uh_dport == 0)

goto bad;

/* Be proactive about malicious use of IPv4 mapped address */

if (IN6_IS_ADDR_V4MAPPED(&ip6->ip6_src) ||

IN6_IS_ADDR_V4MAPPED(&ip6->ip6_dst)) {

/* XXX stat */

goto bad;

}

* Checksum extended UDP header and data.

Line 417 udp6_input(mp, offp, proto)

Line 415 udp6_input(mp, offp, proto)

dst.sin6_port = uh->uh_dport;

if (udp6_realinput(AF_INET6, &src, &dst, m, off) == 0) {

udp6stat.udp6s_noport++;

if (m->m_flags & M_MCAST) {

udp6stat.udp6s_noportmcast++;

goto bad;

}

udp6stat.udp6s_noport++;

icmp6_error(m, ICMP6_DST_UNREACH, ICMP6_DST_UNREACH_NOPORT, 0);

m = NULL;

}

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

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

dst4 = &dst->sin_addr;

dport = &dst->sin_port;

if (IN_MULTICAST(src4->s_addr) ||

if (IN_MULTICAST(dst4->s_addr) ||

in_broadcast(*dst4, m->m_pkthdr.rcvif)) {

struct inpcb *last;

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

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

* (No need to send an ICMP Port Unreachable

* for a broadcast or multicast datgram.)

udpstat.udps_noport++;

udpstat.udps_noportbcast++;

goto bad;

}

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

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

#if 0

struct mbuf *n;

udpstat.udps_noport++;

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

udpstat.udps_noportbcast++;

goto bad;

}

#if NIPKDB > 0

udpstat.udps_noport++;

#ifdef IPKDB

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

m->m_pkthdr.len - off)) {

Line 675 bad:

Line 672 bad:

static int

in6_mcmatch(in6p, ia6, ifp)

struct in6pcb *in6p;

struct in6_addr *ia6;

struct ifnet *ifp;

{

struct ip6_moptions *im6o = in6p->in6p_moptions;

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

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

u_int16_t *sport, *dport;

int rcvcnt;

struct in6_addr *src6, *dst6;

struct in_addr *src4;

struct in_addr *dst4;

struct in6pcb *in6p;

rcvcnt = 0;

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

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

sport = &src->sin6_port;

dst6 = &dst->sin6_addr;

dport = &dst->sin6_port;

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

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

if (IN6_IS_ADDR_MULTICAST(dst6)

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

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

struct in6pcb *last;

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

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

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

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

continue;

}

#ifndef INET6_BINDV6ONLY

else {

if (IN6_IS_ADDR_V4MAPPED(dst6)

&& (in6p->in6p_flags & IN6P_BINDV6ONLY))

continue;

}

#endif

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

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

|| in6p->in6p_fport != *sport)

continue;

}

#ifndef INET6_BINDV6ONLY

else {

if (IN6_IS_ADDR_V4MAPPED(src6)

&& (in6p->in6p_flags & IN6P_BINDV6ONLY))

continue;

}

#endif

last = in6p;

udp6_sendup(m, off, (struct sockaddr *)src,

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

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

switch (af) {

case AF_INET:

udpstat.udps_noport++;

udpstat.udps_noportbcast++;

break;

case AF_INET6:

udp6stat.udp6s_noport++;

udp6stat.udp6s_noportmcast++;

break;

}

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

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

n = m_copy(m, 0, M_COPYALL);

switch (af) {

case AF_INET:

udpstat.udps_noport++;

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:

udp6stat.udp6s_noport++;

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);

Line 852 bad:

Line 861 bad:

}

#endif

#if 0

#else /*UDP6*/

void

#if __STDC__

udp_input(struct mbuf *m, ...)

Line 863 udp_input(m, va_alist)

Line 873 udp_input(m, va_alist)

#endif

{

int proto;

struct ip *ip;

struct udphdr *uh;

struct inpcb *inp;

struct mbuf *opts = 0;

int len;

struct ip save_ip;

Line 905 udp_input(m, va_alist)

Line 915 udp_input(m, va_alist)

}

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

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

if (uh->uh_dport == 0)

goto bad;

* Make mbuf data length reflect UDP length.

* If not enough data to reflect UDP length, drop.

len = ntohs((u_int16_t)uh->uh_ulen);

if (ip->ip_len != iphlen + len) {

if (ip->ip_len < iphlen + len) {

if (ip->ip_len < iphlen + len || len < sizeof(struct udphdr)) {

udpstat.udps_badlen++;

goto bad;

}

Line 1040 udp_input(m, va_alist)

Line 1054 udp_input(m, va_alist)

* (No need to send an ICMP Port Unreachable

* for a broadcast or multicast datgram.)

udpstat.udps_noport++;

udpstat.udps_noportbcast++;

goto bad;

}

Line 1074 udp_input(m, va_alist)

Line 1087 udp_input(m, va_alist)

++udpstat.udps_pcbhashmiss;

inp = in_pcblookup_bind(&udbtable, ip->ip_dst, uh->uh_dport);

if (inp == 0) {

udpstat.udps_noport++;

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

udpstat.udps_noportbcast++;

goto bad;

}

udpstat.udps_noport++;

*ip = save_ip;

#if NIPKDB > 0

#ifdef IPKDB

if (checkipkdb(&ip->ip_src,

uh->uh_sport,

uh->uh_dport,

Line 1123 bad:

Line 1136 bad:

if (opts)

m_freem(opts);

}

#endif

#endif /*UDP6*/

* Notify a udp user of an asynchronous error;

Line 1131 bad:

Line 1144 bad:

static void

udp_notify(inp, errno)

struct inpcb *inp;

int errno;

{

Line 1146 udp_ctlinput(cmd, sa, v)

Line 1159 udp_ctlinput(cmd, sa, v)

struct sockaddr *sa;

void *v;

{

struct ip *ip = v;

struct udphdr *uh;

extern int inetctlerrmap[];

void (*notify) __P((struct inpcb *, int)) = udp_notify;

int errno;

Line 1185 udp_output(m, va_alist)

Line 1197 udp_output(m, va_alist)

va_dcl

#endif

{

struct inpcb *inp;

struct udpiphdr *ui;

int len = m->m_pkthdr.len;

int error = 0;

va_list ap;

Line 1242 udp_output(m, va_alist)

Line 1254 udp_output(m, va_alist)

udpstat.udps_opackets++;

#ifdef IPSEC

m->m_pkthdr.rcvif = (struct ifnet *)inp->inp_socket;

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

error = ENOBUFS;

goto release;

}

#endif /*IPSEC*/

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

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

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

struct mbuf *m, *nam, *control;

struct proc *p;

{

struct inpcb *inp;

int s;

int error = 0;

if (req == PRU_CONTROL)

return (in_control(so, (long)m, (caddr_t)nam,

(struct ifnet *)control, p));

if (req == PRU_PURGEIF) {

in_purgeif((struct ifnet *)control);

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

return (0);

}

s = splsoftnet();

inp = sotoinpcb(so);

#ifdef DIAGNOSTIC

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

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

inp = sotoinpcb(so);

inp->inp_ip.ip_ttl = ip_defttl;

#ifdef IPSEC

error = ipsec_init_policy(&inp->inp_sp);

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

if (error != 0) {

in_pcbdetach(inp);

break;

CVSweb <webmaster@jp.NetBSD.org>