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.8 and 1.15

version 1.8, 1994/01/08 23:19:48

version 1.15, 1995/04/13 06:37:18

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: @(#)udp_usrreq.c 7.20 (Berkeley) 4/20/91

* @(#)udp_usrreq.c 8.4 (Berkeley) 1/21/94

* $Id$

#include <sys/param.h>

Line 40

Line 41

#include <sys/protosw.h>

#include <sys/socket.h>

#include <sys/socketvar.h>

#include <sys/errno.h>

#include <sys/stat.h>

#include <net/if.h>

Line 47

Line 49

#include <netinet/in.h>

#include <netinet/in_systm.h>

#include <netinet/in_var.h>

#include <netinet/ip.h>

#include <netinet/in_pcb.h>

#include <netinet/ip_var.h>

Line 63 int udpcksum = 1;

Line 66 int udpcksum = 1;

#else

int udpcksum = 0; /* XXX */

#endif

int udp_ttl = UDP_TTL;

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

struct inpcb *udp_last_inpcb = &udb;

static void udp_detach __P((struct inpcb *));

static void udp_notify __P((struct inpcb *, int));

static struct mbuf *

static struct mbuf *udp_saveopt __P((caddr_t, int, int));

udp_saveopt __P((caddr_t, int, int));

void

udp_init()

{

udb.inp_next = udb.inp_prev = &udb;

}

Line 122 udp_input(m, iphlen)

* Make mbuf data length reflect UDP length.

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

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

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

if (ip->ip_len != len) {

if (len > ip->ip_len) {

udpstat.udps_badlen++;

Line 151 udp_input(m, iphlen)

return;

}

#ifdef MULTICAST

if (IN_MULTICAST(ntohl(ip->ip_dst.s_addr)) ||

in_broadcast(ip->ip_dst)) {

in_broadcast(ip->ip_dst, m->m_pkthdr.rcvif)) {

struct socket *last;

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

Line 168 udp_input(m, iphlen)

* Those applications open the multiple sockets to overcome an

* inadequacy of the UDP socket interface, but for backwards

* compatibility we avoid the problem here rather than

* fixing the interface. Maybe 4.4BSD will remedy this?)

* fixing the interface. Maybe 4.5BSD will remedy this?)

* Construct sockaddr format source address.

Line 203 udp_input(m, iphlen)

Line 204 udp_input(m, iphlen)

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

if (sbappendaddr(&last->so_rcv,

(struct sockaddr *)&udp_in,

n, (struct mbuf *)0) == 0)

n, (struct mbuf *)0) == 0) {

m_freem(n);

else

udpstat.udps_fullsock++;

} else

sorwakeup(last);

}

last = inp->inp_socket;

* Don't look for additional matches if this one

* Don't look for additional matches if this one does

* does not have the SO_REUSEADDR socket option set.

* not have either the SO_REUSEPORT or SO_REUSEADDR

* This heuristic avoids searching through all pcbs

* socket options set. This heuristic avoids searching

* in the common case of a non-shared port. It

* through all pcbs in the common case of a non-shared

* assumes that an application will never clear

* port. It * assumes that an application will never

* the SO_REUSEADDR option after setting it.

* clear these options after setting them.

if ((last->so_options & SO_REUSEADDR) == 0)

if ((last->so_options&(SO_REUSEPORT|SO_REUSEADDR) == 0))

break;

}

Line 228 udp_input(m, iphlen)

Line 230 udp_input(m, iphlen)

* (No need to send an ICMP Port Unreachable

* for a broadcast or multicast datgram.)

udpstat.udps_noportbcast++;

goto bad;

}

if (sbappendaddr(&last->so_rcv, (struct sockaddr *)&udp_in,

m, (struct mbuf *)0) == 0)

m, (struct mbuf *)0) == 0) {

udpstat.udps_fullsock++;

goto bad;

}

sorwakeup(last);

return;

}

#endif

* Locate pcb for datagram.

Line 252 udp_input(m, iphlen)

Line 256 udp_input(m, iphlen)

udpstat.udpps_pcbcachemiss++;

}

