Home | History | Annotate | Line # | Download | only in dev
event.c revision 1.11.26.1
      1  1.11.26.1     rmind /*	$NetBSD: event.c,v 1.11.26.1 2007/03/12 05:51:36 rmind Exp $ */
      2        1.1       oki 
      3        1.1       oki /*
      4        1.1       oki  * Copyright (c) 1992, 1993
      5        1.1       oki  *	The Regents of the University of California.  All rights reserved.
      6        1.1       oki  *
      7        1.1       oki  * This software was developed by the Computer Systems Engineering group
      8        1.1       oki  * at Lawrence Berkeley Laboratory under DARPA contract BG 91-66 and
      9        1.1       oki  * contributed to Berkeley.
     10        1.1       oki  *
     11        1.1       oki  * All advertising materials mentioning features or use of this software
     12        1.1       oki  * must display the following acknowledgement:
     13        1.1       oki  *	This product includes software developed by the University of
     14        1.1       oki  *	California, Lawrence Berkeley Laboratory.
     15        1.1       oki  *
     16        1.1       oki  * Redistribution and use in source and binary forms, with or without
     17        1.1       oki  * modification, are permitted provided that the following conditions
     18        1.1       oki  * are met:
     19        1.1       oki  * 1. Redistributions of source code must retain the above copyright
     20        1.1       oki  *    notice, this list of conditions and the following disclaimer.
     21        1.1       oki  * 2. Redistributions in binary form must reproduce the above copyright
     22        1.1       oki  *    notice, this list of conditions and the following disclaimer in the
     23        1.1       oki  *    documentation and/or other materials provided with the distribution.
     24        1.9       agc  * 3. Neither the name of the University nor the names of its contributors
     25        1.1       oki  *    may be used to endorse or promote products derived from this software
     26        1.1       oki  *    without specific prior written permission.
     27        1.1       oki  *
     28        1.1       oki  * THIS SOFTWARE IS PROVIDED BY THE REGENTS AND CONTRIBUTORS ``AS IS'' AND
     29        1.1       oki  * ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE
     30        1.1       oki  * IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE
     31        1.1       oki  * ARE DISCLAIMED.  IN NO EVENT SHALL THE REGENTS OR CONTRIBUTORS BE LIABLE
     32        1.1       oki  * FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL
     33        1.1       oki  * DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS
     34        1.1       oki  * OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION)
     35        1.1       oki  * HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT
     36        1.1       oki  * LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY
     37        1.1       oki  * OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF
     38        1.1       oki  * SUCH DAMAGE.
     39        1.1       oki  *
     40        1.1       oki  *	@(#)event.c	8.1 (Berkeley) 6/11/93
     41        1.1       oki  */
     42        1.1       oki 
     43        1.1       oki /*
     44        1.1       oki  * Internal `Firm_event' interface for the keyboard and mouse drivers.
     45        1.1       oki  */
     46        1.8     lukem 
     47        1.8     lukem #include <sys/cdefs.h>
     48  1.11.26.1     rmind __KERNEL_RCSID(0, "$NetBSD: event.c,v 1.11.26.1 2007/03/12 05:51:36 rmind Exp $");
     49        1.1       oki 
     50        1.1       oki #include <sys/param.h>
     51        1.1       oki #include <sys/fcntl.h>
     52        1.1       oki #include <sys/malloc.h>
     53        1.1       oki #include <sys/proc.h>
     54        1.1       oki #include <sys/systm.h>
     55        1.1       oki #include <sys/vnode.h>
     56        1.3       oki #include <sys/select.h>
     57        1.3       oki #include <sys/poll.h>
     58        1.1       oki 
     59        1.1       oki #include <machine/vuid_event.h>
     60        1.1       oki #include <x68k/dev/event_var.h>
     61        1.1       oki 
     62        1.1       oki /*
     63        1.1       oki  * Initialize a firm_event queue.
     64        1.1       oki  */
     65        1.1       oki void
     66       1.10       chs ev_init(struct evvar *ev)
     67        1.1       oki {
     68        1.1       oki 
     69        1.1       oki 	ev->ev_get = ev->ev_put = 0;
     70        1.1       oki 	ev->ev_q = malloc((u_long)EV_QSIZE * sizeof(struct firm_event),
     71        1.1       oki 	    M_DEVBUF, M_WAITOK);
     72  1.11.26.1     rmind 	memset((void *)ev->ev_q, 0, EV_QSIZE * sizeof(struct firm_event));
     73        1.1       oki }
     74        1.1       oki 
     75        1.1       oki /*
     76        1.1       oki  * Tear down a firm_event queue.
     77        1.1       oki  */
     78        1.1       oki void
     79       1.10       chs ev_fini(struct evvar *ev)
     80        1.1       oki {
     81        1.1       oki 
     82        1.1       oki 	free(ev->ev_q, M_DEVBUF);
     83        1.1       oki }
     84        1.1       oki 
     85        1.1       oki /*
     86        1.1       oki  * User-level interface: read, select.
     87        1.1       oki  * (User cannot write an event queue.)
     88        1.1       oki  */
     89        1.1       oki int
     90       1.10       chs ev_read(struct evvar *ev, struct uio *uio, int flags)
     91        1.1       oki {
     92        1.1       oki 	int s, n, cnt, error;
     93        1.1       oki 
     94        1.1       oki 	/*
     95        1.1       oki 	 * Make sure we can return at least 1.
     96        1.1       oki 	 */
     97        1.1       oki 	if (uio->uio_resid < sizeof(struct firm_event))
     98        1.1       oki 		return (EMSGSIZE);	/* ??? */
     99        1.1       oki 	s = splev();
    100        1.1       oki 	while (ev->ev_get == ev->ev_put) {
    101        1.1       oki 		if (flags & IO_NDELAY) {
    102        1.1       oki 			splx(s);
    103        1.1       oki 			return (EWOULDBLOCK);
    104        1.1       oki 		}
    105        1.1       oki 		ev->ev_wanted = 1;
    106  1.11.26.1     rmind 		error = tsleep((void *)ev, PEVENT | PCATCH, "firm_event", 0);
    107        1.1       oki 		if (error) {
    108        1.1       oki 			splx(s);
    109        1.1       oki 			return (error);
    110        1.1       oki 		}
    111        1.1       oki 	}
    112        1.1       oki 	/*
    113        1.1       oki 	 * Move firm_events from tail end of queue (there is at least one
    114        1.1       oki 	 * there).
    115        1.1       oki 	 */
    116        1.1       oki 	if (ev->ev_put < ev->ev_get)
    117        1.1       oki 		cnt = EV_QSIZE - ev->ev_get;	/* events in [get..QSIZE) */
    118        1.1       oki 	else
    119        1.1       oki 		cnt = ev->ev_put - ev->ev_get;	/* events in [get..put) */
    120        1.1       oki 	splx(s);
    121        1.1       oki 	n = howmany(uio->uio_resid, sizeof(struct firm_event));
    122        1.1       oki 	if (cnt > n)
    123        1.1       oki 		cnt = n;
    124  1.11.26.1     rmind 	error = uiomove((void *)&ev->ev_q[ev->ev_get],
    125        1.1       oki 	    cnt * sizeof(struct firm_event), uio);
    126        1.1       oki 	n -= cnt;
    127        1.1       oki 	/*
    128        1.1       oki 	 * If we do not wrap to 0, used up all our space, or had an error,
    129        1.1       oki 	 * stop.  Otherwise move from front of queue to put index, if there
    130        1.1       oki 	 * is anything there to move.
    131        1.1       oki 	 */
    132        1.1       oki 	if ((ev->ev_get = (ev->ev_get + cnt) % EV_QSIZE) != 0 ||
    133        1.1       oki 	    n == 0 || error || (cnt = ev->ev_put) == 0)
    134        1.1       oki 		return (error);
    135        1.1       oki 	if (cnt > n)
    136        1.1       oki 		cnt = n;
    137  1.11.26.1     rmind 	error = uiomove((void *)&ev->ev_q[0],
    138        1.1       oki 	    cnt * sizeof(struct firm_event), uio);
    139        1.1       oki 	ev->ev_get = cnt;
    140        1.1       oki 	return (error);
    141        1.1       oki }
    142        1.1       oki 
    143        1.1       oki int
    144       1.11  christos ev_poll(struct evvar *ev, int events, struct lwp *l)
    145        1.1       oki {
    146       1.10       chs 	int s, revents = 0;
    147        1.1       oki 
    148       1.10       chs 	s = splev();
    149        1.3       oki 	if (events & (POLLIN | POLLRDNORM)) {
    150        1.3       oki 		if (ev->ev_get == ev->ev_put)
    151       1.11  christos 			selrecord(l, &ev->ev_sel);
    152        1.3       oki 		else
    153        1.3       oki 			revents |= events & (POLLIN | POLLRDNORM);
    154        1.3       oki 	}
    155        1.3       oki 	revents |= events & (POLLOUT | POLLWRNORM);
    156        1.1       oki 	splx(s);
    157        1.3       oki 	return (revents);
    158        1.6  jdolecek }
    159        1.6  jdolecek 
    160        1.6  jdolecek static void
    161        1.6  jdolecek filt_evrdetach(struct knote *kn)
    162        1.6  jdolecek {
    163        1.6  jdolecek 	struct evvar *ev = kn->kn_hook;
    164        1.6  jdolecek 	int s;
    165        1.6  jdolecek 
    166        1.6  jdolecek 	s = splev();
    167        1.7  christos 	SLIST_REMOVE(&ev->ev_sel.sel_klist, kn, knote, kn_selnext);
    168        1.6  jdolecek 	splx(s);
    169        1.6  jdolecek }
    170        1.6  jdolecek 
    171        1.6  jdolecek static int
    172        1.6  jdolecek filt_evread(struct knote *kn, long hint)
    173        1.6  jdolecek {
    174        1.6  jdolecek 	struct evvar *ev = kn->kn_hook;
    175        1.6  jdolecek 
    176        1.6  jdolecek 	if (ev->ev_get == ev->ev_put)
    177        1.6  jdolecek 		return (0);
    178        1.6  jdolecek 
    179        1.6  jdolecek 	if (ev->ev_get < ev->ev_put)
    180        1.6  jdolecek 		kn->kn_data = ev->ev_put - ev->ev_get;
    181        1.6  jdolecek 	else
    182        1.6  jdolecek 		kn->kn_data = (EV_QSIZE - ev->ev_get) +
    183        1.6  jdolecek 		    ev->ev_put;
    184        1.6  jdolecek 
    185        1.6  jdolecek 	kn->kn_data *= sizeof(struct firm_event);
    186        1.6  jdolecek 
    187        1.6  jdolecek 	return (1);
    188        1.6  jdolecek }
    189        1.6  jdolecek 
    190        1.6  jdolecek static const struct filterops ev_filtops =
    191        1.6  jdolecek 	{ 1, NULL, filt_evrdetach, filt_evread };
    192        1.6  jdolecek 
    193        1.6  jdolecek int
    194        1.6  jdolecek ev_kqfilter(struct evvar *ev, struct knote *kn)
    195        1.6  jdolecek {
    196        1.6  jdolecek 	struct klist *klist;
    197        1.6  jdolecek 	int s;
    198        1.6  jdolecek 
    199        1.6  jdolecek 	switch (kn->kn_filter) {
    200        1.6  jdolecek 	case EVFILT_READ:
    201        1.7  christos 		klist = &ev->ev_sel.sel_klist;
    202        1.6  jdolecek 		kn->kn_fop = &ev_filtops;
    203        1.6  jdolecek 		break;
    204        1.6  jdolecek 
    205        1.6  jdolecek 	default:
    206        1.6  jdolecek 		return (1);
    207        1.6  jdolecek 	}
    208        1.6  jdolecek 
    209        1.6  jdolecek 	kn->kn_hook = ev;
    210        1.6  jdolecek 
    211        1.6  jdolecek 	s = splev();
    212        1.6  jdolecek 	SLIST_INSERT_HEAD(klist, kn, kn_selnext);
    213        1.6  jdolecek 	splx(s);
    214        1.6  jdolecek 
    215        1.6  jdolecek 	return (0);
    216        1.1       oki }
    217