Home | History | Annotate | Line # | Download | only in dev
event.c revision 1.7.6.4
      1  1.7.6.4     skrll /*	$NetBSD: event.c,v 1.7.6.4 2005/01/24 08:35:10 skrll 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.7.6.1     skrll  * 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.1       oki 
     47  1.7.6.1     skrll #include <sys/cdefs.h>
     48  1.7.6.4     skrll __KERNEL_RCSID(0, "$NetBSD: event.c,v 1.7.6.4 2005/01/24 08:35:10 skrll Exp $");
     49  1.7.6.1     skrll 
     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.7.6.4     skrll 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.5       wiz 	memset((caddr_t)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.7.6.4     skrll 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.7.6.4     skrll 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.1       oki 		error = tsleep((caddr_t)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.1       oki 	error = uiomove((caddr_t)&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.1       oki 	error = uiomove((caddr_t)&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.7.6.4     skrll ev_poll(struct evvar *ev, int events, struct proc *p)
    145      1.1       oki {
    146  1.7.6.4     skrll 	int s, revents = 0;
    147      1.1       oki 
    148  1.7.6.4     skrll 	s = splev();
    149      1.3       oki 	if (events & (POLLIN | POLLRDNORM)) {
    150      1.3       oki 		if (ev->ev_get == ev->ev_put)
    151      1.3       oki 			selrecord(p, &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