rfcomm_socket.c revision 1.1.2.4 1 1.1.2.4 yamt /* $NetBSD: rfcomm_socket.c,v 1.1.2.4 2007/09/03 14:42:43 yamt Exp $ */
2 1.1.2.2 yamt
3 1.1.2.2 yamt /*-
4 1.1.2.2 yamt * Copyright (c) 2006 Itronix Inc.
5 1.1.2.2 yamt * All rights reserved.
6 1.1.2.2 yamt *
7 1.1.2.2 yamt * Written by Iain Hibbert for Itronix Inc.
8 1.1.2.2 yamt *
9 1.1.2.2 yamt * Redistribution and use in source and binary forms, with or without
10 1.1.2.2 yamt * modification, are permitted provided that the following conditions
11 1.1.2.2 yamt * are met:
12 1.1.2.2 yamt * 1. Redistributions of source code must retain the above copyright
13 1.1.2.2 yamt * notice, this list of conditions and the following disclaimer.
14 1.1.2.2 yamt * 2. Redistributions in binary form must reproduce the above copyright
15 1.1.2.2 yamt * notice, this list of conditions and the following disclaimer in the
16 1.1.2.2 yamt * documentation and/or other materials provided with the distribution.
17 1.1.2.2 yamt * 3. The name of Itronix Inc. may not be used to endorse
18 1.1.2.2 yamt * or promote products derived from this software without specific
19 1.1.2.2 yamt * prior written permission.
20 1.1.2.2 yamt *
21 1.1.2.2 yamt * THIS SOFTWARE IS PROVIDED BY ITRONIX INC. ``AS IS'' AND
22 1.1.2.2 yamt * ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED
23 1.1.2.2 yamt * TO, THE IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR
24 1.1.2.2 yamt * PURPOSE ARE DISCLAIMED. IN NO EVENT SHALL ITRONIX INC. BE LIABLE FOR ANY
25 1.1.2.2 yamt * DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES
26 1.1.2.2 yamt * (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES;
27 1.1.2.2 yamt * LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND
28 1.1.2.2 yamt * ON ANY THEORY OF LIABILITY, WHETHER IN
29 1.1.2.2 yamt * CONTRACT, STRICT LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE)
30 1.1.2.2 yamt * ARISING IN ANY WAY OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE
31 1.1.2.2 yamt * POSSIBILITY OF SUCH DAMAGE.
32 1.1.2.2 yamt */
33 1.1.2.2 yamt
34 1.1.2.2 yamt #include <sys/cdefs.h>
35 1.1.2.4 yamt __KERNEL_RCSID(0, "$NetBSD: rfcomm_socket.c,v 1.1.2.4 2007/09/03 14:42:43 yamt Exp $");
36 1.1.2.4 yamt
37 1.1.2.4 yamt /* load symbolic names */
38 1.1.2.4 yamt #ifdef BLUETOOTH_DEBUG
39 1.1.2.4 yamt #define PRUREQUESTS
40 1.1.2.4 yamt #define PRCOREQUESTS
41 1.1.2.4 yamt #endif
42 1.1.2.2 yamt
43 1.1.2.2 yamt #include <sys/param.h>
44 1.1.2.2 yamt #include <sys/domain.h>
45 1.1.2.2 yamt #include <sys/kernel.h>
46 1.1.2.2 yamt #include <sys/mbuf.h>
47 1.1.2.2 yamt #include <sys/proc.h>
48 1.1.2.2 yamt #include <sys/protosw.h>
49 1.1.2.2 yamt #include <sys/socket.h>
50 1.1.2.2 yamt #include <sys/socketvar.h>
51 1.1.2.2 yamt #include <sys/systm.h>
52 1.1.2.2 yamt
53 1.1.2.2 yamt #include <netbt/bluetooth.h>
54 1.1.2.2 yamt #include <netbt/rfcomm.h>
55 1.1.2.2 yamt
56 1.1.2.2 yamt /****************************************************************************
57 1.1.2.2 yamt *
58 1.1.2.2 yamt * RFCOMM SOCK_STREAM Sockets - serial line emulation
59 1.1.2.2 yamt *
60 1.1.2.2 yamt */
61 1.1.2.2 yamt
62 1.1.2.2 yamt static void rfcomm_connecting(void *);
63 1.1.2.2 yamt static void rfcomm_connected(void *);
64 1.1.2.2 yamt static void rfcomm_disconnected(void *, int);
65 1.1.2.2 yamt static void *rfcomm_newconn(void *, struct sockaddr_bt *, struct sockaddr_bt *);
66 1.1.2.2 yamt static void rfcomm_complete(void *, int);
67 1.1.2.4 yamt static void rfcomm_linkmode(void *, int);
68 1.1.2.2 yamt static void rfcomm_input(void *, struct mbuf *);
69 1.1.2.2 yamt
70 1.1.2.2 yamt static const struct btproto rfcomm_proto = {
71 1.1.2.2 yamt rfcomm_connecting,
72 1.1.2.2 yamt rfcomm_connected,
73 1.1.2.2 yamt rfcomm_disconnected,
74 1.1.2.2 yamt rfcomm_newconn,
75 1.1.2.2 yamt rfcomm_complete,
76 1.1.2.4 yamt rfcomm_linkmode,
77 1.1.2.2 yamt rfcomm_input,
78 1.1.2.2 yamt };
79 1.1.2.2 yamt
80 1.1.2.2 yamt /* sysctl variables */
81 1.1.2.2 yamt int rfcomm_sendspace = 4096;
82 1.1.2.2 yamt int rfcomm_recvspace = 4096;
83 1.1.2.2 yamt
84 1.1.2.2 yamt /*
85 1.1.2.2 yamt * User Request.
86 1.1.2.2 yamt * up is socket
87 1.1.2.2 yamt * m is either
88 1.1.2.2 yamt * optional mbuf chain containing message
89 1.1.2.2 yamt * ioctl command (PRU_CONTROL)
90 1.1.2.2 yamt * nam is either
91 1.1.2.2 yamt * optional mbuf chain containing an address
92 1.1.2.2 yamt * ioctl data (PRU_CONTROL)
93 1.1.2.2 yamt * optionally protocol number (PRU_ATTACH)
94 1.1.2.2 yamt * message flags (PRU_RCVD)
95 1.1.2.2 yamt * ctl is either
96 1.1.2.2 yamt * optional mbuf chain containing socket options
97 1.1.2.2 yamt * optional interface pointer (PRU_CONTROL, PRU_PURGEIF)
98 1.1.2.2 yamt * l is pointer to process requesting action (if any)
99 1.1.2.2 yamt *
100 1.1.2.2 yamt * we are responsible for disposing of m and ctl if
101 1.1.2.2 yamt * they are mbuf chains
102 1.1.2.2 yamt */
103 1.1.2.2 yamt int
104 1.1.2.2 yamt rfcomm_usrreq(struct socket *up, int req, struct mbuf *m,
105 1.1.2.2 yamt struct mbuf *nam, struct mbuf *ctl, struct lwp *l)
106 1.1.2.2 yamt {
107 1.1.2.2 yamt struct rfcomm_dlc *pcb = up->so_pcb;
108 1.1.2.2 yamt struct sockaddr_bt *sa;
109 1.1.2.2 yamt struct mbuf *m0;
110 1.1.2.2 yamt int err = 0;
111 1.1.2.2 yamt
112 1.1.2.2 yamt DPRINTFN(2, "%s\n", prurequests[req]);
113 1.1.2.2 yamt
114 1.1.2.2 yamt switch (req) {
115 1.1.2.2 yamt case PRU_CONTROL:
116 1.1.2.2 yamt return EPASSTHROUGH;
117 1.1.2.2 yamt
118 1.1.2.2 yamt case PRU_PURGEIF:
119 1.1.2.2 yamt return EOPNOTSUPP;
120 1.1.2.2 yamt
121 1.1.2.2 yamt case PRU_ATTACH:
122 1.1.2.2 yamt if (pcb != NULL)
123 1.1.2.2 yamt return EINVAL;
124 1.1.2.2 yamt
125 1.1.2.2 yamt /*
126 1.1.2.2 yamt * Since we have nothing to add, we attach the DLC
127 1.1.2.2 yamt * structure directly to our PCB pointer.
128 1.1.2.2 yamt */
129 1.1.2.2 yamt err = rfcomm_attach((struct rfcomm_dlc **)&up->so_pcb,
130 1.1.2.2 yamt &rfcomm_proto, up);
131 1.1.2.2 yamt if (err)
132 1.1.2.2 yamt return err;
133 1.1.2.2 yamt
134 1.1.2.2 yamt err = soreserve(up, rfcomm_sendspace, rfcomm_recvspace);
135 1.1.2.2 yamt if (err)
136 1.1.2.2 yamt return err;
137 1.1.2.2 yamt
138 1.1.2.2 yamt err = rfcomm_rcvd(up->so_pcb, sbspace(&up->so_rcv));
139 1.1.2.2 yamt if (err)
140 1.1.2.2 yamt return err;
141 1.1.2.2 yamt
142 1.1.2.2 yamt return 0;
143 1.1.2.2 yamt }
144 1.1.2.2 yamt
145 1.1.2.2 yamt if (pcb == NULL) {
146 1.1.2.2 yamt err = EINVAL;
147 1.1.2.2 yamt goto release;
148 1.1.2.2 yamt }
149 1.1.2.2 yamt
150 1.1.2.2 yamt switch(req) {
151 1.1.2.2 yamt case PRU_DISCONNECT:
152 1.1.2.2 yamt soisdisconnecting(up);
153 1.1.2.2 yamt return rfcomm_disconnect(pcb, up->so_linger);
154 1.1.2.2 yamt
155 1.1.2.2 yamt case PRU_ABORT:
156 1.1.2.2 yamt rfcomm_disconnect(pcb, 0);
157 1.1.2.2 yamt soisdisconnected(up);
158 1.1.2.2 yamt /* fall through to */
159 1.1.2.2 yamt case PRU_DETACH:
160 1.1.2.2 yamt return rfcomm_detach((struct rfcomm_dlc **)&up->so_pcb);
161 1.1.2.2 yamt
162 1.1.2.2 yamt case PRU_BIND:
163 1.1.2.4 yamt KASSERT(nam != NULL);
164 1.1.2.2 yamt sa = mtod(nam, struct sockaddr_bt *);
165 1.1.2.2 yamt
166 1.1.2.2 yamt if (sa->bt_len != sizeof(struct sockaddr_bt))
167 1.1.2.2 yamt return EINVAL;
168 1.1.2.2 yamt
169 1.1.2.2 yamt if (sa->bt_family != AF_BLUETOOTH)
170 1.1.2.2 yamt return EAFNOSUPPORT;
171 1.1.2.2 yamt
172 1.1.2.2 yamt return rfcomm_bind(pcb, sa);
173 1.1.2.2 yamt
174 1.1.2.2 yamt case PRU_CONNECT:
175 1.1.2.4 yamt KASSERT(nam != NULL);
176 1.1.2.2 yamt sa = mtod(nam, struct sockaddr_bt *);
177 1.1.2.2 yamt
178 1.1.2.2 yamt if (sa->bt_len != sizeof(struct sockaddr_bt))
179 1.1.2.2 yamt return EINVAL;
180 1.1.2.2 yamt
181 1.1.2.2 yamt if (sa->bt_family != AF_BLUETOOTH)
182 1.1.2.2 yamt return EAFNOSUPPORT;
183 1.1.2.2 yamt
184 1.1.2.2 yamt soisconnecting(up);
185 1.1.2.2 yamt return rfcomm_connect(pcb, sa);
186 1.1.2.2 yamt
187 1.1.2.2 yamt case PRU_PEERADDR:
188 1.1.2.4 yamt KASSERT(nam != NULL);
189 1.1.2.2 yamt sa = mtod(nam, struct sockaddr_bt *);
190 1.1.2.2 yamt nam->m_len = sizeof(struct sockaddr_bt);
191 1.1.2.2 yamt return rfcomm_peeraddr(pcb, sa);
192 1.1.2.2 yamt
193 1.1.2.2 yamt case PRU_SOCKADDR:
194 1.1.2.4 yamt KASSERT(nam != NULL);
195 1.1.2.2 yamt sa = mtod(nam, struct sockaddr_bt *);
196 1.1.2.2 yamt nam->m_len = sizeof(struct sockaddr_bt);
197 1.1.2.2 yamt return rfcomm_sockaddr(pcb, sa);
198 1.1.2.2 yamt
199 1.1.2.2 yamt case PRU_SHUTDOWN:
200 1.1.2.2 yamt socantsendmore(up);
201 1.1.2.2 yamt break;
202 1.1.2.2 yamt
203 1.1.2.2 yamt case PRU_SEND:
204 1.1.2.4 yamt KASSERT(m != NULL);
205 1.1.2.2 yamt
206 1.1.2.2 yamt if (ctl) /* no use for that */
207 1.1.2.2 yamt m_freem(ctl);
208 1.1.2.2 yamt
209 1.1.2.2 yamt m0 = m_copypacket(m, M_DONTWAIT);
210 1.1.2.2 yamt if (m0 == NULL)
211 1.1.2.2 yamt return ENOMEM;
212 1.1.2.2 yamt
213 1.1.2.2 yamt sbappendstream(&up->so_snd, m);
214 1.1.2.2 yamt
215 1.1.2.2 yamt return rfcomm_send(pcb, m0);
216 1.1.2.2 yamt
217 1.1.2.2 yamt case PRU_SENSE:
218 1.1.2.2 yamt return 0; /* (no release) */
219 1.1.2.2 yamt
220 1.1.2.2 yamt case PRU_RCVD:
221 1.1.2.2 yamt return rfcomm_rcvd(pcb, sbspace(&up->so_rcv));
222 1.1.2.2 yamt
223 1.1.2.2 yamt case PRU_RCVOOB:
224 1.1.2.2 yamt return EOPNOTSUPP; /* (no release) */
225 1.1.2.2 yamt
226 1.1.2.2 yamt case PRU_LISTEN:
227 1.1.2.2 yamt return rfcomm_listen(pcb);
228 1.1.2.2 yamt
229 1.1.2.2 yamt case PRU_ACCEPT:
230 1.1.2.4 yamt KASSERT(nam != NULL);
231 1.1.2.2 yamt sa = mtod(nam, struct sockaddr_bt *);
232 1.1.2.2 yamt nam->m_len = sizeof(struct sockaddr_bt);
233 1.1.2.2 yamt return rfcomm_peeraddr(pcb, sa);
234 1.1.2.2 yamt
235 1.1.2.2 yamt case PRU_CONNECT2:
236 1.1.2.2 yamt case PRU_SENDOOB:
237 1.1.2.2 yamt case PRU_FASTTIMO:
238 1.1.2.2 yamt case PRU_SLOWTIMO:
239 1.1.2.2 yamt case PRU_PROTORCV:
240 1.1.2.2 yamt case PRU_PROTOSEND:
241 1.1.2.2 yamt err = EOPNOTSUPP;
242 1.1.2.2 yamt break;
243 1.1.2.2 yamt
244 1.1.2.2 yamt default:
245 1.1.2.2 yamt UNKNOWN(req);
246 1.1.2.2 yamt err = EOPNOTSUPP;
247 1.1.2.2 yamt break;
248 1.1.2.2 yamt }
249 1.1.2.2 yamt
250 1.1.2.2 yamt release:
251 1.1.2.2 yamt if (m) m_freem(m);
252 1.1.2.2 yamt if (ctl) m_freem(ctl);
253 1.1.2.2 yamt return err;
254 1.1.2.2 yamt }
255 1.1.2.2 yamt
256 1.1.2.2 yamt /*
257 1.1.2.2 yamt * rfcomm_ctloutput(request, socket, level, optname, opt)
258 1.1.2.2 yamt *
259 1.1.2.2 yamt */
260 1.1.2.2 yamt int
261 1.1.2.2 yamt rfcomm_ctloutput(int req, struct socket *so, int level,
262 1.1.2.2 yamt int optname, struct mbuf **opt)
263 1.1.2.2 yamt {
264 1.1.2.2 yamt struct rfcomm_dlc *pcb = so->so_pcb;
265 1.1.2.2 yamt struct mbuf *m;
266 1.1.2.2 yamt int err = 0;
267 1.1.2.2 yamt
268 1.1.2.2 yamt DPRINTFN(2, "%s\n", prcorequests[req]);
269 1.1.2.2 yamt
270 1.1.2.4 yamt if (pcb == NULL)
271 1.1.2.4 yamt return EINVAL;
272 1.1.2.4 yamt
273 1.1.2.2 yamt if (level != BTPROTO_RFCOMM)
274 1.1.2.4 yamt return ENOPROTOOPT;
275 1.1.2.2 yamt
276 1.1.2.2 yamt switch(req) {
277 1.1.2.2 yamt case PRCO_GETOPT:
278 1.1.2.2 yamt m = m_get(M_WAIT, MT_SOOPTS);
279 1.1.2.2 yamt m->m_len = rfcomm_getopt(pcb, optname, mtod(m, void *));
280 1.1.2.2 yamt if (m->m_len == 0) {
281 1.1.2.2 yamt m_freem(m);
282 1.1.2.2 yamt m = NULL;
283 1.1.2.4 yamt err = ENOPROTOOPT;
284 1.1.2.2 yamt }
285 1.1.2.2 yamt *opt = m;
286 1.1.2.2 yamt break;
287 1.1.2.2 yamt
288 1.1.2.2 yamt case PRCO_SETOPT:
289 1.1.2.2 yamt m = *opt;
290 1.1.2.2 yamt KASSERT(m != NULL);
291 1.1.2.2 yamt err = rfcomm_setopt(pcb, optname, mtod(m, void *));
292 1.1.2.2 yamt m_freem(m);
293 1.1.2.2 yamt break;
294 1.1.2.2 yamt
295 1.1.2.2 yamt default:
296 1.1.2.4 yamt err = ENOPROTOOPT;
297 1.1.2.2 yamt break;
298 1.1.2.2 yamt }
299 1.1.2.2 yamt
300 1.1.2.2 yamt return err;
301 1.1.2.2 yamt }
302 1.1.2.2 yamt
303 1.1.2.2 yamt /**********************************************************************
304 1.1.2.2 yamt *
305 1.1.2.2 yamt * RFCOMM callbacks
306 1.1.2.2 yamt */
307 1.1.2.2 yamt
308 1.1.2.2 yamt static void
309 1.1.2.2 yamt rfcomm_connecting(void *arg)
310 1.1.2.2 yamt {
311 1.1.2.2 yamt /* struct socket *so = arg; */
312 1.1.2.2 yamt
313 1.1.2.4 yamt KASSERT(arg != NULL);
314 1.1.2.2 yamt DPRINTF("Connecting\n");
315 1.1.2.2 yamt }
316 1.1.2.2 yamt
317 1.1.2.2 yamt static void
318 1.1.2.2 yamt rfcomm_connected(void *arg)
319 1.1.2.2 yamt {
320 1.1.2.2 yamt struct socket *so = arg;
321 1.1.2.2 yamt
322 1.1.2.4 yamt KASSERT(so != NULL);
323 1.1.2.2 yamt DPRINTF("Connected\n");
324 1.1.2.2 yamt soisconnected(so);
325 1.1.2.2 yamt }
326 1.1.2.2 yamt
327 1.1.2.2 yamt static void
328 1.1.2.2 yamt rfcomm_disconnected(void *arg, int err)
329 1.1.2.2 yamt {
330 1.1.2.2 yamt struct socket *so = arg;
331 1.1.2.2 yamt
332 1.1.2.4 yamt KASSERT(so != NULL);
333 1.1.2.2 yamt DPRINTF("Disconnected\n");
334 1.1.2.2 yamt
335 1.1.2.2 yamt so->so_error = err;
336 1.1.2.2 yamt soisdisconnected(so);
337 1.1.2.2 yamt }
338 1.1.2.2 yamt
339 1.1.2.2 yamt static void *
340 1.1.2.3 yamt rfcomm_newconn(void *arg, struct sockaddr_bt *laddr,
341 1.1.2.3 yamt struct sockaddr_bt *raddr)
342 1.1.2.2 yamt {
343 1.1.2.2 yamt struct socket *so = arg;
344 1.1.2.2 yamt
345 1.1.2.2 yamt DPRINTF("New Connection\n");
346 1.1.2.2 yamt so = sonewconn(so, 0);
347 1.1.2.2 yamt if (so == NULL)
348 1.1.2.2 yamt return NULL;
349 1.1.2.2 yamt
350 1.1.2.2 yamt soisconnecting(so);
351 1.1.2.2 yamt
352 1.1.2.2 yamt return so->so_pcb;
353 1.1.2.2 yamt }
354 1.1.2.2 yamt
355 1.1.2.2 yamt /*
356 1.1.2.2 yamt * rfcomm_complete(rfcomm_dlc, length)
357 1.1.2.2 yamt *
358 1.1.2.2 yamt * length bytes are sent and may be removed from socket buffer
359 1.1.2.2 yamt */
360 1.1.2.2 yamt static void
361 1.1.2.2 yamt rfcomm_complete(void *arg, int length)
362 1.1.2.2 yamt {
363 1.1.2.2 yamt struct socket *so = arg;
364 1.1.2.2 yamt
365 1.1.2.2 yamt sbdrop(&so->so_snd, length);
366 1.1.2.2 yamt sowwakeup(so);
367 1.1.2.2 yamt }
368 1.1.2.2 yamt
369 1.1.2.2 yamt /*
370 1.1.2.4 yamt * rfcomm_linkmode(rfcomm_dlc, new)
371 1.1.2.4 yamt *
372 1.1.2.4 yamt * link mode change notification.
373 1.1.2.4 yamt */
374 1.1.2.4 yamt static void
375 1.1.2.4 yamt rfcomm_linkmode(void *arg, int new)
376 1.1.2.4 yamt {
377 1.1.2.4 yamt struct socket *so = arg;
378 1.1.2.4 yamt int mode;
379 1.1.2.4 yamt
380 1.1.2.4 yamt DPRINTF("auth %s, encrypt %s, secure %s\n",
381 1.1.2.4 yamt (new & RFCOMM_LM_AUTH ? "on" : "off"),
382 1.1.2.4 yamt (new & RFCOMM_LM_ENCRYPT ? "on" : "off"),
383 1.1.2.4 yamt (new & RFCOMM_LM_SECURE ? "on" : "off"));
384 1.1.2.4 yamt
385 1.1.2.4 yamt (void)rfcomm_getopt(so->so_pcb, SO_RFCOMM_LM, &mode);
386 1.1.2.4 yamt if (((mode & RFCOMM_LM_AUTH) && !(new & RFCOMM_LM_AUTH))
387 1.1.2.4 yamt || ((mode & RFCOMM_LM_ENCRYPT) && !(new & RFCOMM_LM_ENCRYPT))
388 1.1.2.4 yamt || ((mode & RFCOMM_LM_SECURE) && !(new & RFCOMM_LM_SECURE)))
389 1.1.2.4 yamt rfcomm_disconnect(so->so_pcb, 0);
390 1.1.2.4 yamt }
391 1.1.2.4 yamt
392 1.1.2.4 yamt /*
393 1.1.2.2 yamt * rfcomm_input(rfcomm_dlc, mbuf)
394 1.1.2.2 yamt */
395 1.1.2.2 yamt static void
396 1.1.2.2 yamt rfcomm_input(void *arg, struct mbuf *m)
397 1.1.2.2 yamt {
398 1.1.2.2 yamt struct socket *so = arg;
399 1.1.2.2 yamt
400 1.1.2.4 yamt KASSERT(so != NULL);
401 1.1.2.2 yamt
402 1.1.2.2 yamt if (m->m_pkthdr.len > sbspace(&so->so_rcv)) {
403 1.1.2.2 yamt printf("%s: %d bytes dropped (socket buffer full)\n",
404 1.1.2.2 yamt __func__, m->m_pkthdr.len);
405 1.1.2.2 yamt m_freem(m);
406 1.1.2.2 yamt return;
407 1.1.2.2 yamt }
408 1.1.2.2 yamt
409 1.1.2.2 yamt DPRINTFN(10, "received %d bytes\n", m->m_pkthdr.len);
410 1.1.2.2 yamt
411 1.1.2.2 yamt sbappendstream(&so->so_rcv, m);
412 1.1.2.2 yamt sorwakeup(so);
413 1.1.2.2 yamt }
414