sockin.c revision 1.1.2.3
1 1.1.2.2 mjf /* $NetBSD: sockin.c,v 1.1.2.3 2009/01/17 13:29:39 mjf Exp $ */ 2 1.1.2.2 mjf 3 1.1.2.2 mjf /* 4 1.1.2.2 mjf * Copyright (c) 2008 Antti Kantee. All Rights Reserved. 5 1.1.2.2 mjf * 6 1.1.2.2 mjf * Redistribution and use in source and binary forms, with or without 7 1.1.2.2 mjf * modification, are permitted provided that the following conditions 8 1.1.2.2 mjf * are met: 9 1.1.2.2 mjf * 1. Redistributions of source code must retain the above copyright 10 1.1.2.2 mjf * notice, this list of conditions and the following disclaimer. 11 1.1.2.2 mjf * 2. Redistributions in binary form must reproduce the above copyright 12 1.1.2.2 mjf * notice, this list of conditions and the following disclaimer in the 13 1.1.2.2 mjf * documentation and/or other materials provided with the distribution. 14 1.1.2.2 mjf * 15 1.1.2.2 mjf * THIS SOFTWARE IS PROVIDED BY THE AUTHOR ``AS IS'' AND ANY EXPRESS 16 1.1.2.2 mjf * OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE IMPLIED 17 1.1.2.2 mjf * WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE ARE 18 1.1.2.2 mjf * DISCLAIMED. IN NO EVENT SHALL THE AUTHOR OR CONTRIBUTORS BE LIABLE 19 1.1.2.2 mjf * FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL 20 1.1.2.2 mjf * DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR 21 1.1.2.2 mjf * SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION) 22 1.1.2.2 mjf * HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT 23 1.1.2.2 mjf * LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY 24 1.1.2.2 mjf * OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF 25 1.1.2.2 mjf * SUCH DAMAGE. 26 1.1.2.2 mjf */ 27 1.1.2.2 mjf 28 1.1.2.3 mjf #include <sys/cdefs.h> 29 1.1.2.3 mjf __KERNEL_RCSID(0, "$NetBSD: sockin.c,v 1.1.2.3 2009/01/17 13:29:39 mjf Exp $"); 30 1.1.2.3 mjf 31 1.1.2.2 mjf #include <sys/param.h> 32 1.1.2.2 mjf #include <sys/condvar.h> 33 1.1.2.2 mjf #include <sys/domain.h> 34 1.1.2.2 mjf #include <sys/kmem.h> 35 1.1.2.2 mjf #include <sys/kthread.h> 36 1.1.2.2 mjf #include <sys/mbuf.h> 37 1.1.2.2 mjf #include <sys/mutex.h> 38 1.1.2.2 mjf #include <sys/poll.h> 39 1.1.2.2 mjf #include <sys/protosw.h> 40 1.1.2.2 mjf #include <sys/queue.h> 41 1.1.2.2 mjf #include <sys/socket.h> 42 1.1.2.2 mjf #include <sys/socketvar.h> 43 1.1.2.2 mjf #include <sys/time.h> 44 1.1.2.2 mjf 45 1.1.2.3 mjf #include <net/radix.h> 46 1.1.2.3 mjf 47 1.1.2.2 mjf #include <netinet/in.h> 48 1.1.2.2 mjf #include <netinet/in_systm.h> 49 1.1.2.2 mjf #include <netinet/ip.h> 50 1.1.2.2 mjf 51 1.1.2.2 mjf #include <rump/rumpuser.h> 52 1.1.2.2 mjf 53 1.1.2.2 mjf /* 54 1.1.2.2 mjf * An inet communication domain which uses the socket interface. 55 1.1.2.2 mjf * Currently supports only IPv4 UDP, but could easily be extended to 56 1.1.2.2 mjf * support IPv6 and TCP by adding more stuff to the protosw. 57 1.1.2.2 mjf */ 58 1.1.2.2 mjf 59 1.1.2.2 mjf DOMAIN_DEFINE(sockindomain); 60 1.1.2.2 mjf 61 1.1.2.2 mjf static void sockin_init(void); 62 1.1.2.2 mjf static int sockin_usrreq(struct socket *, int, struct mbuf *, 63 1.1.2.2 mjf struct mbuf *, struct mbuf *, struct lwp *); 64 1.1.2.3 mjf static int sockin_ctloutput(int op, struct socket *, struct sockopt *); 65 1.1.2.2 mjf 66 1.1.2.2 mjf const struct protosw sockinsw[] = { 67 1.1.2.3 mjf { 68 1.1.2.3 mjf .pr_type = SOCK_DGRAM, 69 1.1.2.2 mjf .pr_domain = &sockindomain, 70 1.1.2.2 mjf .pr_protocol = IPPROTO_UDP, 71 1.1.2.2 mjf .pr_flags = PR_ATOMIC|PR_ADDR, 72 1.1.2.2 mjf .pr_usrreq = sockin_usrreq, 73 1.1.2.3 mjf .pr_ctloutput = sockin_ctloutput, 74 1.1.2.3 mjf }, 75 1.1.2.3 mjf { 76 1.1.2.3 mjf .pr_type = SOCK_STREAM, 77 1.1.2.3 mjf .pr_domain = &sockindomain, 78 1.1.2.3 mjf .pr_protocol = IPPROTO_TCP, 79 1.1.2.3 mjf .pr_flags = PR_CONNREQUIRED|PR_WANTRCVD|PR_LISTEN|PR_ABRTACPTDIS, 80 1.1.2.3 mjf .pr_usrreq = sockin_usrreq, 81 1.1.2.3 mjf .pr_ctloutput = sockin_ctloutput, 82 1.1.2.2 mjf }}; 83 1.1.2.2 mjf 84 1.1.2.2 mjf struct domain sockindomain = { 85 1.1.2.2 mjf .dom_family = PF_INET, 86 1.1.2.2 mjf .dom_name = "socket_inet", 87 1.1.2.3 mjf .dom_init = sockin_init, 88 1.1.2.2 mjf .dom_externalize = NULL, 89 1.1.2.2 mjf .dom_dispose = NULL, 90 1.1.2.2 mjf .dom_protosw = sockinsw, 91 1.1.2.3 mjf .dom_protoswNPROTOSW = &sockinsw[__arraycount(sockinsw)], 92 1.1.2.3 mjf .dom_rtattach = rn_inithead, 93 1.1.2.3 mjf .dom_rtoffset = 32, 94 1.1.2.3 mjf .dom_maxrtkey = sizeof(struct sockaddr_in), 95 1.1.2.2 mjf .dom_ifattach = NULL, 96 1.1.2.2 mjf .dom_ifdetach = NULL, 97 1.1.2.2 mjf .dom_ifqueues = { NULL }, 98 1.1.2.2 mjf .dom_link = { NULL }, 99 1.1.2.2 mjf .dom_mowner = MOWNER_INIT("",""), 100 1.1.2.2 mjf .dom_rtcache = { NULL }, 101 1.1.2.2 mjf .dom_sockaddr_cmp = NULL 102 1.1.2.2 mjf }; 103 1.1.2.2 mjf 104 1.1.2.2 mjf /* only for testing */ 105 1.1.2.2 mjf #if 0 106 1.1.2.2 mjf #define SOCKIN_NOTHREAD 107 1.1.2.2 mjf #endif 108 1.1.2.2 mjf 109 1.1.2.3 mjf #define SO2S(so) ((intptr_t)(so->so_internal)) 110 1.1.2.3 mjf #define SOCKIN_SBSIZE 65536 111 1.1.2.3 mjf 112 1.1.2.3 mjf struct sockin_unit { 113 1.1.2.3 mjf struct socket *su_so; 114 1.1.2.3 mjf 115 1.1.2.3 mjf LIST_ENTRY(sockin_unit) su_entries; 116 1.1.2.3 mjf }; 117 1.1.2.3 mjf static LIST_HEAD(, sockin_unit) su_ent = LIST_HEAD_INITIALIZER(su_ent); 118 1.1.2.3 mjf static kmutex_t su_mtx; 119 1.1.2.3 mjf static bool rebuild; 120 1.1.2.3 mjf static int nsock; 121 1.1.2.3 mjf 122 1.1.2.3 mjf static int 123 1.1.2.3 mjf registersock(struct socket *so, int news) 124 1.1.2.3 mjf { 125 1.1.2.3 mjf struct sockin_unit *su; 126 1.1.2.3 mjf 127 1.1.2.3 mjf su = kmem_alloc(sizeof(*su), KM_NOSLEEP); 128 1.1.2.3 mjf if (!su) 129 1.1.2.3 mjf return ENOMEM; 130 1.1.2.3 mjf 131 1.1.2.3 mjf so->so_internal = (void *)(intptr_t)news; 132 1.1.2.3 mjf su->su_so = so; 133 1.1.2.3 mjf 134 1.1.2.3 mjf mutex_enter(&su_mtx); 135 1.1.2.3 mjf LIST_INSERT_HEAD(&su_ent, su, su_entries); 136 1.1.2.3 mjf nsock++; 137 1.1.2.3 mjf rebuild = true; 138 1.1.2.3 mjf mutex_exit(&su_mtx); 139 1.1.2.3 mjf 140 1.1.2.3 mjf return 0; 141 1.1.2.3 mjf } 142 1.1.2.2 mjf 143 1.1.2.2 mjf static void 144 1.1.2.2 mjf sockin_process(struct socket *so) 145 1.1.2.2 mjf { 146 1.1.2.2 mjf struct sockaddr_in from; 147 1.1.2.2 mjf struct iovec io; 148 1.1.2.2 mjf struct msghdr rmsg; 149 1.1.2.2 mjf struct mbuf *m; 150 1.1.2.2 mjf ssize_t n; 151 1.1.2.2 mjf size_t plen; 152 1.1.2.2 mjf int error; 153 1.1.2.2 mjf 154 1.1.2.2 mjf plen = IP_MAXPACKET; 155 1.1.2.2 mjf m = m_gethdr(M_WAIT, MT_DATA); 156 1.1.2.2 mjf MEXTMALLOC(m, plen, M_WAIT); 157 1.1.2.2 mjf 158 1.1.2.2 mjf memset(&rmsg, 0, sizeof(rmsg)); 159 1.1.2.2 mjf io.iov_base = mtod(m, void *); 160 1.1.2.2 mjf io.iov_len = plen; 161 1.1.2.2 mjf rmsg.msg_iov = &io; 162 1.1.2.2 mjf rmsg.msg_iovlen = 1; 163 1.1.2.2 mjf rmsg.msg_name = (struct sockaddr *)&from; 164 1.1.2.2 mjf rmsg.msg_namelen = sizeof(from); 165 1.1.2.2 mjf 166 1.1.2.2 mjf n = rumpuser_net_recvmsg(SO2S(so), &rmsg, 0, &error); 167 1.1.2.2 mjf if (n <= 0) { 168 1.1.2.2 mjf m_freem(m); 169 1.1.2.2 mjf return; 170 1.1.2.2 mjf } 171 1.1.2.2 mjf m->m_len = m->m_pkthdr.len = n; 172 1.1.2.2 mjf 173 1.1.2.3 mjf if (so->so_proto->pr_type == SOCK_DGRAM) { 174 1.1.2.3 mjf if (!sbappendaddr(&so->so_rcv, rmsg.msg_name, m, NULL)) { 175 1.1.2.3 mjf m_freem(m); 176 1.1.2.3 mjf } 177 1.1.2.3 mjf } else { 178 1.1.2.3 mjf sbappendstream(&so->so_rcv, m); 179 1.1.2.2 mjf } 180 1.1.2.3 mjf 181 1.1.2.2 mjf sorwakeup(so); 182 1.1.2.2 mjf } 183 1.1.2.2 mjf 184 1.1.2.3 mjf #ifndef SOCKIN_NOTHREAD 185 1.1.2.3 mjf static void 186 1.1.2.3 mjf sockin_accept(struct socket *so) 187 1.1.2.3 mjf { 188 1.1.2.3 mjf struct socket *nso; 189 1.1.2.3 mjf struct sockaddr_in sin; 190 1.1.2.3 mjf int news, error, slen; 191 1.1.2.3 mjf 192 1.1.2.3 mjf slen = sizeof(sin); 193 1.1.2.3 mjf news = rumpuser_net_accept(SO2S(so), (struct sockaddr *)&sin, 194 1.1.2.3 mjf &slen, &error); 195 1.1.2.3 mjf if (news == -1) 196 1.1.2.3 mjf return; 197 1.1.2.2 mjf 198 1.1.2.3 mjf if ((nso = sonewconn(so, SS_ISCONNECTED)) == NULL) 199 1.1.2.3 mjf goto errout; 200 1.1.2.3 mjf if (registersock(nso, news) != 0) 201 1.1.2.3 mjf goto errout; 202 1.1.2.3 mjf return; 203 1.1.2.3 mjf 204 1.1.2.3 mjf errout: 205 1.1.2.3 mjf rumpuser_close(news, &error); 206 1.1.2.3 mjf if (nso) 207 1.1.2.3 mjf soclose(nso); 208 1.1.2.3 mjf } 209 1.1.2.2 mjf 210 1.1.2.2 mjf #define POLLTIMEOUT 100 /* check for new entries every 100ms */ 211 1.1.2.2 mjf 212 1.1.2.2 mjf /* XXX: doesn't handle socket (kernel) locking properly? */ 213 1.1.2.2 mjf static void 214 1.1.2.2 mjf sockinworker(void *arg) 215 1.1.2.2 mjf { 216 1.1.2.2 mjf struct pollfd *pfds = NULL, *npfds; 217 1.1.2.2 mjf struct sockin_unit *su_iter; 218 1.1.2.3 mjf struct socket *so; 219 1.1.2.2 mjf int cursock = 0, i, rv, error; 220 1.1.2.2 mjf 221 1.1.2.2 mjf /* 222 1.1.2.2 mjf * Loop reading requests. Check for new sockets periodically 223 1.1.2.2 mjf * (could be smarter, but I'm lazy). 224 1.1.2.2 mjf */ 225 1.1.2.2 mjf for (;;) { 226 1.1.2.2 mjf if (rebuild) { 227 1.1.2.2 mjf npfds = NULL; 228 1.1.2.2 mjf mutex_enter(&su_mtx); 229 1.1.2.2 mjf if (nsock) 230 1.1.2.2 mjf npfds = kmem_alloc(nsock * sizeof(*npfds), 231 1.1.2.2 mjf KM_NOSLEEP); 232 1.1.2.2 mjf if (npfds || nsock == 0) { 233 1.1.2.2 mjf if (pfds) 234 1.1.2.2 mjf kmem_free(pfds, cursock*sizeof(*pfds)); 235 1.1.2.2 mjf pfds = npfds; 236 1.1.2.2 mjf cursock = nsock; 237 1.1.2.2 mjf rebuild = false; 238 1.1.2.2 mjf 239 1.1.2.2 mjf i = 0; 240 1.1.2.2 mjf LIST_FOREACH(su_iter, &su_ent, su_entries) { 241 1.1.2.2 mjf pfds[i].fd = SO2S(su_iter->su_so); 242 1.1.2.2 mjf pfds[i].events = POLLIN; 243 1.1.2.2 mjf pfds[i].revents = 0; 244 1.1.2.2 mjf i++; 245 1.1.2.2 mjf } 246 1.1.2.2 mjf KASSERT(i == nsock); 247 1.1.2.2 mjf } 248 1.1.2.2 mjf mutex_exit(&su_mtx); 249 1.1.2.2 mjf } 250 1.1.2.2 mjf 251 1.1.2.2 mjf /* find affected sockets & process */ 252 1.1.2.2 mjf rv = rumpuser_poll(pfds, cursock, POLLTIMEOUT, &error); 253 1.1.2.2 mjf for (i = 0; i < cursock && rv > 0; i++) { 254 1.1.2.2 mjf if (pfds[i].revents & POLLIN) { 255 1.1.2.2 mjf mutex_enter(&su_mtx); 256 1.1.2.2 mjf LIST_FOREACH(su_iter, &su_ent, su_entries) { 257 1.1.2.2 mjf if (SO2S(su_iter->su_so)==pfds[i].fd) { 258 1.1.2.3 mjf so = su_iter->su_so; 259 1.1.2.3 mjf mutex_exit(&su_mtx); 260 1.1.2.2 mjf mutex_enter(softnet_lock); 261 1.1.2.3 mjf if(so->so_options&SO_ACCEPTCONN) 262 1.1.2.3 mjf sockin_accept(so); 263 1.1.2.3 mjf else 264 1.1.2.3 mjf sockin_process(so); 265 1.1.2.2 mjf mutex_exit(softnet_lock); 266 1.1.2.3 mjf mutex_enter(&su_mtx); 267 1.1.2.2 mjf break; 268 1.1.2.2 mjf } 269 1.1.2.2 mjf } 270 1.1.2.2 mjf /* if we can't find it, just wing it */ 271 1.1.2.2 mjf KASSERT(rebuild || su_iter); 272 1.1.2.2 mjf mutex_exit(&su_mtx); 273 1.1.2.2 mjf pfds[i].revents = 0; 274 1.1.2.2 mjf rv--; 275 1.1.2.2 mjf i = -1; 276 1.1.2.2 mjf continue; 277 1.1.2.2 mjf } 278 1.1.2.2 mjf 279 1.1.2.2 mjf /* something else? ignore */ 280 1.1.2.2 mjf if (pfds[i].revents) { 281 1.1.2.2 mjf pfds[i].revents = 0; 282 1.1.2.2 mjf rv--; 283 1.1.2.2 mjf } 284 1.1.2.2 mjf } 285 1.1.2.2 mjf KASSERT(rv <= 0); 286 1.1.2.2 mjf } 287 1.1.2.2 mjf 288 1.1.2.2 mjf } 289 1.1.2.2 mjf #endif /* SOCKIN_NOTHREAD */ 290 1.1.2.2 mjf 291 1.1.2.2 mjf static void 292 1.1.2.2 mjf sockin_init() 293 1.1.2.2 mjf { 294 1.1.2.2 mjf #ifndef SOCKIN_NOTHREAD 295 1.1.2.2 mjf int rv; 296 1.1.2.2 mjf 297 1.1.2.2 mjf if ((rv = kthread_create(PRI_NONE, 0, NULL, sockinworker, 298 1.1.2.2 mjf NULL, NULL, "sockwork")) != 0) 299 1.1.2.2 mjf panic("sockin_init: could not create worker thread\n"); 300 1.1.2.2 mjf #endif 301 1.1.2.2 mjf mutex_init(&su_mtx, MUTEX_DEFAULT, IPL_NONE); 302 1.1.2.2 mjf } 303 1.1.2.2 mjf 304 1.1.2.2 mjf static int 305 1.1.2.2 mjf sockin_usrreq(struct socket *so, int req, struct mbuf *m, struct mbuf *nam, 306 1.1.2.2 mjf struct mbuf *control, struct lwp *l) 307 1.1.2.2 mjf { 308 1.1.2.3 mjf int error = 0, rv; 309 1.1.2.2 mjf 310 1.1.2.2 mjf switch (req) { 311 1.1.2.2 mjf case PRU_ATTACH: 312 1.1.2.2 mjf { 313 1.1.2.2 mjf int news; 314 1.1.2.2 mjf 315 1.1.2.2 mjf sosetlock(so); 316 1.1.2.3 mjf if (so->so_snd.sb_hiwat == 0 || so->so_rcv.sb_hiwat == 0) { 317 1.1.2.3 mjf error = soreserve(so, SOCKIN_SBSIZE, SOCKIN_SBSIZE); 318 1.1.2.3 mjf if (error) 319 1.1.2.3 mjf break; 320 1.1.2.2 mjf } 321 1.1.2.2 mjf 322 1.1.2.3 mjf news = rumpuser_net_socket(PF_INET, so->so_proto->pr_type, 323 1.1.2.3 mjf 0, &error); 324 1.1.2.3 mjf if (news == -1) 325 1.1.2.2 mjf break; 326 1.1.2.2 mjf 327 1.1.2.3 mjf if ((error = registersock(so, news)) != 0) 328 1.1.2.3 mjf rumpuser_close(news, &error); 329 1.1.2.3 mjf 330 1.1.2.2 mjf break; 331 1.1.2.2 mjf } 332 1.1.2.2 mjf 333 1.1.2.3 mjf case PRU_ACCEPT: 334 1.1.2.3 mjf /* we do all the work in the worker thread */ 335 1.1.2.3 mjf break; 336 1.1.2.3 mjf 337 1.1.2.3 mjf case PRU_BIND: 338 1.1.2.3 mjf rumpuser_net_bind(SO2S(so), mtod(nam, const struct sockaddr *), 339 1.1.2.3 mjf sizeof(struct sockaddr_in), &error); 340 1.1.2.3 mjf break; 341 1.1.2.3 mjf 342 1.1.2.2 mjf case PRU_CONNECT: 343 1.1.2.3 mjf /* don't bother to connect udp sockets, always sendmsg */ 344 1.1.2.3 mjf if (so->so_proto->pr_type == SOCK_DGRAM) 345 1.1.2.3 mjf break; 346 1.1.2.3 mjf 347 1.1.2.3 mjf rv = rumpuser_net_connect(SO2S(so), 348 1.1.2.3 mjf mtod(nam, struct sockaddr *), sizeof(struct sockaddr_in), 349 1.1.2.3 mjf &error); 350 1.1.2.3 mjf if (rv == 0) 351 1.1.2.3 mjf soisconnected(so); 352 1.1.2.3 mjf break; 353 1.1.2.3 mjf 354 1.1.2.3 mjf case PRU_LISTEN: 355 1.1.2.3 mjf rumpuser_net_listen(SO2S(so), so->so_qlimit, &error); 356 1.1.2.2 mjf break; 357 1.1.2.2 mjf 358 1.1.2.2 mjf case PRU_SEND: 359 1.1.2.2 mjf { 360 1.1.2.2 mjf struct sockaddr *saddr; 361 1.1.2.2 mjf struct msghdr mhdr; 362 1.1.2.2 mjf struct iovec iov[16]; 363 1.1.2.2 mjf struct mbuf *m2; 364 1.1.2.2 mjf size_t tot; 365 1.1.2.2 mjf int i, s; 366 1.1.2.2 mjf 367 1.1.2.2 mjf memset(&mhdr, 0, sizeof(mhdr)); 368 1.1.2.2 mjf 369 1.1.2.2 mjf tot = 0; 370 1.1.2.2 mjf for (i = 0, m2 = m; m2; m2 = m2->m_next, i++) { 371 1.1.2.2 mjf if (i > 16) 372 1.1.2.2 mjf panic("lazy bum"); 373 1.1.2.2 mjf iov[i].iov_base = m2->m_data; 374 1.1.2.2 mjf iov[i].iov_len = m2->m_len; 375 1.1.2.2 mjf tot += m2->m_len; 376 1.1.2.2 mjf 377 1.1.2.2 mjf } 378 1.1.2.2 mjf mhdr.msg_iov = iov; 379 1.1.2.2 mjf mhdr.msg_iovlen = i; 380 1.1.2.3 mjf s = SO2S(so); 381 1.1.2.3 mjf 382 1.1.2.3 mjf if (so->so_proto->pr_type == SOCK_DGRAM) { 383 1.1.2.3 mjf saddr = mtod(nam, struct sockaddr *); 384 1.1.2.3 mjf mhdr.msg_name = saddr; 385 1.1.2.3 mjf mhdr.msg_namelen = saddr->sa_len; 386 1.1.2.3 mjf } 387 1.1.2.2 mjf 388 1.1.2.2 mjf rumpuser_net_sendmsg(s, &mhdr, 0, &error); 389 1.1.2.3 mjf 390 1.1.2.2 mjf m_freem(m); 391 1.1.2.2 mjf m_freem(control); 392 1.1.2.2 mjf #ifdef SOCKIN_NOTHREAD 393 1.1.2.2 mjf /* this assumes too many things to list.. buthey, testing */ 394 1.1.2.2 mjf sockin_process(so); 395 1.1.2.2 mjf #endif 396 1.1.2.2 mjf } 397 1.1.2.2 mjf break; 398 1.1.2.2 mjf 399 1.1.2.2 mjf case PRU_SHUTDOWN: 400 1.1.2.2 mjf { 401 1.1.2.2 mjf struct sockin_unit *su_iter; 402 1.1.2.2 mjf 403 1.1.2.2 mjf mutex_enter(&su_mtx); 404 1.1.2.2 mjf LIST_FOREACH(su_iter, &su_ent, su_entries) { 405 1.1.2.2 mjf if (su_iter->su_so == so) 406 1.1.2.2 mjf break; 407 1.1.2.2 mjf } 408 1.1.2.2 mjf if (!su_iter) 409 1.1.2.2 mjf panic("no such socket"); 410 1.1.2.2 mjf 411 1.1.2.2 mjf LIST_REMOVE(su_iter, su_entries); 412 1.1.2.2 mjf nsock--; 413 1.1.2.2 mjf rebuild = true; 414 1.1.2.2 mjf mutex_exit(&su_mtx); 415 1.1.2.2 mjf 416 1.1.2.2 mjf rumpuser_close(SO2S(su_iter->su_so), &error); 417 1.1.2.2 mjf kmem_free(su_iter, sizeof(*su_iter)); 418 1.1.2.2 mjf } 419 1.1.2.2 mjf break; 420 1.1.2.2 mjf 421 1.1.2.2 mjf default: 422 1.1.2.2 mjf panic("sockin_usrreq: IMPLEMENT ME, req %d not supported", req); 423 1.1.2.2 mjf } 424 1.1.2.2 mjf 425 1.1.2.2 mjf return error; 426 1.1.2.2 mjf } 427 1.1.2.3 mjf 428 1.1.2.3 mjf static int 429 1.1.2.3 mjf sockin_ctloutput(int op, struct socket *so, struct sockopt *sopt) 430 1.1.2.3 mjf { 431 1.1.2.3 mjf 432 1.1.2.3 mjf /* XXX: we should also do something here */ 433 1.1.2.3 mjf return 0; 434 1.1.2.3 mjf } 435
Indexes created Thu Oct 02 01:09:59 GMT 2025