putter.c revision 1.22 1 1.22 christos /* $NetBSD: putter.c,v 1.22 2009/04/11 15:47:33 christos Exp $ */
2 1.1 pooka
3 1.1 pooka /*
4 1.1 pooka * Copyright (c) 2006, 2007 Antti Kantee. All Rights Reserved.
5 1.1 pooka *
6 1.1 pooka * Development of this software was supported by the
7 1.1 pooka * Ulla Tuominen Foundation and the Finnish Cultural Foundation and the
8 1.1 pooka * Research Foundation of Helsinki University of Technology
9 1.1 pooka *
10 1.1 pooka * Redistribution and use in source and binary forms, with or without
11 1.1 pooka * modification, are permitted provided that the following conditions
12 1.1 pooka * are met:
13 1.1 pooka * 1. Redistributions of source code must retain the above copyright
14 1.1 pooka * notice, this list of conditions and the following disclaimer.
15 1.1 pooka * 2. Redistributions in binary form must reproduce the above copyright
16 1.1 pooka * notice, this list of conditions and the following disclaimer in the
17 1.1 pooka * documentation and/or other materials provided with the distribution.
18 1.1 pooka *
19 1.1 pooka * THIS SOFTWARE IS PROVIDED BY THE AUTHOR ``AS IS'' AND ANY EXPRESS
20 1.1 pooka * OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE IMPLIED
21 1.1 pooka * WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE ARE
22 1.1 pooka * DISCLAIMED. IN NO EVENT SHALL THE AUTHOR OR CONTRIBUTORS BE LIABLE
23 1.1 pooka * FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL
24 1.1 pooka * DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR
25 1.1 pooka * SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION)
26 1.1 pooka * HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT
27 1.1 pooka * LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY
28 1.1 pooka * OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF
29 1.1 pooka * SUCH DAMAGE.
30 1.1 pooka */
31 1.1 pooka
32 1.1 pooka /*
33 1.1 pooka * Pass-to-Userspace TransporTER: generic kernel-user request-response
34 1.1 pooka * transport interface.
35 1.1 pooka */
36 1.1 pooka
37 1.1 pooka #include <sys/cdefs.h>
38 1.22 christos __KERNEL_RCSID(0, "$NetBSD: putter.c,v 1.22 2009/04/11 15:47:33 christos Exp $");
39 1.1 pooka
40 1.1 pooka #include <sys/param.h>
41 1.13 ad #include <sys/systm.h>
42 1.1 pooka #include <sys/conf.h>
43 1.1 pooka #include <sys/file.h>
44 1.1 pooka #include <sys/filedesc.h>
45 1.1 pooka #include <sys/kmem.h>
46 1.1 pooka #include <sys/poll.h>
47 1.22 christos #include <sys/stat.h>
48 1.1 pooka #include <sys/socketvar.h>
49 1.10 jmcneill #include <sys/module.h>
50 1.1 pooka
51 1.2 pooka #include <dev/putter/putter_sys.h>
52 1.1 pooka
53 1.1 pooka /*
54 1.22 christos * Device routines. These are for when /dev/puffs is initially
55 1.22 christos * opened before it has been cloned.
56 1.22 christos */
57 1.22 christos
58 1.22 christos dev_type_open(puttercdopen);
59 1.22 christos dev_type_close(puttercdclose);
60 1.22 christos dev_type_ioctl(puttercdioctl);
61 1.22 christos
62 1.22 christos /* dev */
63 1.22 christos const struct cdevsw putter_cdevsw = {
64 1.22 christos puttercdopen, puttercdclose, noread, nowrite,
65 1.22 christos noioctl, nostop, notty, nopoll,
66 1.22 christos nommap, nokqfilter, D_OTHER
67 1.22 christos };
68 1.22 christos
69 1.22 christos /*
70 1.5 pooka * Configuration data.
71 1.5 pooka *
72 1.5 pooka * This is static-size for now. Will be redone for devfs.
73 1.5 pooka */
74 1.5 pooka
75 1.5 pooka #define PUTTER_CONFSIZE 16
76 1.5 pooka
77 1.5 pooka static struct putter_config {
78 1.5 pooka int pc_minor;
79 1.5 pooka int (*pc_config)(int, int, int);
80 1.5 pooka } putterconf[PUTTER_CONFSIZE];
81 1.5 pooka
82 1.5 pooka static int
83 1.5 pooka putter_configure(dev_t dev, int flags, int fmt, int fd)
84 1.5 pooka {
85 1.5 pooka struct putter_config *pc;
86 1.5 pooka
87 1.5 pooka /* are we the catch-all node? */
88 1.5 pooka if (minor(dev) == PUTTER_MINOR_WILDCARD
89 1.5 pooka || minor(dev) == PUTTER_MINOR_COMPAT)
90 1.5 pooka return 0;
91 1.5 pooka
92 1.5 pooka /* nopes? try to configure us */
93 1.5 pooka for (pc = putterconf; pc->pc_config; pc++)
94 1.5 pooka if (minor(dev) == pc->pc_minor)
95 1.5 pooka return pc->pc_config(fd, flags, fmt);
96 1.5 pooka return ENXIO;
97 1.5 pooka }
98 1.5 pooka
99 1.5 pooka int
100 1.5 pooka putter_register(putter_config_fn pcfn, int minor)
101 1.5 pooka {
102 1.5 pooka int i;
103 1.5 pooka
104 1.5 pooka for (i = 0; i < PUTTER_CONFSIZE; i++)
105 1.5 pooka if (putterconf[i].pc_config == NULL)
106 1.5 pooka break;
107 1.5 pooka if (i == PUTTER_CONFSIZE)
108 1.5 pooka return EBUSY;
109 1.5 pooka
110 1.5 pooka putterconf[i].pc_minor = minor;
111 1.5 pooka putterconf[i].pc_config = pcfn;
112 1.5 pooka return 0;
113 1.5 pooka }
114 1.5 pooka
115 1.5 pooka /*
116 1.1 pooka * putter instance structures. these are always allocated and freed
117 1.1 pooka * from the context of the transport user.
118 1.1 pooka */
119 1.1 pooka struct putter_instance {
120 1.1 pooka pid_t pi_pid;
121 1.1 pooka int pi_idx;
122 1.1 pooka int pi_fd;
123 1.1 pooka struct selinfo pi_sel;
124 1.1 pooka
125 1.1 pooka void *pi_private;
126 1.1 pooka struct putter_ops *pi_pop;
127 1.1 pooka
128 1.1 pooka uint8_t *pi_curput;
129 1.1 pooka size_t pi_curres;
130 1.1 pooka void *pi_curopaq;
131 1.22 christos struct timespec pi_atime;
132 1.22 christos struct timespec pi_mtime;
133 1.22 christos struct timespec pi_btime;
134 1.1 pooka
135 1.1 pooka TAILQ_ENTRY(putter_instance) pi_entries;
136 1.1 pooka };
137 1.1 pooka #define PUTTER_EMBRYO ((void *)-1) /* before attach */
138 1.1 pooka #define PUTTER_DEAD ((void *)-2) /* after detach */
139 1.1 pooka
140 1.1 pooka static TAILQ_HEAD(, putter_instance) putter_ilist
141 1.1 pooka = TAILQ_HEAD_INITIALIZER(putter_ilist);
142 1.1 pooka
143 1.1 pooka static int get_pi_idx(struct putter_instance *);
144 1.1 pooka
145 1.1 pooka #ifdef DEBUG
146 1.1 pooka #ifndef PUTTERDEBUG
147 1.1 pooka #define PUTTERDEBUG
148 1.1 pooka #endif
149 1.1 pooka #endif
150 1.1 pooka
151 1.1 pooka #ifdef PUTTERDEBUG
152 1.7 pooka int putterdebug = 0;
153 1.1 pooka #define DPRINTF(x) if (putterdebug > 0) printf x
154 1.1 pooka #define DPRINTF_VERBOSE(x) if (putterdebug > 1) printf x
155 1.1 pooka #else
156 1.1 pooka #define DPRINTF(x)
157 1.1 pooka #define DPRINTF_VERBOSE(x)
158 1.1 pooka #endif
159 1.1 pooka
160 1.1 pooka /*
161 1.1 pooka * public init / deinit
162 1.1 pooka */
163 1.1 pooka
164 1.1 pooka /* protects both the list and the contents of the list elements */
165 1.1 pooka static kmutex_t pi_mtx;
166 1.1 pooka
167 1.1 pooka void putterattach(void);
168 1.1 pooka
169 1.1 pooka void
170 1.20 cegger putterattach(void)
171 1.1 pooka {
172 1.1 pooka
173 1.1 pooka mutex_init(&pi_mtx, MUTEX_DEFAULT, IPL_NONE);
174 1.1 pooka }
175 1.1 pooka
176 1.1 pooka #if 0
177 1.1 pooka void
178 1.20 cegger putter_destroy(void)
179 1.1 pooka {
180 1.1 pooka
181 1.1 pooka mutex_destroy(&pi_mtx);
182 1.1 pooka }
183 1.1 pooka #endif
184 1.1 pooka
185 1.1 pooka /*
186 1.1 pooka * fd routines, for cloner
187 1.1 pooka */
188 1.9 ad static int putter_fop_read(file_t *, off_t *, struct uio *,
189 1.1 pooka kauth_cred_t, int);
190 1.9 ad static int putter_fop_write(file_t *, off_t *, struct uio *,
191 1.1 pooka kauth_cred_t, int);
192 1.9 ad static int putter_fop_ioctl(file_t*, u_long, void *);
193 1.9 ad static int putter_fop_poll(file_t *, int);
194 1.22 christos static int putter_fop_stat(file_t *, struct stat *);
195 1.9 ad static int putter_fop_close(file_t *);
196 1.9 ad static int putter_fop_kqfilter(file_t *, struct knote *);
197 1.1 pooka
198 1.1 pooka
199 1.1 pooka static const struct fileops putter_fileops = {
200 1.21 ad .fo_read = putter_fop_read,
201 1.21 ad .fo_write = putter_fop_write,
202 1.21 ad .fo_ioctl = putter_fop_ioctl,
203 1.21 ad .fo_fcntl = fnullop_fcntl,
204 1.21 ad .fo_poll = putter_fop_poll,
205 1.22 christos .fo_stat = putter_fop_stat,
206 1.21 ad .fo_close = putter_fop_close,
207 1.21 ad .fo_kqfilter = putter_fop_kqfilter,
208 1.21 ad .fo_drain = fnullop_drain,
209 1.1 pooka };
210 1.1 pooka
211 1.1 pooka static int
212 1.9 ad putter_fop_read(file_t *fp, off_t *off, struct uio *uio,
213 1.1 pooka kauth_cred_t cred, int flags)
214 1.1 pooka {
215 1.1 pooka struct putter_instance *pi = fp->f_data;
216 1.1 pooka size_t origres, moved;
217 1.1 pooka int error;
218 1.1 pooka
219 1.22 christos getnanotime(&pi->pi_atime);
220 1.13 ad KERNEL_LOCK(1, NULL);
221 1.13 ad
222 1.1 pooka if (pi->pi_private == PUTTER_EMBRYO || pi->pi_private == PUTTER_DEAD) {
223 1.1 pooka printf("putter_fop_read: private %d not inited\n", pi->pi_idx);
224 1.13 ad KERNEL_UNLOCK_ONE(NULL);
225 1.1 pooka return ENOENT;
226 1.1 pooka }
227 1.1 pooka
228 1.1 pooka if (pi->pi_curput == NULL) {
229 1.1 pooka error = pi->pi_pop->pop_getout(pi->pi_private, uio->uio_resid,
230 1.1 pooka fp->f_flag & O_NONBLOCK, &pi->pi_curput,
231 1.1 pooka &pi->pi_curres, &pi->pi_curopaq);
232 1.13 ad if (error) {
233 1.13 ad KERNEL_UNLOCK_ONE(NULL);
234 1.1 pooka return error;
235 1.13 ad }
236 1.1 pooka }
237 1.1 pooka
238 1.1 pooka origres = uio->uio_resid;
239 1.1 pooka error = uiomove(pi->pi_curput, pi->pi_curres, uio);
240 1.1 pooka moved = origres - uio->uio_resid;
241 1.1 pooka DPRINTF(("putter_fop_read (%p): moved %zu bytes from %p, error %d\n",
242 1.1 pooka pi, moved, pi->pi_curput, error));
243 1.1 pooka
244 1.1 pooka KASSERT(pi->pi_curres >= moved);
245 1.1 pooka pi->pi_curres -= moved;
246 1.1 pooka pi->pi_curput += moved;
247 1.1 pooka
248 1.1 pooka if (pi->pi_curres == 0) {
249 1.1 pooka pi->pi_pop->pop_releaseout(pi->pi_private,
250 1.1 pooka pi->pi_curopaq, error);
251 1.1 pooka pi->pi_curput = NULL;
252 1.1 pooka }
253 1.1 pooka
254 1.13 ad KERNEL_UNLOCK_ONE(NULL);
255 1.1 pooka return error;
256 1.1 pooka }
257 1.1 pooka
258 1.1 pooka static int
259 1.9 ad putter_fop_write(file_t *fp, off_t *off, struct uio *uio,
260 1.1 pooka kauth_cred_t cred, int flags)
261 1.1 pooka {
262 1.1 pooka struct putter_instance *pi = fp->f_data;
263 1.2 pooka struct putter_hdr pth;
264 1.1 pooka uint8_t *buf;
265 1.1 pooka size_t frsize;
266 1.1 pooka int error;
267 1.1 pooka
268 1.22 christos getnanotime(&pi->pi_mtime);
269 1.13 ad KERNEL_LOCK(1, NULL);
270 1.13 ad
271 1.2 pooka DPRINTF(("putter_fop_write (%p): writing response, resid %zu\n",
272 1.1 pooka pi->pi_private, uio->uio_resid));
273 1.1 pooka
274 1.1 pooka if (pi->pi_private == PUTTER_EMBRYO || pi->pi_private == PUTTER_DEAD) {
275 1.1 pooka printf("putter_fop_write: putter %d not inited\n", pi->pi_idx);
276 1.13 ad KERNEL_UNLOCK_ONE(NULL);
277 1.1 pooka return ENOENT;
278 1.1 pooka }
279 1.1 pooka
280 1.2 pooka error = uiomove(&pth, sizeof(struct putter_hdr), uio);
281 1.13 ad if (error) {
282 1.13 ad KERNEL_UNLOCK_ONE(NULL);
283 1.1 pooka return error;
284 1.13 ad }
285 1.1 pooka
286 1.1 pooka /* Sorry mate, the kernel doesn't buffer. */
287 1.2 pooka frsize = pth.pth_framelen - sizeof(struct putter_hdr);
288 1.13 ad if (uio->uio_resid < frsize) {
289 1.13 ad KERNEL_UNLOCK_ONE(NULL);
290 1.1 pooka return EINVAL;
291 1.13 ad }
292 1.1 pooka
293 1.2 pooka buf = kmem_alloc(frsize + sizeof(struct putter_hdr), KM_SLEEP);
294 1.2 pooka memcpy(buf, &pth, sizeof(pth));
295 1.2 pooka error = uiomove(buf+sizeof(struct putter_hdr), frsize, uio);
296 1.1 pooka if (error == 0) {
297 1.3 pooka pi->pi_pop->pop_dispatch(pi->pi_private,
298 1.3 pooka (struct putter_hdr *)buf);
299 1.1 pooka }
300 1.2 pooka kmem_free(buf, frsize + sizeof(struct putter_hdr));
301 1.1 pooka
302 1.13 ad KERNEL_UNLOCK_ONE(NULL);
303 1.1 pooka return error;
304 1.1 pooka }
305 1.1 pooka
306 1.1 pooka /*
307 1.1 pooka * Poll query interface. The question is only if an event
308 1.2 pooka * can be read from us.
309 1.1 pooka */
310 1.1 pooka #define PUTTERPOLL_EVSET (POLLIN | POLLRDNORM | POLLRDBAND | POLLPRI)
311 1.1 pooka static int
312 1.9 ad putter_fop_poll(file_t *fp, int events)
313 1.1 pooka {
314 1.1 pooka struct putter_instance *pi = fp->f_data;
315 1.1 pooka int revents;
316 1.1 pooka
317 1.13 ad KERNEL_LOCK(1, NULL);
318 1.13 ad
319 1.1 pooka if (pi->pi_private == PUTTER_EMBRYO || pi->pi_private == PUTTER_DEAD) {
320 1.1 pooka printf("putter_fop_ioctl: putter %d not inited\n", pi->pi_idx);
321 1.13 ad KERNEL_UNLOCK_ONE(NULL);
322 1.1 pooka return ENOENT;
323 1.1 pooka }
324 1.1 pooka
325 1.1 pooka revents = events & (POLLOUT | POLLWRNORM | POLLWRBAND);
326 1.13 ad if ((events & PUTTERPOLL_EVSET) == 0) {
327 1.13 ad KERNEL_UNLOCK_ONE(NULL);
328 1.1 pooka return revents;
329 1.13 ad }
330 1.1 pooka
331 1.1 pooka /* check queue */
332 1.1 pooka if (pi->pi_pop->pop_waitcount(pi->pi_private))
333 1.1 pooka revents |= PUTTERPOLL_EVSET;
334 1.1 pooka else
335 1.9 ad selrecord(curlwp, &pi->pi_sel);
336 1.1 pooka
337 1.13 ad KERNEL_UNLOCK_ONE(NULL);
338 1.1 pooka return revents;
339 1.1 pooka }
340 1.1 pooka
341 1.1 pooka /*
342 1.1 pooka * device close = forced unmount.
343 1.1 pooka *
344 1.1 pooka * unmounting is a frightfully complex operation to avoid races
345 1.1 pooka */
346 1.1 pooka static int
347 1.9 ad putter_fop_close(file_t *fp)
348 1.1 pooka {
349 1.1 pooka struct putter_instance *pi = fp->f_data;
350 1.1 pooka int rv;
351 1.1 pooka
352 1.1 pooka DPRINTF(("putter_fop_close: device closed\n"));
353 1.1 pooka
354 1.13 ad KERNEL_LOCK(1, NULL);
355 1.13 ad
356 1.1 pooka restart:
357 1.1 pooka mutex_enter(&pi_mtx);
358 1.1 pooka /*
359 1.1 pooka * First check if the fs was never mounted. In that case
360 1.1 pooka * remove the instance from the list. If mount is attempted later,
361 1.1 pooka * it will simply fail.
362 1.1 pooka */
363 1.1 pooka if (pi->pi_private == PUTTER_EMBRYO) {
364 1.1 pooka TAILQ_REMOVE(&putter_ilist, pi, pi_entries);
365 1.1 pooka mutex_exit(&pi_mtx);
366 1.1 pooka
367 1.1 pooka DPRINTF(("putter_fop_close: data associated with fp %p was "
368 1.1 pooka "embryonic\n", fp));
369 1.1 pooka
370 1.1 pooka goto out;
371 1.1 pooka }
372 1.1 pooka
373 1.1 pooka /*
374 1.1 pooka * Next, analyze if unmount was called and the instance is dead.
375 1.1 pooka * In this case we can just free the structure and go home, it
376 1.1 pooka * was removed from the list by putter_rmprivate().
377 1.1 pooka */
378 1.1 pooka if (pi->pi_private == PUTTER_DEAD) {
379 1.1 pooka mutex_exit(&pi_mtx);
380 1.1 pooka
381 1.1 pooka DPRINTF(("putter_fop_close: putter associated with fp %p (%d) "
382 1.1 pooka "dead, freeing\n", fp, pi->pi_idx));
383 1.1 pooka
384 1.1 pooka goto out;
385 1.1 pooka }
386 1.1 pooka
387 1.1 pooka /*
388 1.1 pooka * So we have a reference. Proceed to unwrap the file system.
389 1.1 pooka */
390 1.1 pooka mutex_exit(&pi_mtx);
391 1.1 pooka
392 1.1 pooka /* hmm? suspicious locking? */
393 1.1 pooka while ((rv = pi->pi_pop->pop_close(pi->pi_private)) == ERESTART)
394 1.1 pooka goto restart;
395 1.1 pooka
396 1.1 pooka out:
397 1.13 ad KERNEL_UNLOCK_ONE(NULL);
398 1.1 pooka /*
399 1.1 pooka * Finally, release the instance information. It was already
400 1.1 pooka * removed from the list by putter_rmprivate() and we know it's
401 1.1 pooka * dead, so no need to lock.
402 1.1 pooka */
403 1.1 pooka kmem_free(pi, sizeof(struct putter_instance));
404 1.1 pooka
405 1.1 pooka return 0;
406 1.1 pooka }
407 1.1 pooka
408 1.1 pooka static int
409 1.22 christos putter_fop_stat(file_t *fp, struct stat *st)
410 1.22 christos {
411 1.22 christos struct putter_instance *pi = fp->f_data;
412 1.22 christos
413 1.22 christos (void)memset(st, 0, sizeof(*st));
414 1.22 christos KERNEL_LOCK(1, NULL);
415 1.22 christos st->st_dev = makedev(cdevsw_lookup_major(&putter_cdevsw), pi->pi_idx);
416 1.22 christos st->st_atimespec = pi->pi_atime;
417 1.22 christos st->st_mtimespec = pi->pi_mtime;
418 1.22 christos st->st_ctimespec = st->st_birthtimespec = pi->pi_btime;
419 1.22 christos KERNEL_UNLOCK_ONE(NULL);
420 1.22 christos return 0;
421 1.22 christos }
422 1.22 christos
423 1.22 christos static int
424 1.9 ad putter_fop_ioctl(file_t *fp, u_long cmd, void *data)
425 1.1 pooka {
426 1.1 pooka
427 1.1 pooka /*
428 1.1 pooka * work already done in sys_ioctl(). skip sanity checks to enable
429 1.1 pooka * setting non-blocking fd without yet having mounted the fs
430 1.1 pooka */
431 1.1 pooka if (cmd == FIONBIO)
432 1.1 pooka return 0;
433 1.1 pooka
434 1.1 pooka return EINVAL;
435 1.1 pooka }
436 1.1 pooka
437 1.1 pooka /* kqueue stuff */
438 1.1 pooka
439 1.1 pooka static void
440 1.1 pooka filt_putterdetach(struct knote *kn)
441 1.1 pooka {
442 1.1 pooka struct putter_instance *pi = kn->kn_hook;
443 1.1 pooka
444 1.13 ad KERNEL_LOCK(1, NULL);
445 1.1 pooka mutex_enter(&pi_mtx);
446 1.1 pooka SLIST_REMOVE(&pi->pi_sel.sel_klist, kn, knote, kn_selnext);
447 1.1 pooka mutex_exit(&pi_mtx);
448 1.13 ad KERNEL_UNLOCK_ONE(NULL);
449 1.1 pooka }
450 1.1 pooka
451 1.1 pooka static int
452 1.6 pooka filt_putter(struct knote *kn, long hint)
453 1.1 pooka {
454 1.1 pooka struct putter_instance *pi = kn->kn_hook;
455 1.13 ad int error, rv;
456 1.1 pooka
457 1.13 ad KERNEL_LOCK(1, NULL);
458 1.1 pooka error = 0;
459 1.1 pooka mutex_enter(&pi_mtx);
460 1.1 pooka if (pi->pi_private == PUTTER_EMBRYO || pi->pi_private == PUTTER_DEAD)
461 1.1 pooka error = 1;
462 1.1 pooka mutex_exit(&pi_mtx);
463 1.13 ad if (error) {
464 1.13 ad KERNEL_UNLOCK_ONE(NULL);
465 1.1 pooka return 0;
466 1.13 ad }
467 1.1 pooka
468 1.1 pooka kn->kn_data = pi->pi_pop->pop_waitcount(pi->pi_private);
469 1.13 ad rv = kn->kn_data != 0;
470 1.13 ad KERNEL_UNLOCK_ONE(NULL);
471 1.13 ad return rv;
472 1.1 pooka }
473 1.1 pooka
474 1.6 pooka static const struct filterops putter_filtops =
475 1.6 pooka { 1, NULL, filt_putterdetach, filt_putter };
476 1.1 pooka
477 1.1 pooka static int
478 1.9 ad putter_fop_kqfilter(file_t *fp, struct knote *kn)
479 1.1 pooka {
480 1.1 pooka struct putter_instance *pi = fp->f_data;
481 1.1 pooka struct klist *klist;
482 1.1 pooka
483 1.13 ad KERNEL_LOCK(1, NULL);
484 1.13 ad
485 1.6 pooka switch (kn->kn_filter) {
486 1.6 pooka case EVFILT_READ:
487 1.6 pooka klist = &pi->pi_sel.sel_klist;
488 1.6 pooka kn->kn_fop = &putter_filtops;
489 1.6 pooka kn->kn_hook = pi;
490 1.1 pooka
491 1.6 pooka mutex_enter(&pi_mtx);
492 1.6 pooka SLIST_INSERT_HEAD(klist, kn, kn_selnext);
493 1.6 pooka mutex_exit(&pi_mtx);
494 1.1 pooka
495 1.6 pooka break;
496 1.6 pooka case EVFILT_WRITE:
497 1.6 pooka kn->kn_fop = &seltrue_filtops;
498 1.6 pooka break;
499 1.6 pooka default:
500 1.13 ad KERNEL_UNLOCK_ONE(NULL);
501 1.6 pooka return EINVAL;
502 1.6 pooka }
503 1.1 pooka
504 1.13 ad KERNEL_UNLOCK_ONE(NULL);
505 1.1 pooka return 0;
506 1.1 pooka }
507 1.1 pooka
508 1.1 pooka int
509 1.1 pooka puttercdopen(dev_t dev, int flags, int fmt, struct lwp *l)
510 1.1 pooka {
511 1.1 pooka struct putter_instance *pi;
512 1.9 ad file_t *fp;
513 1.1 pooka int error, fd, idx;
514 1.9 ad proc_t *p;
515 1.1 pooka
516 1.9 ad p = curproc;
517 1.1 pooka pi = kmem_alloc(sizeof(struct putter_instance), KM_SLEEP);
518 1.1 pooka mutex_enter(&pi_mtx);
519 1.1 pooka idx = get_pi_idx(pi);
520 1.1 pooka
521 1.9 ad pi->pi_pid = p->p_pid;
522 1.1 pooka pi->pi_idx = idx;
523 1.1 pooka pi->pi_curput = NULL;
524 1.1 pooka pi->pi_curres = 0;
525 1.1 pooka pi->pi_curopaq = NULL;
526 1.22 christos getnanotime(&pi->pi_btime);
527 1.22 christos pi->pi_atime = pi->pi_mtime = pi->pi_btime;
528 1.4 pooka selinit(&pi->pi_sel);
529 1.1 pooka mutex_exit(&pi_mtx);
530 1.1 pooka
531 1.9 ad if ((error = fd_allocfile(&fp, &fd)) != 0)
532 1.5 pooka goto bad1;
533 1.5 pooka
534 1.5 pooka if ((error = putter_configure(dev, flags, fmt, fd)) != 0)
535 1.5 pooka goto bad2;
536 1.5 pooka
537 1.1 pooka DPRINTF(("puttercdopen: registered embryonic pmp for pid: %d\n",
538 1.1 pooka pi->pi_pid));
539 1.1 pooka
540 1.9 ad error = fd_clone(fp, fd, FREAD|FWRITE, &putter_fileops, pi);
541 1.16 pooka KASSERT(error == EMOVEFD);
542 1.5 pooka return error;
543 1.5 pooka
544 1.5 pooka bad2:
545 1.9 ad fd_abort(p, fp, fd);
546 1.5 pooka bad1:
547 1.5 pooka putter_detach(pi);
548 1.5 pooka kmem_free(pi, sizeof(struct putter_instance));
549 1.5 pooka return error;
550 1.1 pooka }
551 1.1 pooka
552 1.1 pooka int
553 1.1 pooka puttercdclose(dev_t dev, int flags, int fmt, struct lwp *l)
554 1.1 pooka {
555 1.1 pooka
556 1.1 pooka panic("puttercdclose impossible\n");
557 1.1 pooka
558 1.1 pooka return 0;
559 1.1 pooka }
560 1.1 pooka
561 1.1 pooka
562 1.1 pooka /*
563 1.1 pooka * Set the private structure for the file descriptor. This is
564 1.1 pooka * typically done immediately when the counterpart has knowledge
565 1.1 pooka * about the private structure's address and the file descriptor
566 1.1 pooka * (e.g. vfs mount routine).
567 1.1 pooka *
568 1.1 pooka * We only want to make sure that the caller had the right to open the
569 1.1 pooka * device, we don't so much care about which context it gets in case
570 1.1 pooka * the same process opened multiple (since they are equal at this point).
571 1.1 pooka */
572 1.1 pooka struct putter_instance *
573 1.1 pooka putter_attach(pid_t pid, int fd, void *ppriv, struct putter_ops *pop)
574 1.1 pooka {
575 1.1 pooka struct putter_instance *pi = NULL;
576 1.1 pooka
577 1.1 pooka mutex_enter(&pi_mtx);
578 1.1 pooka TAILQ_FOREACH(pi, &putter_ilist, pi_entries) {
579 1.1 pooka if (pi->pi_pid == pid && pi->pi_private == PUTTER_EMBRYO) {
580 1.1 pooka pi->pi_private = ppriv;
581 1.1 pooka pi->pi_fd = fd;
582 1.1 pooka pi->pi_pop = pop;
583 1.1 pooka break;
584 1.1 pooka }
585 1.1 pooka }
586 1.1 pooka mutex_exit(&pi_mtx);
587 1.1 pooka
588 1.1 pooka DPRINTF(("putter_setprivate: pi at %p (%d/%d)\n", pi,
589 1.1 pooka pi ? pi->pi_pid : 0, pi ? pi->pi_fd : 0));
590 1.1 pooka
591 1.1 pooka return pi;
592 1.1 pooka }
593 1.1 pooka
594 1.1 pooka /*
595 1.1 pooka * Remove fp <-> private mapping.
596 1.1 pooka */
597 1.1 pooka void
598 1.1 pooka putter_detach(struct putter_instance *pi)
599 1.1 pooka {
600 1.1 pooka
601 1.1 pooka mutex_enter(&pi_mtx);
602 1.1 pooka TAILQ_REMOVE(&putter_ilist, pi, pi_entries);
603 1.1 pooka pi->pi_private = PUTTER_DEAD;
604 1.1 pooka mutex_exit(&pi_mtx);
605 1.1 pooka
606 1.1 pooka DPRINTF(("putter_nukebypmp: nuked %p\n", pi));
607 1.1 pooka }
608 1.1 pooka
609 1.1 pooka void
610 1.1 pooka putter_notify(struct putter_instance *pi)
611 1.1 pooka {
612 1.1 pooka
613 1.8 rmind selnotify(&pi->pi_sel, 0, 0);
614 1.1 pooka }
615 1.1 pooka
616 1.1 pooka /* search sorted list of instances for free minor, sorted insert arg */
617 1.1 pooka static int
618 1.1 pooka get_pi_idx(struct putter_instance *pi_i)
619 1.1 pooka {
620 1.1 pooka struct putter_instance *pi;
621 1.1 pooka int i;
622 1.1 pooka
623 1.4 pooka KASSERT(mutex_owned(&pi_mtx));
624 1.4 pooka
625 1.1 pooka i = 0;
626 1.1 pooka TAILQ_FOREACH(pi, &putter_ilist, pi_entries) {
627 1.1 pooka if (i != pi->pi_idx)
628 1.1 pooka break;
629 1.1 pooka i++;
630 1.1 pooka }
631 1.1 pooka
632 1.1 pooka pi_i->pi_private = PUTTER_EMBRYO;
633 1.1 pooka
634 1.1 pooka if (pi == NULL)
635 1.1 pooka TAILQ_INSERT_TAIL(&putter_ilist, pi_i, pi_entries);
636 1.1 pooka else
637 1.1 pooka TAILQ_INSERT_BEFORE(pi, pi_i, pi_entries);
638 1.1 pooka
639 1.1 pooka return i;
640 1.1 pooka }
641 1.10 jmcneill
642 1.10 jmcneill MODULE(MODULE_CLASS_MISC, putter, NULL);
643 1.10 jmcneill
644 1.10 jmcneill static int
645 1.10 jmcneill putter_modcmd(modcmd_t cmd, void *arg)
646 1.10 jmcneill {
647 1.18 pooka #ifdef _MODULE
648 1.19 drochner devmajor_t bmajor = NODEVMAJOR, cmajor = NODEVMAJOR;
649 1.10 jmcneill
650 1.10 jmcneill switch (cmd) {
651 1.10 jmcneill case MODULE_CMD_INIT:
652 1.10 jmcneill return devsw_attach("putter", NULL, &bmajor,
653 1.10 jmcneill &putter_cdevsw, &cmajor);
654 1.10 jmcneill case MODULE_CMD_FINI:
655 1.11 ad return devsw_detach(NULL, &putter_cdevsw);
656 1.10 jmcneill default:
657 1.10 jmcneill return ENOTTY;
658 1.10 jmcneill }
659 1.18 pooka #else
660 1.18 pooka if (cmd == MODULE_CMD_INIT)
661 1.18 pooka return 0;
662 1.18 pooka return ENOTTY;
663 1.18 pooka #endif
664 1.10 jmcneill }
665