event.c revision 1.3 1 1.3 cgd /* $NetBSD: event.c,v 1.3 1994/10/26 02:02:58 cgd Exp $ */
2 1.3 cgd
3 1.1 mw /*
4 1.1 mw * Copyright (c) 1992, 1993
5 1.1 mw * The Regents of the University of California. All rights reserved.
6 1.1 mw *
7 1.1 mw * This software was developed by the Computer Systems Engineering group
8 1.1 mw * at Lawrence Berkeley Laboratory under DARPA contract BG 91-66 and
9 1.1 mw * contributed to Berkeley.
10 1.1 mw *
11 1.1 mw * All advertising materials mentioning features or use of this software
12 1.1 mw * must display the following acknowledgement:
13 1.1 mw * This product includes software developed by the University of
14 1.1 mw * California, Lawrence Berkeley Laboratory.
15 1.1 mw *
16 1.1 mw * Redistribution and use in source and binary forms, with or without
17 1.1 mw * modification, are permitted provided that the following conditions
18 1.1 mw * are met:
19 1.1 mw * 1. Redistributions of source code must retain the above copyright
20 1.1 mw * notice, this list of conditions and the following disclaimer.
21 1.1 mw * 2. Redistributions in binary form must reproduce the above copyright
22 1.1 mw * notice, this list of conditions and the following disclaimer in the
23 1.1 mw * documentation and/or other materials provided with the distribution.
24 1.1 mw * 3. All advertising materials mentioning features or use of this software
25 1.1 mw * must display the following acknowledgement:
26 1.1 mw * This product includes software developed by the University of
27 1.1 mw * California, Berkeley and its contributors.
28 1.1 mw * 4. Neither the name of the University nor the names of its contributors
29 1.1 mw * may be used to endorse or promote products derived from this software
30 1.1 mw * without specific prior written permission.
31 1.1 mw *
32 1.1 mw * THIS SOFTWARE IS PROVIDED BY THE REGENTS AND CONTRIBUTORS ``AS IS'' AND
33 1.1 mw * ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE
34 1.1 mw * IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE
35 1.1 mw * ARE DISCLAIMED. IN NO EVENT SHALL THE REGENTS OR CONTRIBUTORS BE LIABLE
36 1.1 mw * FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL
37 1.1 mw * DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS
38 1.1 mw * OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION)
39 1.1 mw * HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT
40 1.1 mw * LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY
41 1.1 mw * OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF
42 1.1 mw * SUCH DAMAGE.
43 1.1 mw *
44 1.1 mw * @(#)event.c 8.1 (Berkeley) 6/11/93
45 1.1 mw *
46 1.3 cgd * Header: event.c,v 1.5 92/11/26 01:10:44 torek Exp (LBL)
47 1.1 mw */
48 1.1 mw
49 1.1 mw /*
50 1.1 mw * Internal `Firm_event' interface for the keyboard and mouse drivers.
51 1.1 mw */
52 1.1 mw
53 1.2 chopps #include <sys/param.h>
54 1.2 chopps #include <sys/fcntl.h>
55 1.2 chopps #include <sys/malloc.h>
56 1.2 chopps #include <sys/proc.h>
57 1.2 chopps #include <sys/systm.h>
58 1.2 chopps #include <sys/vnode.h>
59 1.1 mw
60 1.2 chopps #include <amiga/dev/vuid_event.h>
61 1.2 chopps #include <amiga/dev/event_var.h>
62 1.1 mw
63 1.1 mw /*
64 1.1 mw * Initialize a firm_event queue.
65 1.1 mw */
66 1.1 mw void
67 1.1 mw ev_init(ev)
68 1.1 mw register struct evvar *ev;
69 1.1 mw {
70 1.1 mw
71 1.1 mw ev->ev_get = ev->ev_put = 0;
72 1.1 mw ev->ev_q = malloc((u_long)EV_QSIZE * sizeof(struct firm_event),
73 1.1 mw M_DEVBUF, M_WAITOK);
74 1.1 mw bzero((caddr_t)ev->ev_q, EV_QSIZE * sizeof(struct firm_event));
75 1.1 mw }
76 1.1 mw
77 1.1 mw /*
78 1.1 mw * Tear down a firm_event queue.
79 1.1 mw */
80 1.1 mw void
81 1.1 mw ev_fini(ev)
82 1.1 mw register struct evvar *ev;
83 1.1 mw {
84 1.1 mw
85 1.1 mw free(ev->ev_q, M_DEVBUF);
86 1.1 mw }
87 1.1 mw
88 1.1 mw /*
89 1.1 mw * User-level interface: read, select.
90 1.1 mw * (User cannot write an event queue.)
91 1.1 mw */
92 1.1 mw int
93 1.1 mw ev_read(ev, uio, flags)
94 1.1 mw register struct evvar *ev;
95 1.1 mw struct uio *uio;
96 1.1 mw int flags;
97 1.1 mw {
98 1.1 mw int s, n, cnt, error;
99 1.1 mw
100 1.1 mw /*
101 1.1 mw * Make sure we can return at least 1.
102 1.1 mw */
103 1.1 mw if (uio->uio_resid < sizeof(struct firm_event))
104 1.1 mw return (EMSGSIZE); /* ??? */
105 1.1 mw s = splev();
106 1.1 mw while (ev->ev_get == ev->ev_put) {
107 1.1 mw if (flags & IO_NDELAY) {
108 1.1 mw splx(s);
109 1.1 mw return (EWOULDBLOCK);
110 1.1 mw }
111 1.1 mw ev->ev_wanted = 1;
112 1.1 mw error = tsleep((caddr_t)ev, PEVENT | PCATCH, "firm_event", 0);
113 1.1 mw if (error) {
114 1.1 mw splx(s);
115 1.1 mw return (error);
116 1.1 mw }
117 1.1 mw }
118 1.1 mw /*
119 1.1 mw * Move firm_events from tail end of queue (there is at least one
120 1.1 mw * there).
121 1.1 mw */
122 1.1 mw if (ev->ev_put < ev->ev_get)
123 1.1 mw cnt = EV_QSIZE - ev->ev_get; /* events in [get..QSIZE) */
124 1.1 mw else
125 1.1 mw cnt = ev->ev_put - ev->ev_get; /* events in [get..put) */
126 1.1 mw splx(s);
127 1.1 mw n = howmany(uio->uio_resid, sizeof(struct firm_event));
128 1.1 mw if (cnt > n)
129 1.1 mw cnt = n;
130 1.1 mw error = uiomove((caddr_t)&ev->ev_q[ev->ev_get],
131 1.1 mw cnt * sizeof(struct firm_event), uio);
132 1.1 mw n -= cnt;
133 1.1 mw /*
134 1.1 mw * If we do not wrap to 0, used up all our space, or had an error,
135 1.1 mw * stop. Otherwise move from front of queue to put index, if there
136 1.1 mw * is anything there to move.
137 1.1 mw */
138 1.1 mw if ((ev->ev_get = (ev->ev_get + cnt) % EV_QSIZE) != 0 ||
139 1.1 mw n == 0 || error || (cnt = ev->ev_put) == 0)
140 1.1 mw return (error);
141 1.1 mw if (cnt > n)
142 1.1 mw cnt = n;
143 1.1 mw error = uiomove((caddr_t)&ev->ev_q[0],
144 1.1 mw cnt * sizeof(struct firm_event), uio);
145 1.1 mw ev->ev_get = cnt;
146 1.1 mw return (error);
147 1.1 mw }
148 1.1 mw
149 1.1 mw int
150 1.1 mw ev_select(ev, rw, p)
151 1.1 mw register struct evvar *ev;
152 1.1 mw int rw;
153 1.1 mw struct proc *p;
154 1.1 mw {
155 1.1 mw int s = splev();
156 1.1 mw
157 1.1 mw switch (rw) {
158 1.1 mw
159 1.1 mw case FREAD:
160 1.1 mw /* succeed if there is something to read */
161 1.1 mw if (ev->ev_get != ev->ev_put) {
162 1.1 mw splx(s);
163 1.1 mw return (1);
164 1.1 mw }
165 1.1 mw selrecord(p, &ev->ev_sel);
166 1.1 mw break;
167 1.1 mw
168 1.1 mw case FWRITE:
169 1.1 mw return (1); /* always fails => never blocks */
170 1.1 mw }
171 1.1 mw splx(s);
172 1.1 mw return (0);
173 1.1 mw }
174