sysmon_envsys_events.c revision 1.44 1 1.44 xtraeme /* $NetBSD: sysmon_envsys_events.c,v 1.44 2007/11/03 23:05:21 xtraeme Exp $ */
2 1.1 xtraeme
3 1.1 xtraeme /*-
4 1.36 xtraeme * Copyright (c) 2007 Juan Romero Pardines.
5 1.1 xtraeme * All rights reserved.
6 1.1 xtraeme *
7 1.1 xtraeme * Redistribution and use in source and binary forms, with or without
8 1.1 xtraeme * modification, are permitted provided that the following conditions
9 1.1 xtraeme * are met:
10 1.1 xtraeme * 1. Redistributions of source code must retain the above copyright
11 1.1 xtraeme * notice, this list of conditions and the following disclaimer.
12 1.1 xtraeme * 2. Redistributions in binary form must reproduce the above copyright
13 1.1 xtraeme * notice, this list of conditions and the following disclaimer in the
14 1.1 xtraeme * documentation and/or other materials provided with the distribution.
15 1.1 xtraeme *
16 1.36 xtraeme * THIS SOFTWARE IS PROVIDED BY THE AUTHOR ``AS IS'' AND ANY EXPRESS OR
17 1.36 xtraeme * IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE IMPLIED WARRANTIES
18 1.36 xtraeme * OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE ARE DISCLAIMED.
19 1.36 xtraeme * IN NO EVENT SHALL THE AUTHOR BE LIABLE FOR ANY DIRECT, INDIRECT,
20 1.36 xtraeme * INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT
21 1.36 xtraeme * NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE,
22 1.36 xtraeme * DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY
23 1.36 xtraeme * THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT
24 1.36 xtraeme * (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE OF
25 1.36 xtraeme * THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.
26 1.1 xtraeme */
27 1.1 xtraeme
28 1.1 xtraeme /*
29 1.1 xtraeme * sysmon_envsys(9) events framework.
30 1.1 xtraeme */
31 1.1 xtraeme
32 1.1 xtraeme #include <sys/cdefs.h>
33 1.44 xtraeme __KERNEL_RCSID(0, "$NetBSD: sysmon_envsys_events.c,v 1.44 2007/11/03 23:05:21 xtraeme Exp $");
34 1.1 xtraeme
35 1.1 xtraeme #include <sys/param.h>
36 1.1 xtraeme #include <sys/types.h>
37 1.1 xtraeme #include <sys/conf.h>
38 1.1 xtraeme #include <sys/errno.h>
39 1.1 xtraeme #include <sys/kernel.h>
40 1.3 xtraeme #include <sys/sysctl.h>
41 1.1 xtraeme #include <sys/systm.h>
42 1.1 xtraeme #include <sys/proc.h>
43 1.1 xtraeme #include <sys/mutex.h>
44 1.1 xtraeme #include <sys/kmem.h>
45 1.1 xtraeme #include <sys/callout.h>
46 1.1 xtraeme
47 1.32 xtraeme /* #define ENVSYS_DEBUG */
48 1.1 xtraeme #include <dev/sysmon/sysmonvar.h>
49 1.1 xtraeme #include <dev/sysmon/sysmon_envsysvar.h>
50 1.1 xtraeme
51 1.10 xtraeme struct sme_sensor_event {
52 1.10 xtraeme int state;
53 1.10 xtraeme int event;
54 1.10 xtraeme };
55 1.10 xtraeme
56 1.10 xtraeme static const struct sme_sensor_event sme_sensor_event[] = {
57 1.10 xtraeme { ENVSYS_SVALID, PENVSYS_EVENT_NORMAL },
58 1.10 xtraeme { ENVSYS_SCRITICAL, PENVSYS_EVENT_CRITICAL },
59 1.10 xtraeme { ENVSYS_SCRITOVER, PENVSYS_EVENT_CRITOVER },
60 1.10 xtraeme { ENVSYS_SCRITUNDER, PENVSYS_EVENT_CRITUNDER },
61 1.10 xtraeme { ENVSYS_SWARNOVER, PENVSYS_EVENT_WARNOVER },
62 1.10 xtraeme { ENVSYS_SWARNUNDER, PENVSYS_EVENT_WARNUNDER },
63 1.10 xtraeme { -1, -1 }
64 1.10 xtraeme };
65 1.10 xtraeme
66 1.1 xtraeme static struct workqueue *seewq;
67 1.1 xtraeme static struct callout seeco;
68 1.1 xtraeme static bool sme_events_initialized = false;
69 1.38 xtraeme static bool sysmon_low_power = false;
70 1.31 xtraeme kmutex_t sme_mtx, sme_event_init_mtx;
71 1.33 xtraeme kcondvar_t sme_cv;
72 1.1 xtraeme
73 1.3 xtraeme /* 10 seconds of timeout for the callout */
74 1.3 xtraeme static int sme_events_timeout = 10;
75 1.3 xtraeme static int sme_events_timeout_sysctl(SYSCTLFN_PROTO);
76 1.3 xtraeme #define SME_EVTIMO (sme_events_timeout * hz)
77 1.3 xtraeme
78 1.44 xtraeme static bool sme_event_check_low_power(void);
79 1.44 xtraeme static bool sme_battery_critical(envsys_data_t *);
80 1.38 xtraeme
81 1.3 xtraeme /*
82 1.3 xtraeme * sysctl(9) stuff to handle the refresh value in the callout
83 1.3 xtraeme * function.
84 1.3 xtraeme */
85 1.3 xtraeme static int
86 1.3 xtraeme sme_events_timeout_sysctl(SYSCTLFN_ARGS)
87 1.3 xtraeme {
88 1.3 xtraeme struct sysctlnode node;
89 1.3 xtraeme int timo, error;
90 1.3 xtraeme
91 1.3 xtraeme node = *rnode;
92 1.3 xtraeme timo = sme_events_timeout;
93 1.3 xtraeme node.sysctl_data = &timo;
94 1.3 xtraeme
95 1.3 xtraeme error = sysctl_lookup(SYSCTLFN_CALL(&node));
96 1.36 xtraeme if (error || !newp)
97 1.3 xtraeme return error;
98 1.3 xtraeme
99 1.5 xtraeme /* min 1s */
100 1.5 xtraeme if (timo < 1)
101 1.3 xtraeme return EINVAL;
102 1.3 xtraeme
103 1.3 xtraeme sme_events_timeout = timo;
104 1.3 xtraeme return 0;
105 1.3 xtraeme }
106 1.3 xtraeme
107 1.3 xtraeme SYSCTL_SETUP(sysctl_kern_envsys_timeout_setup, "sysctl kern.envsys subtree")
108 1.3 xtraeme {
109 1.3 xtraeme const struct sysctlnode *node, *envsys_node;
110 1.3 xtraeme
111 1.3 xtraeme sysctl_createv(clog, 0, NULL, &node,
112 1.3 xtraeme CTLFLAG_PERMANENT,
113 1.3 xtraeme CTLTYPE_NODE, "kern", NULL,
114 1.3 xtraeme NULL, 0, NULL, 0,
115 1.3 xtraeme CTL_KERN, CTL_EOL);
116 1.3 xtraeme
117 1.3 xtraeme sysctl_createv(clog, 0, &node, &envsys_node,
118 1.3 xtraeme 0,
119 1.3 xtraeme CTLTYPE_NODE, "envsys", NULL,
120 1.3 xtraeme NULL, 0, NULL, 0,
121 1.3 xtraeme CTL_CREATE, CTL_EOL);
122 1.3 xtraeme
123 1.3 xtraeme sysctl_createv(clog, 0, &envsys_node, &node,
124 1.3 xtraeme CTLFLAG_READWRITE,
125 1.3 xtraeme CTLTYPE_INT, "refresh_value",
126 1.3 xtraeme SYSCTL_DESCR("wait time in seconds to refresh "
127 1.3 xtraeme "sensors being monitored"),
128 1.3 xtraeme sme_events_timeout_sysctl, 0, &sme_events_timeout, 0,
129 1.3 xtraeme CTL_CREATE, CTL_EOL);
130 1.3 xtraeme }
131 1.3 xtraeme
132 1.1 xtraeme /*
133 1.1 xtraeme * sme_event_register:
134 1.1 xtraeme *
135 1.24 xtraeme * + Registers a new sysmon envsys event or updates any event
136 1.24 xtraeme * already in the queue.
137 1.1 xtraeme */
138 1.1 xtraeme int
139 1.24 xtraeme sme_event_register(prop_dictionary_t sdict, envsys_data_t *edata,
140 1.24 xtraeme const char *drvn, const char *objkey,
141 1.24 xtraeme int32_t critval, int crittype, int powertype)
142 1.1 xtraeme {
143 1.24 xtraeme sme_event_t *see = NULL;
144 1.24 xtraeme prop_object_t obj;
145 1.24 xtraeme bool critvalup = false;
146 1.1 xtraeme int error = 0;
147 1.1 xtraeme
148 1.24 xtraeme KASSERT(sdict != NULL || edata != NULL);
149 1.1 xtraeme
150 1.31 xtraeme mutex_enter(&sme_mtx);
151 1.1 xtraeme /*
152 1.24 xtraeme * check if the event is already on the list and return
153 1.24 xtraeme * EEXIST if value provided hasn't been changed.
154 1.1 xtraeme */
155 1.24 xtraeme LIST_FOREACH(see, &sme_events_list, see_list) {
156 1.24 xtraeme if (strcmp(edata->desc, see->pes.pes_sensname) == 0)
157 1.24 xtraeme if (crittype == see->type) {
158 1.24 xtraeme if (see->critval == critval) {
159 1.24 xtraeme DPRINTF(("%s: dev=%s sensor=%s type=%d "
160 1.24 xtraeme "(already exists)\n", __func__,
161 1.24 xtraeme see->pes.pes_dvname,
162 1.24 xtraeme see->pes.pes_sensname, see->type));
163 1.31 xtraeme mutex_exit(&sme_mtx);
164 1.24 xtraeme return EEXIST;
165 1.24 xtraeme }
166 1.24 xtraeme critvalup = true;
167 1.24 xtraeme break;
168 1.1 xtraeme }
169 1.24 xtraeme }
170 1.24 xtraeme
171 1.24 xtraeme /*
172 1.24 xtraeme * Critical condition operation requested by userland.
173 1.24 xtraeme */
174 1.24 xtraeme if (objkey && critval && critvalup) {
175 1.24 xtraeme obj = prop_dictionary_get(sdict, objkey);
176 1.36 xtraeme if (obj) {
177 1.24 xtraeme /*
178 1.24 xtraeme * object is already in dictionary and value
179 1.24 xtraeme * provided is not the same than we have
180 1.24 xtraeme * currently, update the critical value.
181 1.24 xtraeme */
182 1.24 xtraeme see->critval = critval;
183 1.24 xtraeme DPRINTF(("%s: sensor=%s type=%d (critval updated)\n",
184 1.24 xtraeme __func__, edata->desc, see->type));
185 1.24 xtraeme error = sme_sensor_upint32(sdict, objkey, critval);
186 1.31 xtraeme mutex_exit(&sme_mtx);
187 1.24 xtraeme return error;
188 1.1 xtraeme }
189 1.1 xtraeme }
190 1.1 xtraeme
191 1.24 xtraeme /*
192 1.24 xtraeme * The event is not in on the list or in a dictionary, create a new
193 1.24 xtraeme * sme event, assign required members and update the object in
194 1.24 xtraeme * the dictionary.
195 1.24 xtraeme */
196 1.24 xtraeme see = NULL;
197 1.24 xtraeme see = kmem_zalloc(sizeof(*see), KM_NOSLEEP);
198 1.24 xtraeme if (see == NULL) {
199 1.31 xtraeme mutex_exit(&sme_mtx);
200 1.24 xtraeme return ENOMEM;
201 1.24 xtraeme }
202 1.24 xtraeme
203 1.24 xtraeme see->critval = critval;
204 1.24 xtraeme see->type = crittype;
205 1.24 xtraeme (void)strlcpy(see->pes.pes_dvname, drvn,
206 1.24 xtraeme sizeof(see->pes.pes_dvname));
207 1.24 xtraeme see->pes.pes_type = powertype;
208 1.24 xtraeme (void)strlcpy(see->pes.pes_sensname, edata->desc,
209 1.24 xtraeme sizeof(see->pes.pes_sensname));
210 1.24 xtraeme see->snum = edata->sensor;
211 1.24 xtraeme
212 1.27 xtraeme LIST_INSERT_HEAD(&sme_events_list, see, see_list);
213 1.27 xtraeme if (objkey && critval) {
214 1.27 xtraeme error = sme_sensor_upint32(sdict, objkey, critval);
215 1.27 xtraeme if (error) {
216 1.31 xtraeme mutex_exit(&sme_mtx);
217 1.27 xtraeme goto out;
218 1.27 xtraeme }
219 1.27 xtraeme }
220 1.24 xtraeme DPRINTF(("%s: registering dev=%s sensor=%s snum=%d type=%d "
221 1.1 xtraeme "critval=%" PRIu32 "\n", __func__,
222 1.1 xtraeme see->pes.pes_dvname, see->pes.pes_sensname,
223 1.1 xtraeme see->snum, see->type, see->critval));
224 1.1 xtraeme /*
225 1.1 xtraeme * Initialize the events framework if it wasn't initialized
226 1.1 xtraeme * before.
227 1.1 xtraeme */
228 1.1 xtraeme mutex_enter(&sme_event_init_mtx);
229 1.31 xtraeme mutex_exit(&sme_mtx);
230 1.1 xtraeme if (sme_events_initialized == false)
231 1.1 xtraeme error = sme_events_init();
232 1.1 xtraeme mutex_exit(&sme_event_init_mtx);
233 1.27 xtraeme out:
234 1.24 xtraeme if (error)
235 1.24 xtraeme kmem_free(see, sizeof(*see));
236 1.1 xtraeme return error;
237 1.1 xtraeme }
238 1.1 xtraeme
239 1.1 xtraeme /*
240 1.18 xtraeme * sme_event_unregister_all:
241 1.18 xtraeme *
242 1.18 xtraeme * + Unregisters all sysmon envsys events associated with a
243 1.18 xtraeme * sysmon envsys device.
244 1.18 xtraeme */
245 1.18 xtraeme void
246 1.25 xtraeme sme_event_unregister_all(const char *sme_name)
247 1.18 xtraeme {
248 1.18 xtraeme sme_event_t *see;
249 1.18 xtraeme int evcounter = 0;
250 1.18 xtraeme
251 1.31 xtraeme KASSERT(mutex_owned(&sme_mtx));
252 1.25 xtraeme KASSERT(sme_name != NULL);
253 1.18 xtraeme
254 1.18 xtraeme LIST_FOREACH(see, &sme_events_list, see_list) {
255 1.25 xtraeme if (strcmp(see->pes.pes_dvname, sme_name) == 0)
256 1.18 xtraeme evcounter++;
257 1.18 xtraeme }
258 1.18 xtraeme
259 1.18 xtraeme DPRINTF(("%s: total events %d (%s)\n", __func__,
260 1.25 xtraeme evcounter, sme_name));
261 1.18 xtraeme
262 1.36 xtraeme while ((see = LIST_FIRST(&sme_events_list))) {
263 1.18 xtraeme if (evcounter == 0)
264 1.18 xtraeme break;
265 1.18 xtraeme
266 1.25 xtraeme if (strcmp(see->pes.pes_dvname, sme_name) == 0) {
267 1.18 xtraeme DPRINTF(("%s: event %s %d removed (%s)\n", __func__,
268 1.25 xtraeme see->pes.pes_sensname, see->type, sme_name));
269 1.18 xtraeme
270 1.18 xtraeme while (see->see_flags & SME_EVENT_WORKING)
271 1.33 xtraeme cv_wait(&sme_cv, &sme_mtx);
272 1.18 xtraeme
273 1.18 xtraeme LIST_REMOVE(see, see_list);
274 1.18 xtraeme kmem_free(see, sizeof(*see));
275 1.18 xtraeme evcounter--;
276 1.18 xtraeme }
277 1.18 xtraeme }
278 1.18 xtraeme
279 1.20 xtraeme if (LIST_EMPTY(&sme_events_list)) {
280 1.21 xtraeme mutex_enter(&sme_event_init_mtx);
281 1.29 xtraeme if (sme_events_initialized)
282 1.29 xtraeme sme_events_destroy();
283 1.21 xtraeme mutex_exit(&sme_event_init_mtx);
284 1.20 xtraeme }
285 1.18 xtraeme }
286 1.18 xtraeme
287 1.18 xtraeme /*
288 1.1 xtraeme * sme_event_unregister:
289 1.1 xtraeme *
290 1.1 xtraeme * + Unregisters a sysmon envsys event.
291 1.1 xtraeme */
292 1.1 xtraeme int
293 1.1 xtraeme sme_event_unregister(const char *sensor, int type)
294 1.1 xtraeme {
295 1.1 xtraeme sme_event_t *see;
296 1.1 xtraeme bool found = false;
297 1.1 xtraeme
298 1.36 xtraeme KASSERT(mutex_owned(&sme_mtx));
299 1.1 xtraeme KASSERT(sensor != NULL);
300 1.1 xtraeme
301 1.1 xtraeme LIST_FOREACH(see, &sme_events_list, see_list) {
302 1.1 xtraeme if (strcmp(see->pes.pes_sensname, sensor) == 0) {
303 1.1 xtraeme if (see->type == type) {
304 1.1 xtraeme found = true;
305 1.1 xtraeme break;
306 1.1 xtraeme }
307 1.1 xtraeme }
308 1.1 xtraeme }
309 1.1 xtraeme
310 1.36 xtraeme if (!found)
311 1.1 xtraeme return EINVAL;
312 1.1 xtraeme
313 1.15 xtraeme while (see->see_flags & SME_EVENT_WORKING)
314 1.33 xtraeme cv_wait(&sme_cv, &sme_mtx);
315 1.15 xtraeme
316 1.1 xtraeme DPRINTF(("%s: removing dev=%s sensor=%s type=%d\n",
317 1.1 xtraeme __func__, see->pes.pes_dvname, sensor, type));
318 1.1 xtraeme LIST_REMOVE(see, see_list);
319 1.1 xtraeme /*
320 1.1 xtraeme * So the events list is empty, we'll do the following:
321 1.1 xtraeme *
322 1.9 xtraeme * - stop and destroy the callout.
323 1.1 xtraeme * - destroy the workqueue.
324 1.1 xtraeme */
325 1.20 xtraeme if (LIST_EMPTY(&sme_events_list)) {
326 1.21 xtraeme mutex_enter(&sme_event_init_mtx);
327 1.18 xtraeme sme_events_destroy();
328 1.21 xtraeme mutex_exit(&sme_event_init_mtx);
329 1.20 xtraeme }
330 1.1 xtraeme
331 1.20 xtraeme kmem_free(see, sizeof(*see));
332 1.1 xtraeme return 0;
333 1.1 xtraeme }
334 1.1 xtraeme
335 1.1 xtraeme /*
336 1.1 xtraeme * sme_event_drvadd:
337 1.1 xtraeme *
338 1.1 xtraeme * + Adds a new sysmon envsys event for a driver if a sensor
339 1.1 xtraeme * has set any accepted monitoring flag.
340 1.1 xtraeme */
341 1.1 xtraeme void
342 1.1 xtraeme sme_event_drvadd(void *arg)
343 1.1 xtraeme {
344 1.1 xtraeme sme_event_drv_t *sed_t = arg;
345 1.2 xtraeme int error = 0;
346 1.1 xtraeme
347 1.1 xtraeme KASSERT(sed_t != NULL);
348 1.1 xtraeme
349 1.1 xtraeme #define SEE_REGEVENT(a, b, c) \
350 1.1 xtraeme do { \
351 1.1 xtraeme if (sed_t->edata->flags & (a)) { \
352 1.36 xtraeme char str[ENVSYS_DESCLEN] = "monitoring-state-"; \
353 1.1 xtraeme \
354 1.24 xtraeme error = sme_event_register(sed_t->sdict, \
355 1.2 xtraeme sed_t->edata, \
356 1.2 xtraeme sed_t->sme->sme_name, \
357 1.2 xtraeme NULL, \
358 1.2 xtraeme 0, \
359 1.2 xtraeme (b), \
360 1.2 xtraeme sed_t->powertype); \
361 1.2 xtraeme if (error && error != EEXIST) \
362 1.2 xtraeme printf("%s: failed to add event! " \
363 1.2 xtraeme "error=%d sensor=%s event=%s\n", \
364 1.2 xtraeme __func__, error, sed_t->edata->desc, (c)); \
365 1.2 xtraeme else { \
366 1.2 xtraeme (void)strlcat(str, (c), sizeof(str)); \
367 1.2 xtraeme prop_dictionary_set_bool(sed_t->sdict, \
368 1.2 xtraeme str, \
369 1.2 xtraeme true); \
370 1.2 xtraeme } \
371 1.1 xtraeme } \
372 1.1 xtraeme } while (/* CONSTCOND */ 0)
373 1.1 xtraeme
374 1.1 xtraeme SEE_REGEVENT(ENVSYS_FMONCRITICAL,
375 1.1 xtraeme PENVSYS_EVENT_CRITICAL,
376 1.1 xtraeme "critical");
377 1.1 xtraeme
378 1.1 xtraeme SEE_REGEVENT(ENVSYS_FMONCRITUNDER,
379 1.1 xtraeme PENVSYS_EVENT_CRITUNDER,
380 1.1 xtraeme "critunder");
381 1.1 xtraeme
382 1.1 xtraeme SEE_REGEVENT(ENVSYS_FMONCRITOVER,
383 1.1 xtraeme PENVSYS_EVENT_CRITOVER,
384 1.1 xtraeme "critover");
385 1.1 xtraeme
386 1.1 xtraeme SEE_REGEVENT(ENVSYS_FMONWARNUNDER,
387 1.1 xtraeme PENVSYS_EVENT_WARNUNDER,
388 1.1 xtraeme "warnunder");
389 1.1 xtraeme
390 1.1 xtraeme SEE_REGEVENT(ENVSYS_FMONWARNOVER,
391 1.1 xtraeme PENVSYS_EVENT_WARNOVER,
392 1.1 xtraeme "warnover");
393 1.1 xtraeme
394 1.28 xtraeme SEE_REGEVENT(ENVSYS_FMONSTCHANGED,
395 1.28 xtraeme PENVSYS_EVENT_STATE_CHANGED,
396 1.28 xtraeme "state-changed");
397 1.1 xtraeme
398 1.1 xtraeme /* we are done, free memory now */
399 1.1 xtraeme kmem_free(sed_t, sizeof(*sed_t));
400 1.1 xtraeme }
401 1.1 xtraeme
402 1.1 xtraeme /*
403 1.1 xtraeme * sme_events_init:
404 1.1 xtraeme *
405 1.18 xtraeme * + Initializes the events framework.
406 1.1 xtraeme */
407 1.1 xtraeme int
408 1.1 xtraeme sme_events_init(void)
409 1.1 xtraeme {
410 1.1 xtraeme int error;
411 1.1 xtraeme
412 1.22 xtraeme KASSERT(mutex_owned(&sme_event_init_mtx));
413 1.22 xtraeme
414 1.1 xtraeme error = workqueue_create(&seewq, "envsysev",
415 1.40 xtraeme sme_events_worker, NULL, PRI_NONE, IPL_SOFTCLOCK, WQ_MPSAFE);
416 1.1 xtraeme if (error)
417 1.1 xtraeme goto out;
418 1.1 xtraeme
419 1.6 ad callout_init(&seeco, 0);
420 1.1 xtraeme callout_setfunc(&seeco, sme_events_check, NULL);
421 1.1 xtraeme callout_schedule(&seeco, SME_EVTIMO);
422 1.1 xtraeme sme_events_initialized = true;
423 1.1 xtraeme DPRINTF(("%s: events framework initialized\n", __func__));
424 1.1 xtraeme
425 1.1 xtraeme out:
426 1.1 xtraeme return error;
427 1.1 xtraeme }
428 1.1 xtraeme
429 1.1 xtraeme /*
430 1.18 xtraeme * sme_events_destroy:
431 1.18 xtraeme *
432 1.18 xtraeme * + Destroys the events framework: the workqueue and the
433 1.18 xtraeme * callout are stopped and destroyed because there are not
434 1.18 xtraeme * events in the queue.
435 1.18 xtraeme */
436 1.18 xtraeme void
437 1.18 xtraeme sme_events_destroy(void)
438 1.18 xtraeme {
439 1.22 xtraeme KASSERT(mutex_owned(&sme_event_init_mtx));
440 1.22 xtraeme
441 1.18 xtraeme callout_stop(&seeco);
442 1.18 xtraeme sme_events_initialized = false;
443 1.18 xtraeme DPRINTF(("%s: events framework destroyed\n", __func__));
444 1.20 xtraeme callout_destroy(&seeco);
445 1.20 xtraeme workqueue_destroy(seewq);
446 1.18 xtraeme }
447 1.18 xtraeme
448 1.18 xtraeme /*
449 1.1 xtraeme * sme_events_check:
450 1.1 xtraeme *
451 1.1 xtraeme * + Runs the work on each sysmon envsys event in our
452 1.1 xtraeme * workqueue periodically with callout.
453 1.1 xtraeme */
454 1.1 xtraeme void
455 1.1 xtraeme sme_events_check(void *arg)
456 1.1 xtraeme {
457 1.1 xtraeme sme_event_t *see;
458 1.1 xtraeme
459 1.1 xtraeme LIST_FOREACH(see, &sme_events_list, see_list) {
460 1.14 xtraeme DPRINTFOBJ(("%s: dev=%s sensor=%s type=%d\n",
461 1.1 xtraeme __func__,
462 1.1 xtraeme see->pes.pes_dvname,
463 1.1 xtraeme see->pes.pes_sensname,
464 1.1 xtraeme see->type));
465 1.8 rmind workqueue_enqueue(seewq, &see->see_wk, NULL);
466 1.1 xtraeme }
467 1.42 xtraeme /*
468 1.42 xtraeme * Now that the events list was checked, reset the refresh value.
469 1.42 xtraeme */
470 1.42 xtraeme LIST_FOREACH(see, &sme_events_list, see_list)
471 1.43 xtraeme see->see_flags &= ~SME_EVENT_REFRESHED;
472 1.42 xtraeme
473 1.38 xtraeme if (!sysmon_low_power)
474 1.38 xtraeme callout_schedule(&seeco, SME_EVTIMO);
475 1.1 xtraeme }
476 1.1 xtraeme
477 1.1 xtraeme /*
478 1.1 xtraeme * sme_events_worker:
479 1.1 xtraeme *
480 1.1 xtraeme * + workqueue thread that checks if there's a critical condition
481 1.1 xtraeme * and sends an event if the condition was triggered.
482 1.1 xtraeme */
483 1.1 xtraeme void
484 1.1 xtraeme sme_events_worker(struct work *wk, void *arg)
485 1.1 xtraeme {
486 1.28 xtraeme const struct sme_description_table *sdt = NULL;
487 1.10 xtraeme const struct sme_sensor_event *sse = sme_sensor_event;
488 1.1 xtraeme sme_event_t *see = (void *)wk;
489 1.1 xtraeme struct sysmon_envsys *sme;
490 1.1 xtraeme envsys_data_t *edata;
491 1.28 xtraeme int i, state, error;
492 1.1 xtraeme
493 1.1 xtraeme KASSERT(wk == &see->see_wk);
494 1.1 xtraeme
495 1.28 xtraeme state = error = 0;
496 1.28 xtraeme
497 1.31 xtraeme mutex_enter(&sme_mtx);
498 1.15 xtraeme see->see_flags |= SME_EVENT_WORKING;
499 1.15 xtraeme
500 1.1 xtraeme /*
501 1.1 xtraeme * We have to find the sme device by looking
502 1.1 xtraeme * at the power envsys device name.
503 1.1 xtraeme */
504 1.1 xtraeme LIST_FOREACH(sme, &sysmon_envsys_list, sme_list)
505 1.1 xtraeme if (strcmp(sme->sme_name, see->pes.pes_dvname) == 0)
506 1.1 xtraeme break;
507 1.36 xtraeme if (!sme)
508 1.30 xtraeme goto out;
509 1.1 xtraeme
510 1.13 xtraeme /* get the sensor with the index specified in see->snum */
511 1.13 xtraeme edata = &sme->sme_sensor_data[see->snum];
512 1.1 xtraeme
513 1.1 xtraeme /*
514 1.42 xtraeme * refresh the sensor that was marked with a critical event
515 1.42 xtraeme * only if it wasn't refreshed before or if the driver doesn't
516 1.42 xtraeme * use its own method for refreshing.
517 1.1 xtraeme */
518 1.1 xtraeme if ((sme->sme_flags & SME_DISABLE_GTREDATA) == 0) {
519 1.43 xtraeme if ((see->see_flags & SME_EVENT_REFRESHED) == 0) {
520 1.42 xtraeme error = (*sme->sme_gtredata)(sme, edata);
521 1.42 xtraeme if (error)
522 1.42 xtraeme goto out;
523 1.43 xtraeme see->see_flags |= SME_EVENT_REFRESHED;
524 1.42 xtraeme }
525 1.1 xtraeme }
526 1.1 xtraeme
527 1.18 xtraeme DPRINTFOBJ(("%s: desc=%s sensor=%d units=%d value_cur=%d\n",
528 1.1 xtraeme __func__, edata->desc, edata->sensor,
529 1.1 xtraeme edata->units, edata->value_cur));
530 1.1 xtraeme
531 1.10 xtraeme #define SME_SEND_NORMALEVENT() \
532 1.10 xtraeme do { \
533 1.10 xtraeme see->evsent = false; \
534 1.10 xtraeme sysmon_penvsys_event(&see->pes, PENVSYS_EVENT_NORMAL); \
535 1.10 xtraeme } while (/* CONSTCOND */ 0)
536 1.10 xtraeme
537 1.10 xtraeme #define SME_SEND_EVENT(type) \
538 1.1 xtraeme do { \
539 1.10 xtraeme see->evsent = true; \
540 1.10 xtraeme sysmon_penvsys_event(&see->pes, (type)); \
541 1.1 xtraeme } while (/* CONSTCOND */ 0)
542 1.1 xtraeme
543 1.38 xtraeme
544 1.1 xtraeme switch (see->type) {
545 1.10 xtraeme /*
546 1.10 xtraeme * if state is the same than the one that matches sse[i].state,
547 1.10 xtraeme * send the event...
548 1.10 xtraeme */
549 1.1 xtraeme case PENVSYS_EVENT_CRITICAL:
550 1.1 xtraeme case PENVSYS_EVENT_CRITUNDER:
551 1.1 xtraeme case PENVSYS_EVENT_CRITOVER:
552 1.10 xtraeme case PENVSYS_EVENT_WARNUNDER:
553 1.10 xtraeme case PENVSYS_EVENT_WARNOVER:
554 1.10 xtraeme for (i = 0; sse[i].state != -1; i++)
555 1.10 xtraeme if (sse[i].event == see->type)
556 1.10 xtraeme break;
557 1.1 xtraeme
558 1.10 xtraeme if (see->evsent && edata->state == ENVSYS_SVALID)
559 1.10 xtraeme SME_SEND_NORMALEVENT();
560 1.1 xtraeme
561 1.10 xtraeme if (!see->evsent && edata->state == sse[i].state)
562 1.10 xtraeme SME_SEND_EVENT(see->type);
563 1.1 xtraeme
564 1.1 xtraeme break;
565 1.10 xtraeme /*
566 1.10 xtraeme * if value_cur is lower than the limit, send the event...
567 1.10 xtraeme */
568 1.1 xtraeme case PENVSYS_EVENT_BATT_USERCAP:
569 1.10 xtraeme case PENVSYS_EVENT_USER_CRITMIN:
570 1.10 xtraeme if (see->evsent && edata->value_cur > see->critval)
571 1.10 xtraeme SME_SEND_NORMALEVENT();
572 1.1 xtraeme
573 1.10 xtraeme if (!see->evsent && edata->value_cur < see->critval)
574 1.10 xtraeme SME_SEND_EVENT(see->type);
575 1.1 xtraeme
576 1.1 xtraeme break;
577 1.10 xtraeme /*
578 1.10 xtraeme * if value_cur is higher than the limit, send the event...
579 1.10 xtraeme */
580 1.1 xtraeme case PENVSYS_EVENT_USER_CRITMAX:
581 1.10 xtraeme if (see->evsent && edata->value_cur < see->critval)
582 1.10 xtraeme SME_SEND_NORMALEVENT();
583 1.1 xtraeme
584 1.10 xtraeme if (!see->evsent && edata->value_cur > see->critval)
585 1.10 xtraeme SME_SEND_EVENT(see->type);
586 1.1 xtraeme
587 1.1 xtraeme break;
588 1.10 xtraeme /*
589 1.28 xtraeme * if value_cur is not normal (battery) or online (drive),
590 1.28 xtraeme * send the event...
591 1.10 xtraeme */
592 1.28 xtraeme case PENVSYS_EVENT_STATE_CHANGED:
593 1.1 xtraeme /* the state has not been changed, just ignore the event */
594 1.1 xtraeme if (edata->value_cur == see->evsent)
595 1.1 xtraeme break;
596 1.1 xtraeme
597 1.28 xtraeme switch (edata->units) {
598 1.28 xtraeme case ENVSYS_DRIVE:
599 1.28 xtraeme sdt = sme_get_description_table(SME_DESC_DRIVE_STATES);
600 1.28 xtraeme state = ENVSYS_DRIVE_ONLINE;
601 1.28 xtraeme break;
602 1.44 xtraeme case ENVSYS_BATTERY_CAPACITY:
603 1.28 xtraeme sdt =
604 1.44 xtraeme sme_get_description_table(SME_DESC_BATTERY_CAPACITY);
605 1.44 xtraeme state = ENVSYS_BATTERY_CAPACITY_NORMAL;
606 1.28 xtraeme break;
607 1.34 xtraeme default:
608 1.35 xtraeme panic("%s: invalid units for ENVSYS_FMONSTCHANGED",
609 1.35 xtraeme __func__);
610 1.28 xtraeme }
611 1.28 xtraeme
612 1.28 xtraeme for (i = 0; sdt[i].type != -1; i++)
613 1.28 xtraeme if (sdt[i].type == edata->value_cur)
614 1.1 xtraeme break;
615 1.1 xtraeme
616 1.1 xtraeme /* copy current state description */
617 1.28 xtraeme (void)strlcpy(see->pes.pes_statedesc, sdt[i].desc,
618 1.1 xtraeme sizeof(see->pes.pes_statedesc));
619 1.1 xtraeme
620 1.1 xtraeme /* state is ok again... send a normal event */
621 1.28 xtraeme if (see->evsent && edata->value_cur == state)
622 1.10 xtraeme SME_SEND_NORMALEVENT();
623 1.1 xtraeme
624 1.28 xtraeme /* state has been changed... send event */
625 1.28 xtraeme if (see->evsent || edata->value_cur != state) {
626 1.1 xtraeme /* save current drive state */
627 1.1 xtraeme see->evsent = edata->value_cur;
628 1.10 xtraeme sysmon_penvsys_event(&see->pes, see->type);
629 1.1 xtraeme }
630 1.1 xtraeme
631 1.39 xtraeme /*
632 1.39 xtraeme * Check if the system is running in low power and send the
633 1.39 xtraeme * event to powerd (if running) or shutdown the system
634 1.39 xtraeme * otherwise.
635 1.39 xtraeme */
636 1.39 xtraeme if (!sysmon_low_power && sme_event_check_low_power()) {
637 1.39 xtraeme struct penvsys_state pes;
638 1.39 xtraeme
639 1.39 xtraeme pes.pes_type = PENVSYS_TYPE_BATTERY;
640 1.39 xtraeme sysmon_penvsys_event(&pes, PENVSYS_EVENT_LOW_POWER);
641 1.39 xtraeme sysmon_low_power = true;
642 1.39 xtraeme callout_stop(&seeco);
643 1.39 xtraeme }
644 1.39 xtraeme
645 1.1 xtraeme break;
646 1.1 xtraeme }
647 1.30 xtraeme out:
648 1.15 xtraeme see->see_flags &= ~SME_EVENT_WORKING;
649 1.33 xtraeme cv_broadcast(&sme_cv);
650 1.31 xtraeme mutex_exit(&sme_mtx);
651 1.1 xtraeme }
652 1.38 xtraeme
653 1.44 xtraeme static bool
654 1.38 xtraeme sme_event_check_low_power(void)
655 1.38 xtraeme {
656 1.38 xtraeme struct sysmon_envsys *sme;
657 1.38 xtraeme envsys_data_t *edata;
658 1.44 xtraeme int i;
659 1.44 xtraeme bool battery, batterycap, batterycharge;
660 1.38 xtraeme
661 1.44 xtraeme KASSERT(mutex_owned(&sme_mtx));
662 1.38 xtraeme
663 1.44 xtraeme battery = batterycap = batterycharge = false;
664 1.38 xtraeme
665 1.38 xtraeme LIST_FOREACH(sme, &sysmon_envsys_list, sme_list)
666 1.38 xtraeme if (sme->sme_class == SME_CLASS_ACADAPTER)
667 1.38 xtraeme break;
668 1.38 xtraeme
669 1.38 xtraeme /*
670 1.38 xtraeme * No AC Adapter devices were found, do nothing.
671 1.38 xtraeme */
672 1.38 xtraeme if (!sme)
673 1.44 xtraeme return false;
674 1.38 xtraeme
675 1.44 xtraeme /*
676 1.44 xtraeme * If there's an AC Adapter connected, there's no need
677 1.44 xtraeme * to continue...
678 1.44 xtraeme */
679 1.38 xtraeme for (i = 0; i < sme->sme_nsensors; i++) {
680 1.38 xtraeme edata = &sme->sme_sensor_data[i];
681 1.38 xtraeme if (edata->units == ENVSYS_INDICATOR) {
682 1.44 xtraeme if (edata->value_cur)
683 1.44 xtraeme return false;
684 1.38 xtraeme }
685 1.38 xtraeme }
686 1.44 xtraeme
687 1.38 xtraeme /*
688 1.44 xtraeme * Check for battery devices and its state.
689 1.38 xtraeme */
690 1.44 xtraeme LIST_FOREACH(sme, &sysmon_envsys_list, sme_list) {
691 1.44 xtraeme if (sme->sme_class != SME_CLASS_BATTERY)
692 1.44 xtraeme continue;
693 1.38 xtraeme
694 1.44 xtraeme /*
695 1.44 xtraeme * We've found a battery device...
696 1.44 xtraeme */
697 1.44 xtraeme battery = true;
698 1.44 xtraeme for (i = 0; i < sme->sme_nsensors; i++) {
699 1.44 xtraeme edata = &sme->sme_sensor_data[i];
700 1.44 xtraeme if (edata->units == ENVSYS_BATTERY_CAPACITY) {
701 1.44 xtraeme batterycap = true;
702 1.44 xtraeme if (!sme_battery_critical(edata))
703 1.44 xtraeme return false;
704 1.44 xtraeme } else if (edata->units == ENVSYS_BATTERY_CHARGE) {
705 1.44 xtraeme batterycharge = true;
706 1.44 xtraeme if (edata->value_cur)
707 1.44 xtraeme return false;
708 1.38 xtraeme }
709 1.38 xtraeme }
710 1.38 xtraeme }
711 1.44 xtraeme if (!battery || !batterycap || !batterycharge)
712 1.44 xtraeme return false;
713 1.38 xtraeme
714 1.38 xtraeme /*
715 1.44 xtraeme * All batteries in low/critical capacity and discharging.
716 1.38 xtraeme */
717 1.44 xtraeme return true;
718 1.44 xtraeme }
719 1.38 xtraeme
720 1.44 xtraeme static bool
721 1.44 xtraeme sme_battery_critical(envsys_data_t *edata)
722 1.44 xtraeme {
723 1.44 xtraeme if (edata->value_cur == ENVSYS_BATTERY_CAPACITY_CRITICAL ||
724 1.44 xtraeme edata->value_cur == ENVSYS_BATTERY_CAPACITY_LOW)
725 1.44 xtraeme return true;
726 1.44 xtraeme
727 1.44 xtraeme return false;
728 1.38 xtraeme }
729