sysmon_envsys_events.c revision 1.57 1 1.57 pgoyette /* $NetBSD: sysmon_envsys_events.c,v 1.57 2008/09/04 21:54:51 pgoyette Exp $ */
2 1.1 xtraeme
3 1.1 xtraeme /*-
4 1.51 xtraeme * Copyright (c) 2007, 2008 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.57 pgoyette __KERNEL_RCSID(0, "$NetBSD: sysmon_envsys_events.c,v 1.57 2008/09/04 21:54:51 pgoyette 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.1 xtraeme #include <sys/systm.h>
41 1.1 xtraeme #include <sys/proc.h>
42 1.1 xtraeme #include <sys/mutex.h>
43 1.1 xtraeme #include <sys/kmem.h>
44 1.1 xtraeme #include <sys/callout.h>
45 1.1 xtraeme
46 1.32 xtraeme /* #define ENVSYS_DEBUG */
47 1.56 pgoyette
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.51 xtraeme static bool sysmon_low_power;
67 1.1 xtraeme
68 1.45 xtraeme #define SME_EVTIMO (SME_EVENTS_DEFTIMEOUT * hz)
69 1.3 xtraeme
70 1.44 xtraeme static bool sme_event_check_low_power(void);
71 1.47 xtraeme static bool sme_battery_check(void);
72 1.44 xtraeme static bool sme_battery_critical(envsys_data_t *);
73 1.47 xtraeme static bool sme_acadapter_check(void);
74 1.38 xtraeme
75 1.3 xtraeme /*
76 1.1 xtraeme * sme_event_register:
77 1.1 xtraeme *
78 1.24 xtraeme * + Registers a new sysmon envsys event or updates any event
79 1.24 xtraeme * already in the queue.
80 1.1 xtraeme */
81 1.1 xtraeme int
82 1.24 xtraeme sme_event_register(prop_dictionary_t sdict, envsys_data_t *edata,
83 1.45 xtraeme struct sysmon_envsys *sme, const char *objkey,
84 1.24 xtraeme int32_t critval, int crittype, int powertype)
85 1.1 xtraeme {
86 1.51 xtraeme sme_event_t *see = NULL, *osee = NULL;
87 1.24 xtraeme prop_object_t obj;
88 1.24 xtraeme bool critvalup = false;
89 1.1 xtraeme int error = 0;
90 1.56 pgoyette int real_crittype;
91 1.56 pgoyette int32_t o_critval;
92 1.1 xtraeme
93 1.45 xtraeme KASSERT(sdict != NULL || edata != NULL || sme != NULL);
94 1.51 xtraeme /*
95 1.51 xtraeme * Allocate a new sysmon_envsys event.
96 1.51 xtraeme */
97 1.51 xtraeme see = kmem_zalloc(sizeof(*see), KM_SLEEP);
98 1.51 xtraeme if (see == NULL)
99 1.51 xtraeme return ENOMEM;
100 1.1 xtraeme
101 1.56 pgoyette /*
102 1.56 pgoyette * Map user-types to kernel types
103 1.56 pgoyette */
104 1.56 pgoyette switch (crittype) {
105 1.56 pgoyette case PENVSYS_EVENT_USER_CRITMAX:
106 1.56 pgoyette case PENVSYS_EVENT_USER_CRITMIN:
107 1.56 pgoyette case PENVSYS_EVENT_USER_WARNMAX:
108 1.56 pgoyette case PENVSYS_EVENT_USER_WARNMIN:
109 1.56 pgoyette real_crittype = PENVSYS_EVENT_USER_LIMITS;
110 1.56 pgoyette break;
111 1.56 pgoyette case PENVSYS_EVENT_BATT_USERCAP:
112 1.56 pgoyette case PENVSYS_EVENT_BATT_USERWARN:
113 1.56 pgoyette real_crittype = PENVSYS_EVENT_BATT_USER_LIMITS;
114 1.56 pgoyette break;
115 1.56 pgoyette default:
116 1.56 pgoyette real_crittype = crittype;
117 1.56 pgoyette }
118 1.56 pgoyette
119 1.1 xtraeme /*
120 1.24 xtraeme * check if the event is already on the list and return
121 1.24 xtraeme * EEXIST if value provided hasn't been changed.
122 1.1 xtraeme */
123 1.51 xtraeme mutex_enter(&sme->sme_mtx);
124 1.51 xtraeme LIST_FOREACH(osee, &sme->sme_events_list, see_list) {
125 1.51 xtraeme if (strcmp(edata->desc, osee->see_pes.pes_sensname) == 0)
126 1.56 pgoyette if (real_crittype == osee->see_type) {
127 1.56 pgoyette switch (crittype) {
128 1.56 pgoyette case PENVSYS_EVENT_USER_CRITMAX:
129 1.56 pgoyette case PENVSYS_EVENT_BATT_USERCAP:
130 1.56 pgoyette o_critval = osee->see_critmax;
131 1.56 pgoyette break;
132 1.56 pgoyette case PENVSYS_EVENT_USER_WARNMAX:
133 1.56 pgoyette case PENVSYS_EVENT_BATT_USERWARN:
134 1.56 pgoyette o_critval = osee->see_warnmax;
135 1.56 pgoyette break;
136 1.56 pgoyette case PENVSYS_EVENT_USER_WARNMIN:
137 1.56 pgoyette o_critval = osee->see_warnmin;
138 1.56 pgoyette break;
139 1.56 pgoyette case PENVSYS_EVENT_USER_CRITMIN:
140 1.56 pgoyette default:
141 1.56 pgoyette o_critval = osee->see_critmin;
142 1.56 pgoyette break;
143 1.56 pgoyette }
144 1.56 pgoyette if (o_critval == critval) {
145 1.24 xtraeme DPRINTF(("%s: dev=%s sensor=%s type=%d "
146 1.24 xtraeme "(already exists)\n", __func__,
147 1.51 xtraeme osee->see_pes.pes_dvname,
148 1.51 xtraeme osee->see_pes.pes_sensname,
149 1.51 xtraeme osee->see_type));
150 1.52 rmind error = EEXIST;
151 1.52 rmind goto out;
152 1.24 xtraeme }
153 1.24 xtraeme critvalup = true;
154 1.24 xtraeme break;
155 1.1 xtraeme }
156 1.24 xtraeme }
157 1.24 xtraeme
158 1.24 xtraeme /*
159 1.24 xtraeme * Critical condition operation requested by userland.
160 1.24 xtraeme */
161 1.24 xtraeme if (objkey && critval && critvalup) {
162 1.24 xtraeme obj = prop_dictionary_get(sdict, objkey);
163 1.45 xtraeme if (obj && prop_object_type(obj) == PROP_TYPE_NUMBER) {
164 1.24 xtraeme /*
165 1.24 xtraeme * object is already in dictionary and value
166 1.24 xtraeme * provided is not the same than we have
167 1.51 xtraeme * currently, update the critical value.
168 1.24 xtraeme */
169 1.56 pgoyette switch (crittype) {
170 1.56 pgoyette case PENVSYS_EVENT_USER_CRITMAX:
171 1.56 pgoyette case PENVSYS_EVENT_BATT_USERCAP:
172 1.56 pgoyette osee->see_critmax = critval;
173 1.56 pgoyette break;
174 1.56 pgoyette case PENVSYS_EVENT_USER_WARNMAX:
175 1.56 pgoyette case PENVSYS_EVENT_BATT_USERWARN:
176 1.56 pgoyette osee->see_warnmax = critval;
177 1.56 pgoyette break;
178 1.56 pgoyette case PENVSYS_EVENT_USER_WARNMIN:
179 1.56 pgoyette osee->see_warnmin = critval;
180 1.56 pgoyette break;
181 1.56 pgoyette case PENVSYS_EVENT_USER_CRITMIN:
182 1.56 pgoyette default:
183 1.56 pgoyette osee->see_critmin = critval;
184 1.56 pgoyette break;
185 1.56 pgoyette }
186 1.51 xtraeme DPRINTF(("%s: (%s) event [sensor=%s type=%d] "
187 1.45 xtraeme "(critval updated)\n", __func__, sme->sme_name,
188 1.51 xtraeme edata->desc, osee->see_type));
189 1.24 xtraeme error = sme_sensor_upint32(sdict, objkey, critval);
190 1.52 rmind goto out;
191 1.1 xtraeme }
192 1.1 xtraeme }
193 1.1 xtraeme
194 1.51 xtraeme /*
195 1.56 pgoyette * New limit defined for existing event
196 1.56 pgoyette */
197 1.56 pgoyette if (osee != NULL) {
198 1.56 pgoyette osee->see_edata = edata;
199 1.56 pgoyette switch (crittype) {
200 1.56 pgoyette case PENVSYS_EVENT_USER_CRITMAX:
201 1.56 pgoyette case PENVSYS_EVENT_BATT_USERCAP:
202 1.56 pgoyette osee->see_critmax = critval;
203 1.56 pgoyette break;
204 1.56 pgoyette case PENVSYS_EVENT_USER_WARNMAX:
205 1.56 pgoyette case PENVSYS_EVENT_BATT_USERWARN:
206 1.56 pgoyette osee->see_warnmax = critval;
207 1.56 pgoyette break;
208 1.56 pgoyette case PENVSYS_EVENT_USER_WARNMIN:
209 1.56 pgoyette osee->see_warnmin = critval;
210 1.56 pgoyette break;
211 1.56 pgoyette case PENVSYS_EVENT_USER_CRITMIN:
212 1.56 pgoyette default:
213 1.56 pgoyette osee->see_critmin = critval;
214 1.56 pgoyette break;
215 1.56 pgoyette }
216 1.56 pgoyette if (objkey && critval) {
217 1.56 pgoyette error = sme_sensor_upint32(sdict, objkey, critval);
218 1.56 pgoyette if (error)
219 1.56 pgoyette goto out;
220 1.56 pgoyette }
221 1.56 pgoyette DPRINTF(("%s: (%s) new limit added to existing event, type %d "
222 1.56 pgoyette "critmin=%" PRIu32 " warnmin=%" PRIu32 " warnmax=%"
223 1.56 pgoyette PRIu32 " critmax=%d\n", __func__, osee->see_sme->sme_name,
224 1.56 pgoyette osee->see_type, osee->see_critmin, osee->see_warnmin,
225 1.56 pgoyette osee->see_warnmax, osee->see_critmax));
226 1.56 pgoyette goto out;
227 1.56 pgoyette }
228 1.56 pgoyette /*
229 1.51 xtraeme * New event requested.
230 1.24 xtraeme */
231 1.45 xtraeme see->see_edata = edata;
232 1.56 pgoyette switch (crittype) {
233 1.56 pgoyette case PENVSYS_EVENT_USER_CRITMAX:
234 1.56 pgoyette case PENVSYS_EVENT_BATT_USERCAP:
235 1.56 pgoyette see->see_critmax = critval;
236 1.56 pgoyette break;
237 1.56 pgoyette case PENVSYS_EVENT_USER_WARNMAX:
238 1.56 pgoyette case PENVSYS_EVENT_BATT_USERWARN:
239 1.56 pgoyette see->see_warnmax = critval;
240 1.56 pgoyette break;
241 1.56 pgoyette case PENVSYS_EVENT_USER_WARNMIN:
242 1.56 pgoyette see->see_warnmin = critval;
243 1.56 pgoyette break;
244 1.56 pgoyette case PENVSYS_EVENT_USER_CRITMIN:
245 1.56 pgoyette default:
246 1.56 pgoyette see->see_critmin = critval;
247 1.56 pgoyette break;
248 1.56 pgoyette }
249 1.56 pgoyette see->see_type = real_crittype;
250 1.45 xtraeme see->see_sme = sme;
251 1.57 pgoyette
252 1.57 pgoyette /* Initialize sensor type and previously-sent state */
253 1.57 pgoyette
254 1.57 pgoyette see->see_pes.pes_type = powertype;
255 1.57 pgoyette switch (powertype) {
256 1.57 pgoyette case PENVSYS_TYPE_BATTERY:
257 1.57 pgoyette see->see_evsent = ENVSYS_BATTERY_CAPACITY_NORMAL;
258 1.57 pgoyette break;
259 1.57 pgoyette case PENVSYS_TYPE_DRIVE:
260 1.57 pgoyette see->see_evsent = ENVSYS_DRIVE_EMPTY;
261 1.57 pgoyette break;
262 1.57 pgoyette case PENVSYS_TYPE_FAN:
263 1.57 pgoyette case PENVSYS_TYPE_INDICATOR:
264 1.57 pgoyette case PENVSYS_TYPE_TEMP:
265 1.57 pgoyette case PENVSYS_TYPE_POWER:
266 1.57 pgoyette case PENVSYS_TYPE_RESISTANCE:
267 1.57 pgoyette case PENVSYS_TYPE_VOLTAGE:
268 1.57 pgoyette see->see_evsent = ENVSYS_SVALID;
269 1.57 pgoyette break;
270 1.57 pgoyette default:
271 1.57 pgoyette see->see_evsent = 0;
272 1.57 pgoyette }
273 1.57 pgoyette
274 1.45 xtraeme (void)strlcpy(see->see_pes.pes_dvname, sme->sme_name,
275 1.45 xtraeme sizeof(see->see_pes.pes_dvname));
276 1.45 xtraeme (void)strlcpy(see->see_pes.pes_sensname, edata->desc,
277 1.45 xtraeme sizeof(see->see_pes.pes_sensname));
278 1.24 xtraeme
279 1.45 xtraeme LIST_INSERT_HEAD(&sme->sme_events_list, see, see_list);
280 1.27 xtraeme if (objkey && critval) {
281 1.27 xtraeme error = sme_sensor_upint32(sdict, objkey, critval);
282 1.45 xtraeme if (error)
283 1.27 xtraeme goto out;
284 1.27 xtraeme }
285 1.51 xtraeme DPRINTF(("%s: (%s) event registered (sensor=%s snum=%d type=%d "
286 1.56 pgoyette "critmin=%" PRIu32 " warnmin=%" PRIu32 " warnmax=%" PRIu32
287 1.56 pgoyette " crixmax=%" PRIu32 ")\n", __func__,
288 1.45 xtraeme see->see_sme->sme_name, see->see_pes.pes_sensname,
289 1.56 pgoyette see->see_edata->sensor, see->see_type, see->see_critmin,
290 1.56 pgoyette see->see_warnmin, see->see_warnmax, see->see_critmax));
291 1.1 xtraeme /*
292 1.45 xtraeme * Initialize the events framework if it wasn't initialized before.
293 1.1 xtraeme */
294 1.45 xtraeme if ((sme->sme_flags & SME_CALLOUT_INITIALIZED) == 0)
295 1.45 xtraeme error = sme_events_init(sme);
296 1.27 xtraeme out:
297 1.51 xtraeme mutex_exit(&sme->sme_mtx);
298 1.53 xtraeme if (error || critvalup)
299 1.24 xtraeme kmem_free(see, sizeof(*see));
300 1.1 xtraeme return error;
301 1.1 xtraeme }
302 1.1 xtraeme
303 1.1 xtraeme /*
304 1.18 xtraeme * sme_event_unregister_all:
305 1.18 xtraeme *
306 1.51 xtraeme * + Unregisters all events associated with a sysmon envsys device.
307 1.18 xtraeme */
308 1.18 xtraeme void
309 1.45 xtraeme sme_event_unregister_all(struct sysmon_envsys *sme)
310 1.18 xtraeme {
311 1.18 xtraeme sme_event_t *see;
312 1.18 xtraeme int evcounter = 0;
313 1.18 xtraeme
314 1.45 xtraeme KASSERT(sme != NULL);
315 1.18 xtraeme
316 1.51 xtraeme mutex_enter(&sme->sme_mtx);
317 1.45 xtraeme LIST_FOREACH(see, &sme->sme_events_list, see_list) {
318 1.56 pgoyette while (see->see_flags & SEE_EVENT_WORKING)
319 1.51 xtraeme cv_wait(&sme->sme_condvar, &sme->sme_mtx);
320 1.51 xtraeme
321 1.45 xtraeme if (strcmp(see->see_pes.pes_dvname, sme->sme_name) == 0)
322 1.18 xtraeme evcounter++;
323 1.18 xtraeme }
324 1.18 xtraeme
325 1.18 xtraeme DPRINTF(("%s: total events %d (%s)\n", __func__,
326 1.45 xtraeme evcounter, sme->sme_name));
327 1.18 xtraeme
328 1.45 xtraeme while ((see = LIST_FIRST(&sme->sme_events_list))) {
329 1.18 xtraeme if (evcounter == 0)
330 1.18 xtraeme break;
331 1.18 xtraeme
332 1.45 xtraeme if (strcmp(see->see_pes.pes_dvname, sme->sme_name) == 0) {
333 1.51 xtraeme LIST_REMOVE(see, see_list);
334 1.18 xtraeme DPRINTF(("%s: event %s %d removed (%s)\n", __func__,
335 1.45 xtraeme see->see_pes.pes_sensname, see->see_type,
336 1.45 xtraeme sme->sme_name));
337 1.18 xtraeme kmem_free(see, sizeof(*see));
338 1.18 xtraeme evcounter--;
339 1.18 xtraeme }
340 1.18 xtraeme }
341 1.18 xtraeme
342 1.51 xtraeme if (LIST_EMPTY(&sme->sme_events_list))
343 1.45 xtraeme if (sme->sme_flags & SME_CALLOUT_INITIALIZED)
344 1.45 xtraeme sme_events_destroy(sme);
345 1.51 xtraeme mutex_exit(&sme->sme_mtx);
346 1.18 xtraeme }
347 1.18 xtraeme
348 1.18 xtraeme /*
349 1.1 xtraeme * sme_event_unregister:
350 1.1 xtraeme *
351 1.45 xtraeme * + Unregisters an event from the specified sysmon envsys device.
352 1.1 xtraeme */
353 1.1 xtraeme int
354 1.45 xtraeme sme_event_unregister(struct sysmon_envsys *sme, const char *sensor, int type)
355 1.1 xtraeme {
356 1.1 xtraeme sme_event_t *see;
357 1.1 xtraeme bool found = false;
358 1.1 xtraeme
359 1.1 xtraeme KASSERT(sensor != NULL);
360 1.1 xtraeme
361 1.51 xtraeme mutex_enter(&sme->sme_mtx);
362 1.45 xtraeme LIST_FOREACH(see, &sme->sme_events_list, see_list) {
363 1.45 xtraeme if (strcmp(see->see_pes.pes_sensname, sensor) == 0) {
364 1.45 xtraeme if (see->see_type == type) {
365 1.1 xtraeme found = true;
366 1.1 xtraeme break;
367 1.1 xtraeme }
368 1.1 xtraeme }
369 1.1 xtraeme }
370 1.1 xtraeme
371 1.51 xtraeme if (!found) {
372 1.51 xtraeme mutex_exit(&sme->sme_mtx);
373 1.1 xtraeme return EINVAL;
374 1.51 xtraeme }
375 1.1 xtraeme
376 1.51 xtraeme /*
377 1.51 xtraeme * Wait for the event to finish its work, remove from the list
378 1.51 xtraeme * and release resouces.
379 1.51 xtraeme */
380 1.56 pgoyette while (see->see_flags & SEE_EVENT_WORKING)
381 1.51 xtraeme cv_wait(&sme->sme_condvar, &sme->sme_mtx);
382 1.15 xtraeme
383 1.51 xtraeme DPRINTF(("%s: removed dev=%s sensor=%s type=%d\n",
384 1.45 xtraeme __func__, see->see_pes.pes_dvname, sensor, type));
385 1.1 xtraeme LIST_REMOVE(see, see_list);
386 1.1 xtraeme /*
387 1.1 xtraeme * So the events list is empty, we'll do the following:
388 1.1 xtraeme *
389 1.9 xtraeme * - stop and destroy the callout.
390 1.1 xtraeme * - destroy the workqueue.
391 1.1 xtraeme */
392 1.51 xtraeme if (LIST_EMPTY(&sme->sme_events_list))
393 1.45 xtraeme sme_events_destroy(sme);
394 1.51 xtraeme mutex_exit(&sme->sme_mtx);
395 1.1 xtraeme
396 1.20 xtraeme kmem_free(see, sizeof(*see));
397 1.1 xtraeme return 0;
398 1.1 xtraeme }
399 1.1 xtraeme
400 1.1 xtraeme /*
401 1.1 xtraeme * sme_event_drvadd:
402 1.1 xtraeme *
403 1.45 xtraeme * + Registers a new event for a device that had enabled any of
404 1.45 xtraeme * the monitoring flags in the driver.
405 1.1 xtraeme */
406 1.1 xtraeme void
407 1.1 xtraeme sme_event_drvadd(void *arg)
408 1.1 xtraeme {
409 1.1 xtraeme sme_event_drv_t *sed_t = arg;
410 1.2 xtraeme int error = 0;
411 1.1 xtraeme
412 1.1 xtraeme KASSERT(sed_t != NULL);
413 1.1 xtraeme
414 1.1 xtraeme #define SEE_REGEVENT(a, b, c) \
415 1.1 xtraeme do { \
416 1.45 xtraeme if (sed_t->sed_edata->flags & (a)) { \
417 1.36 xtraeme char str[ENVSYS_DESCLEN] = "monitoring-state-"; \
418 1.1 xtraeme \
419 1.45 xtraeme error = sme_event_register(sed_t->sed_sdict, \
420 1.45 xtraeme sed_t->sed_edata, \
421 1.45 xtraeme sed_t->sed_sme, \
422 1.2 xtraeme NULL, \
423 1.2 xtraeme 0, \
424 1.2 xtraeme (b), \
425 1.45 xtraeme sed_t->sed_powertype); \
426 1.2 xtraeme if (error && error != EEXIST) \
427 1.2 xtraeme printf("%s: failed to add event! " \
428 1.2 xtraeme "error=%d sensor=%s event=%s\n", \
429 1.45 xtraeme __func__, error, \
430 1.45 xtraeme sed_t->sed_edata->desc, (c)); \
431 1.2 xtraeme else { \
432 1.2 xtraeme (void)strlcat(str, (c), sizeof(str)); \
433 1.45 xtraeme prop_dictionary_set_bool(sed_t->sed_sdict, \
434 1.2 xtraeme str, \
435 1.2 xtraeme true); \
436 1.2 xtraeme } \
437 1.1 xtraeme } \
438 1.1 xtraeme } while (/* CONSTCOND */ 0)
439 1.1 xtraeme
440 1.1 xtraeme SEE_REGEVENT(ENVSYS_FMONCRITICAL,
441 1.1 xtraeme PENVSYS_EVENT_CRITICAL,
442 1.1 xtraeme "critical");
443 1.1 xtraeme
444 1.56 pgoyette SEE_REGEVENT(ENVSYS_FMONCRITUNDER | ENVSYS_FMONCRITOVER |
445 1.56 pgoyette ENVSYS_FMONWARNUNDER | ENVSYS_FMONWARNOVER,
446 1.56 pgoyette PENVSYS_EVENT_HW_LIMITS,
447 1.56 pgoyette "hw-range-limits");
448 1.1 xtraeme
449 1.28 xtraeme SEE_REGEVENT(ENVSYS_FMONSTCHANGED,
450 1.28 xtraeme PENVSYS_EVENT_STATE_CHANGED,
451 1.28 xtraeme "state-changed");
452 1.1 xtraeme
453 1.45 xtraeme /*
454 1.45 xtraeme * we are done, free memory now.
455 1.45 xtraeme */
456 1.1 xtraeme kmem_free(sed_t, sizeof(*sed_t));
457 1.1 xtraeme }
458 1.1 xtraeme
459 1.1 xtraeme /*
460 1.1 xtraeme * sme_events_init:
461 1.1 xtraeme *
462 1.45 xtraeme * + Initialize the events framework for this device.
463 1.1 xtraeme */
464 1.1 xtraeme int
465 1.45 xtraeme sme_events_init(struct sysmon_envsys *sme)
466 1.1 xtraeme {
467 1.51 xtraeme int error = 0;
468 1.45 xtraeme uint64_t timo;
469 1.1 xtraeme
470 1.45 xtraeme KASSERT(sme != NULL);
471 1.51 xtraeme KASSERT(mutex_owned(&sme->sme_mtx));
472 1.22 xtraeme
473 1.45 xtraeme if (sme->sme_events_timeout)
474 1.45 xtraeme timo = sme->sme_events_timeout * hz;
475 1.45 xtraeme else
476 1.45 xtraeme timo = SME_EVTIMO;
477 1.45 xtraeme
478 1.45 xtraeme error = workqueue_create(&sme->sme_wq, sme->sme_name,
479 1.45 xtraeme sme_events_worker, sme, PRI_NONE, IPL_SOFTCLOCK, WQ_MPSAFE);
480 1.1 xtraeme if (error)
481 1.51 xtraeme return error;
482 1.1 xtraeme
483 1.51 xtraeme mutex_init(&sme->sme_callout_mtx, MUTEX_DEFAULT, IPL_SOFTCLOCK);
484 1.54 xtraeme callout_init(&sme->sme_callout, CALLOUT_MPSAFE);
485 1.45 xtraeme callout_setfunc(&sme->sme_callout, sme_events_check, sme);
486 1.45 xtraeme callout_schedule(&sme->sme_callout, timo);
487 1.45 xtraeme sme->sme_flags |= SME_CALLOUT_INITIALIZED;
488 1.45 xtraeme DPRINTF(("%s: events framework initialized for '%s'\n",
489 1.45 xtraeme __func__, sme->sme_name));
490 1.1 xtraeme
491 1.1 xtraeme return error;
492 1.1 xtraeme }
493 1.1 xtraeme
494 1.1 xtraeme /*
495 1.18 xtraeme * sme_events_destroy:
496 1.18 xtraeme *
497 1.51 xtraeme * + Destroys the event framework for this device: callout
498 1.51 xtraeme * stopped, workqueue destroyed and callout mutex destroyed.
499 1.18 xtraeme */
500 1.18 xtraeme void
501 1.45 xtraeme sme_events_destroy(struct sysmon_envsys *sme)
502 1.18 xtraeme {
503 1.51 xtraeme KASSERT(mutex_owned(&sme->sme_mtx));
504 1.22 xtraeme
505 1.45 xtraeme callout_stop(&sme->sme_callout);
506 1.54 xtraeme workqueue_destroy(sme->sme_wq);
507 1.54 xtraeme mutex_destroy(&sme->sme_callout_mtx);
508 1.54 xtraeme callout_destroy(&sme->sme_callout);
509 1.45 xtraeme sme->sme_flags &= ~SME_CALLOUT_INITIALIZED;
510 1.45 xtraeme DPRINTF(("%s: events framework destroyed for '%s'\n",
511 1.45 xtraeme __func__, sme->sme_name));
512 1.18 xtraeme }
513 1.18 xtraeme
514 1.18 xtraeme /*
515 1.1 xtraeme * sme_events_check:
516 1.1 xtraeme *
517 1.51 xtraeme * + Passes the events to the workqueue thread and stops
518 1.51 xtraeme * the callout if the 'low-power' condition is triggered.
519 1.1 xtraeme */
520 1.1 xtraeme void
521 1.1 xtraeme sme_events_check(void *arg)
522 1.1 xtraeme {
523 1.45 xtraeme struct sysmon_envsys *sme = arg;
524 1.1 xtraeme sme_event_t *see;
525 1.45 xtraeme uint64_t timo;
526 1.45 xtraeme
527 1.45 xtraeme KASSERT(sme != NULL);
528 1.45 xtraeme
529 1.51 xtraeme mutex_enter(&sme->sme_callout_mtx);
530 1.51 xtraeme LIST_FOREACH(see, &sme->sme_events_list, see_list) {
531 1.45 xtraeme workqueue_enqueue(sme->sme_wq, &see->see_wk, NULL);
532 1.56 pgoyette see->see_edata->flags |= ENVSYS_FNEED_REFRESH;
533 1.51 xtraeme }
534 1.45 xtraeme if (sme->sme_events_timeout)
535 1.45 xtraeme timo = sme->sme_events_timeout * hz;
536 1.45 xtraeme else
537 1.45 xtraeme timo = SME_EVTIMO;
538 1.38 xtraeme if (!sysmon_low_power)
539 1.45 xtraeme callout_schedule(&sme->sme_callout, timo);
540 1.51 xtraeme mutex_exit(&sme->sme_callout_mtx);
541 1.1 xtraeme }
542 1.1 xtraeme
543 1.1 xtraeme /*
544 1.1 xtraeme * sme_events_worker:
545 1.1 xtraeme *
546 1.1 xtraeme * + workqueue thread that checks if there's a critical condition
547 1.51 xtraeme * and sends an event if it was triggered.
548 1.1 xtraeme */
549 1.1 xtraeme void
550 1.1 xtraeme sme_events_worker(struct work *wk, void *arg)
551 1.1 xtraeme {
552 1.28 xtraeme const struct sme_description_table *sdt = NULL;
553 1.10 xtraeme const struct sme_sensor_event *sse = sme_sensor_event;
554 1.1 xtraeme sme_event_t *see = (void *)wk;
555 1.51 xtraeme struct sysmon_envsys *sme = see->see_sme;
556 1.51 xtraeme envsys_data_t *edata = see->see_edata;
557 1.51 xtraeme int i, state = 0;
558 1.1 xtraeme
559 1.1 xtraeme KASSERT(wk == &see->see_wk);
560 1.51 xtraeme KASSERT(sme != NULL || edata != NULL);
561 1.1 xtraeme
562 1.51 xtraeme mutex_enter(&sme->sme_mtx);
563 1.56 pgoyette if ((see->see_flags & SEE_EVENT_WORKING) == 0)
564 1.56 pgoyette see->see_flags |= SEE_EVENT_WORKING;
565 1.1 xtraeme /*
566 1.56 pgoyette * sme_events_check marks the first event for the device to
567 1.56 pgoyette * mak us refresh it here. Don't refresh if the driver uses
568 1.56 pgoyette * its own method for refreshing.
569 1.1 xtraeme */
570 1.45 xtraeme if ((sme->sme_flags & SME_DISABLE_REFRESH) == 0) {
571 1.56 pgoyette if ((see->see_edata->flags & ENVSYS_FNEED_REFRESH) != 0) {
572 1.51 xtraeme /* refresh sensor in device */
573 1.51 xtraeme (*sme->sme_refresh)(sme, edata);
574 1.56 pgoyette see->see_edata->flags &= ~ENVSYS_FNEED_REFRESH;
575 1.42 xtraeme }
576 1.1 xtraeme }
577 1.1 xtraeme
578 1.56 pgoyette DPRINTFOBJ(("%s: (%s) desc=%s sensor=%d type=%d state=%d units=%d "
579 1.51 xtraeme "value_cur=%d\n", __func__, sme->sme_name, edata->desc,
580 1.56 pgoyette edata->sensor, see->see_type, edata->state, edata->units,
581 1.56 pgoyette edata->value_cur));
582 1.1 xtraeme
583 1.50 xtraeme /* skip the event if current sensor is in invalid state */
584 1.51 xtraeme if (edata->state == ENVSYS_SINVALID)
585 1.50 xtraeme goto out;
586 1.50 xtraeme
587 1.45 xtraeme switch (see->see_type) {
588 1.10 xtraeme /*
589 1.56 pgoyette * For user range limits, calculate a new state first
590 1.56 pgoyette * State based on user limits will override any hardware
591 1.56 pgoyette * detected state.
592 1.56 pgoyette */
593 1.56 pgoyette case PENVSYS_EVENT_USER_LIMITS:
594 1.56 pgoyette case PENVSYS_EVENT_BATT_USER_LIMITS:
595 1.56 pgoyette #define __EXCEEDED_LIMIT(lim, rel) ((lim) && edata->value_cur rel (lim))
596 1.56 pgoyette if __EXCEEDED_LIMIT(see->see_critmin, <)
597 1.56 pgoyette edata->state = ENVSYS_SCRITUNDER;
598 1.56 pgoyette else if __EXCEEDED_LIMIT(see->see_warnmin, <)
599 1.56 pgoyette edata->state = ENVSYS_SWARNUNDER;
600 1.56 pgoyette else if __EXCEEDED_LIMIT(see->see_warnmax, >)
601 1.56 pgoyette edata->state = ENVSYS_SWARNOVER;
602 1.56 pgoyette else if __EXCEEDED_LIMIT(see->see_critmax, >)
603 1.56 pgoyette edata->state = ENVSYS_SCRITOVER;
604 1.56 pgoyette /* FALLTHROUGH */
605 1.56 pgoyette #undef __EXCEED_LIMIT
606 1.56 pgoyette /*
607 1.56 pgoyette * For hardware and user range limits, send event if state has changed
608 1.10 xtraeme */
609 1.1 xtraeme case PENVSYS_EVENT_CRITICAL:
610 1.56 pgoyette case PENVSYS_EVENT_HW_LIMITS:
611 1.56 pgoyette if (edata->state != see->see_evsent) {
612 1.56 pgoyette for (i = 0; sse[i].state != -1; i++)
613 1.56 pgoyette if (sse[i].state == edata->state)
614 1.56 pgoyette break;
615 1.56 pgoyette
616 1.56 pgoyette if (sse[i].state == -1)
617 1.10 xtraeme break;
618 1.1 xtraeme
619 1.56 pgoyette if (edata->state == ENVSYS_SVALID)
620 1.56 pgoyette sysmon_penvsys_event(&see->see_pes,
621 1.56 pgoyette PENVSYS_EVENT_NORMAL);
622 1.56 pgoyette else
623 1.56 pgoyette sysmon_penvsys_event(&see->see_pes,
624 1.56 pgoyette sse[i].event);
625 1.1 xtraeme
626 1.56 pgoyette see->see_evsent = edata->state;
627 1.56 pgoyette }
628 1.1 xtraeme break;
629 1.1 xtraeme
630 1.10 xtraeme /*
631 1.28 xtraeme * if value_cur is not normal (battery) or online (drive),
632 1.28 xtraeme * send the event...
633 1.10 xtraeme */
634 1.28 xtraeme case PENVSYS_EVENT_STATE_CHANGED:
635 1.45 xtraeme /*
636 1.45 xtraeme * the state has not been changed, just ignore the event.
637 1.45 xtraeme */
638 1.51 xtraeme if (edata->value_cur == see->see_evsent)
639 1.1 xtraeme break;
640 1.1 xtraeme
641 1.51 xtraeme switch (edata->units) {
642 1.28 xtraeme case ENVSYS_DRIVE:
643 1.28 xtraeme sdt = sme_get_description_table(SME_DESC_DRIVE_STATES);
644 1.28 xtraeme state = ENVSYS_DRIVE_ONLINE;
645 1.28 xtraeme break;
646 1.44 xtraeme case ENVSYS_BATTERY_CAPACITY:
647 1.51 xtraeme sdt = sme_get_description_table(
648 1.51 xtraeme SME_DESC_BATTERY_CAPACITY);
649 1.44 xtraeme state = ENVSYS_BATTERY_CAPACITY_NORMAL;
650 1.28 xtraeme break;
651 1.34 xtraeme default:
652 1.35 xtraeme panic("%s: invalid units for ENVSYS_FMONSTCHANGED",
653 1.35 xtraeme __func__);
654 1.28 xtraeme }
655 1.28 xtraeme
656 1.28 xtraeme for (i = 0; sdt[i].type != -1; i++)
657 1.51 xtraeme if (sdt[i].type == edata->value_cur)
658 1.1 xtraeme break;
659 1.1 xtraeme
660 1.51 xtraeme if (sdt[i].type == -1)
661 1.51 xtraeme break;
662 1.51 xtraeme
663 1.45 xtraeme /*
664 1.45 xtraeme * copy current state description.
665 1.45 xtraeme */
666 1.45 xtraeme (void)strlcpy(see->see_pes.pes_statedesc, sdt[i].desc,
667 1.45 xtraeme sizeof(see->see_pes.pes_statedesc));
668 1.1 xtraeme
669 1.45 xtraeme /*
670 1.45 xtraeme * state is ok again... send a normal event.
671 1.45 xtraeme */
672 1.56 pgoyette if (see->see_evsent && edata->value_cur == state) {
673 1.56 pgoyette sysmon_penvsys_event(&see->see_pes,
674 1.56 pgoyette PENVSYS_EVENT_NORMAL);
675 1.56 pgoyette see->see_evsent = false;
676 1.56 pgoyette }
677 1.1 xtraeme
678 1.45 xtraeme /*
679 1.45 xtraeme * state has been changed... send event.
680 1.45 xtraeme */
681 1.51 xtraeme if (see->see_evsent || edata->value_cur != state) {
682 1.45 xtraeme /*
683 1.45 xtraeme * save current drive state.
684 1.45 xtraeme */
685 1.51 xtraeme see->see_evsent = edata->value_cur;
686 1.45 xtraeme sysmon_penvsys_event(&see->see_pes, see->see_type);
687 1.1 xtraeme }
688 1.1 xtraeme
689 1.49 xtraeme /*
690 1.49 xtraeme * There's no need to continue if it's a drive sensor.
691 1.49 xtraeme */
692 1.51 xtraeme if (edata->units == ENVSYS_DRIVE)
693 1.49 xtraeme break;
694 1.49 xtraeme
695 1.39 xtraeme /*
696 1.39 xtraeme * Check if the system is running in low power and send the
697 1.39 xtraeme * event to powerd (if running) or shutdown the system
698 1.39 xtraeme * otherwise.
699 1.39 xtraeme */
700 1.39 xtraeme if (!sysmon_low_power && sme_event_check_low_power()) {
701 1.39 xtraeme struct penvsys_state pes;
702 1.39 xtraeme
703 1.45 xtraeme /*
704 1.45 xtraeme * Stop the callout and send the 'low-power' event.
705 1.45 xtraeme */
706 1.45 xtraeme sysmon_low_power = true;
707 1.45 xtraeme callout_stop(&sme->sme_callout);
708 1.39 xtraeme pes.pes_type = PENVSYS_TYPE_BATTERY;
709 1.39 xtraeme sysmon_penvsys_event(&pes, PENVSYS_EVENT_LOW_POWER);
710 1.39 xtraeme }
711 1.1 xtraeme break;
712 1.56 pgoyette default:
713 1.56 pgoyette panic("%s: invalid event type %d", __func__, see->see_type);
714 1.1 xtraeme }
715 1.45 xtraeme
716 1.50 xtraeme out:
717 1.56 pgoyette see->see_flags &= ~SEE_EVENT_WORKING;
718 1.51 xtraeme cv_broadcast(&sme->sme_condvar);
719 1.51 xtraeme mutex_exit(&sme->sme_mtx);
720 1.1 xtraeme }
721 1.38 xtraeme
722 1.47 xtraeme /*
723 1.51 xtraeme * Returns true if the system is in low power state: an AC adapter
724 1.51 xtraeme * is OFF and all batteries are in LOW/CRITICAL state.
725 1.47 xtraeme */
726 1.44 xtraeme static bool
727 1.38 xtraeme sme_event_check_low_power(void)
728 1.38 xtraeme {
729 1.47 xtraeme if (!sme_acadapter_check())
730 1.47 xtraeme return false;
731 1.47 xtraeme
732 1.47 xtraeme return sme_battery_check();
733 1.47 xtraeme }
734 1.47 xtraeme
735 1.51 xtraeme /*
736 1.51 xtraeme * Called with the sysmon_envsys device mtx held through the
737 1.51 xtraeme * workqueue thread.
738 1.51 xtraeme */
739 1.47 xtraeme static bool
740 1.47 xtraeme sme_acadapter_check(void)
741 1.47 xtraeme {
742 1.38 xtraeme struct sysmon_envsys *sme;
743 1.38 xtraeme envsys_data_t *edata;
744 1.50 xtraeme bool dev = false, sensor = false;
745 1.38 xtraeme
746 1.50 xtraeme LIST_FOREACH(sme, &sysmon_envsys_list, sme_list) {
747 1.50 xtraeme if (sme->sme_class == SME_CLASS_ACADAPTER) {
748 1.50 xtraeme dev = true;
749 1.38 xtraeme break;
750 1.50 xtraeme }
751 1.50 xtraeme }
752 1.51 xtraeme
753 1.38 xtraeme /*
754 1.47 xtraeme * No AC Adapter devices were found.
755 1.38 xtraeme */
756 1.50 xtraeme if (!dev)
757 1.44 xtraeme return false;
758 1.51 xtraeme
759 1.44 xtraeme /*
760 1.47 xtraeme * Check if there's an AC adapter device connected.
761 1.44 xtraeme */
762 1.45 xtraeme TAILQ_FOREACH(edata, &sme->sme_sensors_list, sensors_head) {
763 1.38 xtraeme if (edata->units == ENVSYS_INDICATOR) {
764 1.47 xtraeme sensor = true;
765 1.50 xtraeme /* refresh current sensor */
766 1.50 xtraeme (*sme->sme_refresh)(sme, edata);
767 1.44 xtraeme if (edata->value_cur)
768 1.44 xtraeme return false;
769 1.38 xtraeme }
770 1.38 xtraeme }
771 1.51 xtraeme
772 1.47 xtraeme if (!sensor)
773 1.47 xtraeme return false;
774 1.47 xtraeme
775 1.51 xtraeme /*
776 1.51 xtraeme * AC adapter found and not connected.
777 1.51 xtraeme */
778 1.47 xtraeme return true;
779 1.47 xtraeme }
780 1.47 xtraeme
781 1.51 xtraeme /*
782 1.51 xtraeme * Called with the sysmon_envsys device mtx held through the
783 1.51 xtraeme * workqueue thread.
784 1.51 xtraeme */
785 1.47 xtraeme static bool
786 1.47 xtraeme sme_battery_check(void)
787 1.47 xtraeme {
788 1.47 xtraeme struct sysmon_envsys *sme;
789 1.47 xtraeme envsys_data_t *edata;
790 1.55 drochner int batteriesfound = 0;
791 1.55 drochner bool present, batterycap, batterycharge;
792 1.44 xtraeme
793 1.38 xtraeme /*
794 1.44 xtraeme * Check for battery devices and its state.
795 1.38 xtraeme */
796 1.44 xtraeme LIST_FOREACH(sme, &sysmon_envsys_list, sme_list) {
797 1.44 xtraeme if (sme->sme_class != SME_CLASS_BATTERY)
798 1.44 xtraeme continue;
799 1.38 xtraeme
800 1.55 drochner present = true;
801 1.55 drochner TAILQ_FOREACH(edata, &sme->sme_sensors_list, sensors_head) {
802 1.55 drochner if (edata->units == ENVSYS_INDICATOR &&
803 1.55 drochner !edata->value_cur) {
804 1.55 drochner present = false;
805 1.55 drochner break;
806 1.55 drochner }
807 1.55 drochner }
808 1.55 drochner if (!present)
809 1.55 drochner continue;
810 1.44 xtraeme /*
811 1.44 xtraeme * We've found a battery device...
812 1.44 xtraeme */
813 1.55 drochner batteriesfound++;
814 1.55 drochner batterycap = batterycharge = false;
815 1.45 xtraeme TAILQ_FOREACH(edata, &sme->sme_sensors_list, sensors_head) {
816 1.44 xtraeme if (edata->units == ENVSYS_BATTERY_CAPACITY) {
817 1.44 xtraeme batterycap = true;
818 1.44 xtraeme if (!sme_battery_critical(edata))
819 1.44 xtraeme return false;
820 1.44 xtraeme } else if (edata->units == ENVSYS_BATTERY_CHARGE) {
821 1.44 xtraeme batterycharge = true;
822 1.44 xtraeme if (edata->value_cur)
823 1.44 xtraeme return false;
824 1.38 xtraeme }
825 1.38 xtraeme }
826 1.55 drochner if (!batterycap || !batterycharge)
827 1.55 drochner return false;
828 1.38 xtraeme }
829 1.51 xtraeme
830 1.55 drochner if (!batteriesfound)
831 1.44 xtraeme return false;
832 1.38 xtraeme
833 1.38 xtraeme /*
834 1.44 xtraeme * All batteries in low/critical capacity and discharging.
835 1.38 xtraeme */
836 1.44 xtraeme return true;
837 1.44 xtraeme }
838 1.38 xtraeme
839 1.44 xtraeme static bool
840 1.44 xtraeme sme_battery_critical(envsys_data_t *edata)
841 1.44 xtraeme {
842 1.44 xtraeme if (edata->value_cur == ENVSYS_BATTERY_CAPACITY_CRITICAL ||
843 1.44 xtraeme edata->value_cur == ENVSYS_BATTERY_CAPACITY_LOW)
844 1.44 xtraeme return true;
845 1.44 xtraeme
846 1.44 xtraeme return false;
847 1.38 xtraeme }
848