Please note that diffs are not public domain; they are subject to the copyright notices on the relevant files. =================================================================== RCS file: /ftp/cvs/cvsroot/src/sys/kern/uipc_socket.c,v retrieving revision 1.186 retrieving revision 1.186.2.1 diff -u -p -r1.186 -r1.186.2.1 --- src/sys/kern/uipc_socket.c 2009/01/23 15:40:19 1.186 +++ src/sys/kern/uipc_socket.c 2009/05/13 17:21:58 1.186.2.1 @@ -1,11 +1,11 @@ -/* $NetBSD: uipc_socket.c,v 1.186 2009/01/23 15:40:19 pooka Exp $ */ +/* $NetBSD: uipc_socket.c,v 1.186.2.1 2009/05/13 17:21:58 jym Exp $ */ /*- - * Copyright (c) 2002, 2007, 2008 The NetBSD Foundation, Inc. + * Copyright (c) 2002, 2007, 2008, 2009 The NetBSD Foundation, Inc. * All rights reserved. * * This code is derived from software contributed to The NetBSD Foundation - * by Jason R. Thorpe of Wasabi Systems, Inc. + * by Jason R. Thorpe of Wasabi Systems, Inc, and by Andrew Doran. * * Redistribution and use in source and binary forms, with or without * modification, are permitted provided that the following conditions @@ -63,7 +63,7 @@ */ #include -__KERNEL_RCSID(0, "$NetBSD: uipc_socket.c,v 1.186 2009/01/23 15:40:19 pooka Exp $"); +__KERNEL_RCSID(0, "$NetBSD: uipc_socket.c,v 1.186.2.1 2009/05/13 17:21:58 jym Exp $"); #include "opt_compat_netbsd.h" #include "opt_sock_counters.h" @@ -1547,6 +1547,20 @@ soshutdown(struct socket *so, int how) return error; } +int +sodrain(struct socket *so) +{ + int error; + + solock(so); + so->so_state |= SS_ISDRAINING; + cv_broadcast(&so->so_cv); + error = soshutdown(so, SHUT_RDWR); + sounlock(so); + + return error; +} + void sorflush(struct socket *so) { @@ -2078,7 +2092,7 @@ sohasoutofband(struct socket *so) { fownsignal(so->so_pgid, SIGURG, POLL_PRI, POLLPRI|POLLRDBAND, so); - selnotify(&so->so_rcv.sb_sel, POLLPRI | POLLRDBAND, 0); + selnotify(&so->so_rcv.sb_sel, POLLPRI | POLLRDBAND, NOTE_SUBMIT); } static void @@ -2310,7 +2324,7 @@ sysctl_kern_somaxkva(SYSCTLFN_ARGS) } static void -sysctl_kern_somaxkva_setup() +sysctl_kern_somaxkva_setup(void) { KASSERT(socket_sysctllog == NULL);