6afbf203bd
This commit includes the following changes: 1) Old-style (pr_usrreq()) protocols are no longer supported, the compatibility glue for them is deleted, and the kernel will panic on boot if any are compiled in. 2) Certain protocol entry points are modified to take a process structure, so they they can easily tell whether or not it is possible to sleep, and also to access credentials. 3) SS_PRIV is no more, and with it goes the SO_PRIVSTATE setsockopt() call. Protocols should use the process pointer they are now passed. 4) The PF_LOCAL and PF_ROUTE families have been updated to use the new style, as has the `raw' skeleton family. 5) PF_LOCAL sockets now obey the process's umask when creating a socket in the filesystem. As a result, LINT is now broken. I'm hoping that some enterprising hacker with a bit more time will either make the broken bits work (should be easy for netipx) or dike them out.
280 lines
11 KiB
C
280 lines
11 KiB
C
/*-
|
|
* Copyright (c) 1982, 1986, 1990, 1993
|
|
* The Regents of the University of California. All rights reserved.
|
|
*
|
|
* Redistribution and use in source and binary forms, with or without
|
|
* modification, are permitted provided that the following conditions
|
|
* are met:
|
|
* 1. Redistributions of source code must retain the above copyright
|
|
* notice, this list of conditions and the following disclaimer.
|
|
* 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
|
|
* 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.
|
|
*
|
|
* THIS SOFTWARE IS PROVIDED BY THE REGENTS 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
|
|
* ARE DISCLAIMED. IN NO EVENT SHALL THE REGENTS OR CONTRIBUTORS BE LIABLE
|
|
* FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL
|
|
* DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS
|
|
* OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION)
|
|
* HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT
|
|
* LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY
|
|
* OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF
|
|
* SUCH DAMAGE.
|
|
*
|
|
* @(#)socketvar.h 8.3 (Berkeley) 2/19/95
|
|
* $Id: socketvar.h,v 1.18 1997/02/22 09:45:56 peter Exp $
|
|
*/
|
|
|
|
#ifndef _SYS_SOCKETVAR_H_
|
|
#define _SYS_SOCKETVAR_H_
|
|
|
|
#include <sys/queue.h> /* for TAILQ macros */
|
|
#include <sys/select.h> /* for struct selinfo */
|
|
|
|
/*
|
|
* Kernel structure per socket.
|
|
* Contains send and receive buffer queues,
|
|
* handle on protocol and pointer to protocol
|
|
* private data and error information.
|
|
*/
|
|
struct socket {
|
|
short so_type; /* generic type, see socket.h */
|
|
short so_options; /* from socket call, see socket.h */
|
|
short so_linger; /* time to linger while closing */
|
|
short so_state; /* internal state flags SS_*, below */
|
|
caddr_t so_pcb; /* protocol control block */
|
|
struct protosw *so_proto; /* protocol handle */
|
|
/*
|
|
* Variables for connection queuing.
|
|
* Socket where accepts occur is so_head in all subsidiary sockets.
|
|
* If so_head is 0, socket is not related to an accept.
|
|
* For head socket so_q0 queues partially completed connections,
|
|
* while so_q is a queue of connections ready to be accepted.
|
|
* If a connection is aborted and it has so_head set, then
|
|
* it has to be pulled out of either so_q0 or so_q.
|
|
* We allow connections to queue up based on current queue lengths
|
|
* and limit on number of queued connections for this socket.
|
|
*/
|
|
struct socket *so_head; /* back pointer to accept socket */
|
|
TAILQ_HEAD(, socket) so_incomp; /* queue of partial unaccepted connections */
|
|
TAILQ_HEAD(, socket) so_comp; /* queue of complete unaccepted connections */
|
|
TAILQ_ENTRY(socket) so_list; /* list of unaccepted connections */
|
|
short so_qlen; /* number of unaccepted connections */
|
|
short so_incqlen; /* number of unaccepted incomplete
|
|
connections */
|
|
short so_qlimit; /* max number queued connections */
|
|
short so_timeo; /* connection timeout */
|
|
u_short so_error; /* error affecting connection */
|
|
pid_t so_pgid; /* pgid for signals */
|
|
u_long so_oobmark; /* chars to oob mark */
|
|
/*
|
|
* Variables for socket buffering.
|
|
*/
|
|
struct sockbuf {
|
|
u_long sb_cc; /* actual chars in buffer */
|
|
u_long sb_hiwat; /* max actual char count */
|
|
u_long sb_mbcnt; /* chars of mbufs used */
|
|
u_long sb_mbmax; /* max chars of mbufs to use */
|
|
long sb_lowat; /* low water mark */
|
|
struct mbuf *sb_mb; /* the mbuf chain */
|
|
struct selinfo sb_sel; /* process selecting read/write */
|
|
short sb_flags; /* flags, see below */
|
|
short sb_timeo; /* timeout for read/write */
|
|
} so_rcv, so_snd;
|
|
#define SB_MAX (256*1024) /* default for max chars in sockbuf */
|
|
#define SB_LOCK 0x01 /* lock on data queue */
|
|
#define SB_WANT 0x02 /* someone is waiting to lock */
|
|
#define SB_WAIT 0x04 /* someone is waiting for data/space */
|
|
#define SB_SEL 0x08 /* someone is selecting */
|
|
#define SB_ASYNC 0x10 /* ASYNC I/O, need signals */
|
|
#define SB_NOTIFY (SB_WAIT|SB_SEL|SB_ASYNC)
|
|
#define SB_NOINTR 0x40 /* operations not interruptible */
|
|
|
|
caddr_t so_tpcb; /* Wisc. protocol control block XXX */
|
|
void (*so_upcall) __P((struct socket *so, caddr_t arg, int waitf));
|
|
caddr_t so_upcallarg; /* Arg for above */
|
|
};
|
|
|
|
/*
|
|
* Socket state bits.
|
|
*/
|
|
#define SS_NOFDREF 0x0001 /* no file table ref any more */
|
|
#define SS_ISCONNECTED 0x0002 /* socket connected to a peer */
|
|
#define SS_ISCONNECTING 0x0004 /* in process of connecting to peer */
|
|
#define SS_ISDISCONNECTING 0x0008 /* in process of disconnecting */
|
|
#define SS_CANTSENDMORE 0x0010 /* can't send more data to peer */
|
|
#define SS_CANTRCVMORE 0x0020 /* can't receive more data from peer */
|
|
#define SS_RCVATMARK 0x0040 /* at mark on input */
|
|
|
|
/*efine SS_PRIV 0x0080 privileged for broadcast, raw... */
|
|
#define SS_NBIO 0x0100 /* non-blocking ops */
|
|
#define SS_ASYNC 0x0200 /* async i/o notify */
|
|
#define SS_ISCONFIRMING 0x0400 /* deciding to accept connection req */
|
|
|
|
#define SS_INCOMP 0x0800 /* unaccepted, incomplete connection */
|
|
#define SS_COMP 0x1000 /* unaccepted, complete connection */
|
|
|
|
|
|
/*
|
|
* Macros for sockets and socket buffering.
|
|
*/
|
|
|
|
/*
|
|
* How much space is there in a socket buffer (so->so_snd or so->so_rcv)?
|
|
* This is problematical if the fields are unsigned, as the space might
|
|
* still be negative (cc > hiwat or mbcnt > mbmax). Should detect
|
|
* overflow and return 0. Should use "lmin" but it doesn't exist now.
|
|
*/
|
|
#define sbspace(sb) \
|
|
((long) imin((int)((sb)->sb_hiwat - (sb)->sb_cc), \
|
|
(int)((sb)->sb_mbmax - (sb)->sb_mbcnt)))
|
|
|
|
/* do we have to send all at once on a socket? */
|
|
#define sosendallatonce(so) \
|
|
((so)->so_proto->pr_flags & PR_ATOMIC)
|
|
|
|
/* can we read something from so? */
|
|
#define soreadable(so) \
|
|
((so)->so_rcv.sb_cc >= (so)->so_rcv.sb_lowat || \
|
|
((so)->so_state & SS_CANTRCVMORE) || \
|
|
(so)->so_comp.tqh_first || (so)->so_error)
|
|
|
|
/* can we write something to so? */
|
|
#define sowriteable(so) \
|
|
((sbspace(&(so)->so_snd) >= (so)->so_snd.sb_lowat && \
|
|
(((so)->so_state&SS_ISCONNECTED) || \
|
|
((so)->so_proto->pr_flags&PR_CONNREQUIRED)==0)) || \
|
|
((so)->so_state & SS_CANTSENDMORE) || \
|
|
(so)->so_error)
|
|
|
|
/* adjust counters in sb reflecting allocation of m */
|
|
#define sballoc(sb, m) { \
|
|
(sb)->sb_cc += (m)->m_len; \
|
|
(sb)->sb_mbcnt += MSIZE; \
|
|
if ((m)->m_flags & M_EXT) \
|
|
(sb)->sb_mbcnt += (m)->m_ext.ext_size; \
|
|
}
|
|
|
|
/* adjust counters in sb reflecting freeing of m */
|
|
#define sbfree(sb, m) { \
|
|
(sb)->sb_cc -= (m)->m_len; \
|
|
(sb)->sb_mbcnt -= MSIZE; \
|
|
if ((m)->m_flags & M_EXT) \
|
|
(sb)->sb_mbcnt -= (m)->m_ext.ext_size; \
|
|
}
|
|
|
|
/*
|
|
* Set lock on sockbuf sb; sleep if lock is already held.
|
|
* Unless SB_NOINTR is set on sockbuf, sleep is interruptible.
|
|
* Returns error without lock if sleep is interrupted.
|
|
*/
|
|
#define sblock(sb, wf) ((sb)->sb_flags & SB_LOCK ? \
|
|
(((wf) == M_WAITOK) ? sb_lock(sb) : EWOULDBLOCK) : \
|
|
((sb)->sb_flags |= SB_LOCK), 0)
|
|
|
|
/* release lock on sockbuf sb */
|
|
#define sbunlock(sb) { \
|
|
(sb)->sb_flags &= ~SB_LOCK; \
|
|
if ((sb)->sb_flags & SB_WANT) { \
|
|
(sb)->sb_flags &= ~SB_WANT; \
|
|
wakeup((caddr_t)&(sb)->sb_flags); \
|
|
} \
|
|
}
|
|
|
|
#define sorwakeup(so) { sowakeup((so), &(so)->so_rcv); \
|
|
if ((so)->so_upcall) \
|
|
(*((so)->so_upcall))((so), (so)->so_upcallarg, M_DONTWAIT); \
|
|
}
|
|
|
|
#define sowwakeup(so) sowakeup((so), &(so)->so_snd)
|
|
|
|
#ifdef KERNEL
|
|
extern u_long sb_max;
|
|
|
|
/* to catch callers missing new second argument to sonewconn: */
|
|
#define sonewconn(head, connstatus) sonewconn1((head), (connstatus))
|
|
|
|
struct filedesc;
|
|
struct mbuf;
|
|
struct sockaddr;
|
|
struct stat;
|
|
|
|
/*
|
|
* File operations on sockets.
|
|
*/
|
|
int soo_ioctl __P((struct file *fp, int cmd, caddr_t data,
|
|
struct proc *p));
|
|
int soo_select __P((struct file *fp, int which, struct proc *p));
|
|
int soo_stat __P((struct socket *so, struct stat *ub));
|
|
|
|
/*
|
|
* From uipc_socket and friends
|
|
*/
|
|
int getsock __P((struct filedesc *fdp, int fdes, struct file **fpp));
|
|
int sockargs __P((struct mbuf **mp, caddr_t buf, int buflen, int type));
|
|
void sbappend __P((struct sockbuf *sb, struct mbuf *m));
|
|
int sbappendaddr __P((struct sockbuf *sb, struct sockaddr *asa,
|
|
struct mbuf *m0, struct mbuf *control));
|
|
int sbappendcontrol __P((struct sockbuf *sb, struct mbuf *m0,
|
|
struct mbuf *control));
|
|
void sbappendrecord __P((struct sockbuf *sb, struct mbuf *m0));
|
|
void sbcheck __P((struct sockbuf *sb));
|
|
void sbcompress __P((struct sockbuf *sb, struct mbuf *m, struct mbuf *n));
|
|
struct mbuf *
|
|
sbcreatecontrol __P((caddr_t p, int size, int type, int level));
|
|
void sbdrop __P((struct sockbuf *sb, int len));
|
|
void sbdroprecord __P((struct sockbuf *sb));
|
|
void sbflush __P((struct sockbuf *sb));
|
|
void sbinsertoob __P((struct sockbuf *sb, struct mbuf *m0));
|
|
void sbrelease __P((struct sockbuf *sb));
|
|
int sbreserve __P((struct sockbuf *sb, u_long cc));
|
|
int sbwait __P((struct sockbuf *sb));
|
|
int sb_lock __P((struct sockbuf *sb));
|
|
int soabort __P((struct socket *so));
|
|
int soaccept __P((struct socket *so, struct mbuf *nam));
|
|
int sobind __P((struct socket *so, struct mbuf *nam, struct proc *p));
|
|
void socantrcvmore __P((struct socket *so));
|
|
void socantsendmore __P((struct socket *so));
|
|
int soclose __P((struct socket *so));
|
|
int soconnect __P((struct socket *so, struct mbuf *nam, struct proc *p));
|
|
int soconnect2 __P((struct socket *so1, struct socket *so2));
|
|
int socreate __P((int dom, struct socket **aso, int type, int proto,
|
|
struct proc *p));
|
|
int sodisconnect __P((struct socket *so));
|
|
void sofree __P((struct socket *so));
|
|
int sogetopt __P((struct socket *so, int level, int optname,
|
|
struct mbuf **mp, struct proc *p));
|
|
void sohasoutofband __P((struct socket *so));
|
|
void soisconnected __P((struct socket *so));
|
|
void soisconnecting __P((struct socket *so));
|
|
void soisdisconnected __P((struct socket *so));
|
|
void soisdisconnecting __P((struct socket *so));
|
|
int solisten __P((struct socket *so, int backlog, struct proc *p));
|
|
struct socket *
|
|
sodropablereq __P((struct socket *head));
|
|
struct socket *
|
|
sonewconn1 __P((struct socket *head, int connstatus));
|
|
int soreceive __P((struct socket *so, struct mbuf **paddr, struct uio *uio,
|
|
struct mbuf **mp0, struct mbuf **controlp, int *flagsp));
|
|
int soreserve __P((struct socket *so, u_long sndcc, u_long rcvcc));
|
|
void sorflush __P((struct socket *so));
|
|
int soselect __P((struct socket *so, int which, struct proc *p));
|
|
int sosend __P((struct socket *so, struct mbuf *addr, struct uio *uio,
|
|
struct mbuf *top, struct mbuf *control, int flags));
|
|
int sosetopt __P((struct socket *so, int level, int optname,
|
|
struct mbuf *m0, struct proc *p));
|
|
int soshutdown __P((struct socket *so, int how));
|
|
void sowakeup __P((struct socket *so, struct sockbuf *sb));
|
|
#endif /* KERNEL */
|
|
|
|
#endif /* !_SYS_SOCKETVAR_H_ */
|