if (inp == 0) {

/* don't send ICMP response for broadcast packet */

udpstat.udps_noport++;

#ifndef MULTICAST

/* XXX why don't we do this with MULTICAST? */

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

udpstat.udps_noportbcast++;

goto bad;

}

#endif

*ip = save_ip;

ip->ip_len += iphlen;

icmp_error(m, ICMP_UNREACH, ICMP_UNREACH_PORT);

icmp_error(m, ICMP_UNREACH, ICMP_UNREACH_PORT, 0, 0);

return;

}

Line 320 bad:

* Create a "control" mbuf containing the specified data

* with the specified type for presentation with a datagram.

static struct mbuf *

struct mbuf *

udp_saveopt(p, size, type)

caddr_t p;

Line 332 udp_saveopt(p, size, type)

if ((m = m_get(M_DONTWAIT, MT_CONTROL)) == NULL)

return ((struct mbuf *) NULL);

cp = (struct cmsghdr *) mtod(m, struct cmsghdr *);

bcopy(p, (caddr_t)(cp + 1), size);

bcopy(p, CMSG_DATA(cp), size);

size += sizeof(*cp);

m->m_len = size;

cp->cmsg_len = size;

Line 350 udp_notify(inp, errno)

int errno;

{

inp->inp_socket->so_error = errno;

sorwakeup(inp->inp_socket);

sowwakeup(inp->inp_socket);

Line 366 udp_ctlinput(cmd, sa, ip)

Line 365 udp_ctlinput(cmd, sa, ip)

extern struct in_addr zeroin_addr;

extern u_char inetctlerrmap[];

if ((unsigned)cmd > PRC_NCMDS || inetctlerrmap[cmd] == 0)

if (!PRC_IS_REDIRECT(cmd) &&

((unsigned)cmd >= PRC_NCMDS || inetctlerrmap[cmd] == 0))

return;

if (ip) {

uh = (struct udphdr *)((caddr_t)ip + (ip->ip_hl << 2));

Line 415 udp_output(inp, m, addr, control)

* Calculate data length and get a mbuf

* for UDP and IP headers.

M_PREPEND(m, sizeof(struct udpiphdr), M_WAIT);

M_PREPEND(m, sizeof(struct udpiphdr), M_DONTWAIT);

if (m == 0) {

error = ENOBUFS;

goto release;

}

* Fill in mbuf with extended UDP header

Line 425 udp_output(inp, m, addr, control)

Line 429 udp_output(inp, m, addr, control)

ui->ui_next = ui->ui_prev = 0;

ui->ui_x1 = 0;

ui->ui_pr = IPPROTO_UDP;

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

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;

Line 445 udp_output(inp, m, addr, control)

Line 449 udp_output(inp, m, addr, control)

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

udpstat.udps_opackets++;

error = ip_output(m, inp->inp_options, &inp->inp_route,

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

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

#ifdef MULTICAST

inp->inp_moptions);

| IP_MULTICASTOPTS, inp->inp_moptions

#endif

);

if (addr) {

in_pcbdisconnect(inp);

Line 479 udp_usrreq(so, req, m, addr, control)

Line 480 udp_usrreq(so, req, m, addr, control)

int s;

if (req == PRU_CONTROL)

return (in_control(so, (int)m, (caddr_t)addr,

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

(struct ifnet *)control));

if (inp == NULL && req != PRU_ATTACH) {

error = EINVAL;

Line 504 udp_usrreq(so, req, m, addr, control)

Line 505 udp_usrreq(so, req, m, addr, control)

error = soreserve(so, udp_sendspace, udp_recvspace);

if (error)

break;

((struct inpcb *) so->so_pcb)->inp_ip.ip_ttl = udp_ttl;

((struct inpcb *) so->so_pcb)->inp_ip.ip_ttl = ip_defttl;

break;

case PRU_DETACH:

Line 616 udp_detach(inp)

Line 617 udp_detach(inp)

in_pcbdetach(inp);

splx(s);

}

* Sysctl for udp variables.

udp_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 UDPCTL_CHECKSUM:

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

default:

return (ENOPROTOOPT);

}

/* NOTREACHED */

}

CVSweb <webmaster@jp.NetBSD.org>