#include <sys/param.h>
#include <sys/systm.h>
#include <sys/file_internal.h>
#include <sys/event.h>
#include <sys/protosw.h>
#include <sys/socket.h>
#include <sys/socketvar.h>
#include <sys/filio.h>
#include <sys/sockio.h>
#include <sys/stat.h>
#include <sys/uio.h>
#include <sys/filedesc.h>
#include <sys/kauth.h>
#include <sys/signalvar.h>
#include <sys/vnode.h>
#include <net/if.h>
#include <net/route.h>
#if CONFIG_MACF
#include <security/mac_framework.h>
#endif
static int soo_read(struct fileproc *, struct uio *, int, vfs_context_t ctx);
static int soo_write(struct fileproc *, struct uio *, int, vfs_context_t ctx);
static int soo_close(struct fileglob *, vfs_context_t ctx);
static int soo_drain(struct fileproc *, vfs_context_t ctx);
const struct fileops socketops = {
.fo_type = DTYPE_SOCKET,
.fo_read = soo_read,
.fo_write = soo_write,
.fo_ioctl = soo_ioctl,
.fo_select = soo_select,
.fo_close = soo_close,
.fo_drain = soo_drain,
.fo_kqfilter = soo_kqfilter,
};
static int
soo_read(struct fileproc *fp, struct uio *uio, __unused int flags,
__unused vfs_context_t ctx)
{
struct socket *so;
int stat;
int (*fsoreceive)(struct socket *so2, struct sockaddr **paddr,
struct uio *uio2, struct mbuf **mp0, struct mbuf **controlp,
int *flagsp);
if ((so = (struct socket *)fp->fp_glob->fg_data) == NULL) {
return EBADF;
}
fsoreceive = so->so_proto->pr_usrreqs->pru_soreceive;
stat = (*fsoreceive)(so, 0, uio, 0, 0, 0);
return stat;
}
static int
soo_write(struct fileproc *fp, struct uio *uio, __unused int flags,
vfs_context_t ctx)
{
struct socket *so;
int stat;
int (*fsosend)(struct socket *so2, struct sockaddr *addr,
struct uio *uio2, struct mbuf *top, struct mbuf *control,
int flags2);
proc_t procp;
if ((so = (struct socket *)fp->fp_glob->fg_data) == NULL) {
return EBADF;
}
fsosend = so->so_proto->pr_usrreqs->pru_sosend;
stat = (*fsosend)(so, 0, uio, 0, 0, 0);
procp = vfs_context_proc(ctx);
if (stat == EPIPE && !(so->so_flags & SOF_NOSIGPIPE)) {
psignal(procp, SIGPIPE);
}
return stat;
}
__private_extern__ int
soioctl(struct socket *so, u_long cmd, caddr_t data, struct proc *p)
{
int error = 0;
int int_arg;
#if CONFIG_MACF_SOCKET_SUBSET
error = mac_socket_check_ioctl(kauth_cred_get(), so, cmd);
if (error) {
return error;
}
#endif
socket_lock(so, 1);
if (IOCGROUP(cmd) != 'i' && IOCGROUP(cmd) != 'r') {
switch (cmd) {
case SIOCGASSOCIDS32:
case SIOCGASSOCIDS64:
case SIOCGCONNIDS32:
case SIOCGCONNIDS64:
case SIOCGCONNINFO32:
case SIOCGCONNINFO64:
case SIOCSCONNORDER:
case SIOCGCONNORDER:
break;
default:
error = sflt_ioctl(so, cmd, data);
if (error != 0) {
goto out;
}
break;
}
}
switch (cmd) {
case FIONBIO:
bcopy(data, &int_arg, sizeof(int_arg));
if (int_arg) {
so->so_state |= SS_NBIO;
} else {
so->so_state &= ~SS_NBIO;
}
goto out;
case FIOASYNC:
bcopy(data, &int_arg, sizeof(int_arg));
if (int_arg) {
so->so_state |= SS_ASYNC;
so->so_rcv.sb_flags |= SB_ASYNC;
so->so_snd.sb_flags |= SB_ASYNC;
} else {
so->so_state &= ~SS_ASYNC;
so->so_rcv.sb_flags &= ~SB_ASYNC;
so->so_snd.sb_flags &= ~SB_ASYNC;
}
goto out;
case FIONREAD:
bcopy(&so->so_rcv.sb_cc, data, sizeof(u_int32_t));
goto out;
case SIOCSPGRP:
bcopy(data, &so->so_pgid, sizeof(pid_t));
goto out;
case SIOCGPGRP:
bcopy(&so->so_pgid, data, sizeof(pid_t));
goto out;
case SIOCATMARK:
int_arg = (so->so_state & SS_RCVATMARK) != 0;
bcopy(&int_arg, data, sizeof(int_arg));
goto out;
case SIOCSETOT:
error = EOPNOTSUPP;
goto out;
case SIOCGASSOCIDS32:
case SIOCGASSOCIDS64:
case SIOCGCONNIDS32:
case SIOCGCONNIDS64:
case SIOCGCONNINFO32:
case SIOCGCONNINFO64:
case SIOCSCONNORDER:
case SIOCGCONNORDER:
error = (*so->so_proto->pr_usrreqs->pru_control)(so,
cmd, data, NULL, p);
goto out;
}
if (IOCGROUP(cmd) == 'i') {
error = ifioctllocked(so, cmd, data, p);
} else {
if (IOCGROUP(cmd) == 'r') {
error = rtioctl(cmd, data, p);
} else {
error = (*so->so_proto->pr_usrreqs->pru_control)(so,
cmd, data, NULL, p);
}
}
out:
socket_unlock(so, 1);
if (error == EJUSTRETURN) {
error = 0;
}
return error;
}
int
soo_ioctl(struct fileproc *fp, u_long cmd, caddr_t data, vfs_context_t ctx)
{
struct socket *so;
proc_t procp = vfs_context_proc(ctx);
if ((so = (struct socket *)fp->fp_glob->fg_data) == NULL) {
return EBADF;
}
return soioctl(so, cmd, data, procp);
}
int
soo_select(struct fileproc *fp, int which, void *wql, vfs_context_t ctx)
{
struct socket *so = (struct socket *)fp->fp_glob->fg_data;
int retnum = 0;
proc_t procp;
if (so == NULL || so == (struct socket *)-1) {
return 0;
}
procp = vfs_context_proc(ctx);
socket_lock(so, 1);
switch (which) {
case FREAD:
so->so_rcv.sb_flags |= SB_SEL;
if (soreadable(so)) {
retnum = 1;
so->so_rcv.sb_flags &= ~SB_SEL;
goto done;
}
selrecord(procp, &so->so_rcv.sb_sel, wql);
break;
case FWRITE:
so->so_snd.sb_flags |= SB_SEL;
if (sowriteable(so)) {
retnum = 1;
so->so_snd.sb_flags &= ~SB_SEL;
goto done;
}
selrecord(procp, &so->so_snd.sb_sel, wql);
break;
case 0:
so->so_rcv.sb_flags |= SB_SEL;
if (so->so_oobmark || (so->so_state & SS_RCVATMARK)) {
retnum = 1;
so->so_rcv.sb_flags &= ~SB_SEL;
goto done;
}
selrecord(procp, &so->so_rcv.sb_sel, wql);
break;
}
done:
socket_unlock(so, 1);
return retnum;
}
int
soo_stat(struct socket *so, void *ub, int isstat64)
{
int ret;
struct stat *sb = (struct stat *)0;
struct stat64 *sb64 = (struct stat64 *)0;
#if CONFIG_MACF_SOCKET_SUBSET
ret = mac_socket_check_stat(kauth_cred_get(), so);
if (ret) {
return ret;
}
#endif
if (isstat64 != 0) {
sb64 = (struct stat64 *)ub;
bzero((caddr_t)sb64, sizeof(*sb64));
} else {
sb = (struct stat *)ub;
bzero((caddr_t)sb, sizeof(*sb));
}
socket_lock(so, 1);
if (isstat64 != 0) {
sb64->st_mode = S_IFSOCK;
if ((so->so_state & SS_CANTRCVMORE) == 0 ||
so->so_rcv.sb_cc != 0) {
sb64->st_mode |= S_IRUSR | S_IRGRP | S_IROTH;
}
if ((so->so_state & SS_CANTSENDMORE) == 0) {
sb64->st_mode |= S_IWUSR | S_IWGRP | S_IWOTH;
}
sb64->st_size = so->so_rcv.sb_cc - so->so_rcv.sb_ctl;
sb64->st_uid = kauth_cred_getuid(so->so_cred);
sb64->st_gid = kauth_cred_getgid(so->so_cred);
} else {
sb->st_mode = S_IFSOCK;
if ((so->so_state & SS_CANTRCVMORE) == 0 ||
so->so_rcv.sb_cc != 0) {
sb->st_mode |= S_IRUSR | S_IRGRP | S_IROTH;
}
if ((so->so_state & SS_CANTSENDMORE) == 0) {
sb->st_mode |= S_IWUSR | S_IWGRP | S_IWOTH;
}
sb->st_size = so->so_rcv.sb_cc - so->so_rcv.sb_ctl;
sb->st_uid = kauth_cred_getuid(so->so_cred);
sb->st_gid = kauth_cred_getgid(so->so_cred);
}
ret = (*so->so_proto->pr_usrreqs->pru_sense)(so, ub, isstat64);
socket_unlock(so, 1);
return ret;
}
static int
soo_close(struct fileglob *fg, __unused vfs_context_t ctx)
{
int error = 0;
struct socket *sp;
sp = (struct socket *)fg->fg_data;
fg->fg_data = NULL;
if (sp) {
error = soclose(sp);
}
return error;
}
static int
soo_drain(struct fileproc *fp, __unused vfs_context_t ctx)
{
int error = 0;
struct socket *so = (struct socket *)fp->fp_glob->fg_data;
if (so) {
socket_lock(so, 1);
so->so_state |= SS_DRAINING;
wakeup((caddr_t)&so->so_timeo);
sorwakeup(so);
sowwakeup(so);
soevent(so, SO_FILT_HINT_LOCKED);
socket_unlock(so, 1);
}
return error;
}
static __attribute__((unused)) void
soioctl_cassert(void)
{
switch ((u_long)0) {
case 0:
case SIOCSHIWAT:
case SIOCGHIWAT:
case SIOCSLOWAT:
case SIOCGLOWAT:
case SIOCATMARK:
case SIOCSPGRP:
case SIOCGPGRP:
case SIOCSETOT:
case SIOCGASSOCIDS32:
case SIOCGASSOCIDS64:
case SIOCGCONNIDS32:
case SIOCGCONNIDS64:
case SIOCGCONNINFO32:
case SIOCGCONNINFO64:
case SIOCSCONNORDER:
case SIOCGCONNORDER:
;
}
}