sysmon_envsys_events.c revision 1.77 1 1.77 pgoyette /* $NetBSD: sysmon_envsys_events.c,v 1.77 2010/01/30 02:46:52 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.77 pgoyette __KERNEL_RCSID(0, "$NetBSD: sysmon_envsys_events.c,v 1.77 2010/01/30 02:46:52 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.65 pgoyette { ENVSYS_SVALID, PENVSYS_EVENT_NORMAL },
58 1.65 pgoyette { ENVSYS_SCRITOVER, PENVSYS_EVENT_CRITOVER },
59 1.65 pgoyette { ENVSYS_SCRITUNDER, PENVSYS_EVENT_CRITUNDER },
60 1.65 pgoyette { ENVSYS_SWARNOVER, PENVSYS_EVENT_WARNOVER },
61 1.65 pgoyette { ENVSYS_SWARNUNDER, PENVSYS_EVENT_WARNUNDER },
62 1.65 pgoyette { ENVSYS_BATTERY_CAPACITY_NORMAL, PENVSYS_EVENT_NORMAL },
63 1.65 pgoyette { ENVSYS_BATTERY_CAPACITY_WARNING, PENVSYS_EVENT_BATT_WARN },
64 1.65 pgoyette { ENVSYS_BATTERY_CAPACITY_CRITICAL, PENVSYS_EVENT_BATT_CRIT },
65 1.65 pgoyette { -1, -1 }
66 1.10 xtraeme };
67 1.10 xtraeme
68 1.51 xtraeme static bool sysmon_low_power;
69 1.1 xtraeme
70 1.45 xtraeme #define SME_EVTIMO (SME_EVENTS_DEFTIMEOUT * hz)
71 1.3 xtraeme
72 1.44 xtraeme static bool sme_event_check_low_power(void);
73 1.47 xtraeme static bool sme_battery_check(void);
74 1.44 xtraeme static bool sme_battery_critical(envsys_data_t *);
75 1.47 xtraeme static bool sme_acadapter_check(void);
76 1.38 xtraeme
77 1.3 xtraeme /*
78 1.1 xtraeme * sme_event_register:
79 1.1 xtraeme *
80 1.24 xtraeme * + Registers a new sysmon envsys event or updates any event
81 1.24 xtraeme * already in the queue.
82 1.1 xtraeme */
83 1.1 xtraeme int
84 1.24 xtraeme sme_event_register(prop_dictionary_t sdict, envsys_data_t *edata,
85 1.67 pgoyette struct sysmon_envsys *sme, sysmon_envsys_lim_t *lims,
86 1.67 pgoyette int crittype, int powertype)
87 1.1 xtraeme {
88 1.51 xtraeme sme_event_t *see = NULL, *osee = NULL;
89 1.24 xtraeme prop_object_t obj;
90 1.1 xtraeme int error = 0;
91 1.65 pgoyette const char *objkey;
92 1.1 xtraeme
93 1.76 pgoyette KASSERT(sdict != NULL);
94 1.76 pgoyette KASSERT(edata != NULL);
95 1.76 pgoyette KASSERT(sme != NULL);
96 1.77 pgoyette KASSERT(lims != NULL);
97 1.77 pgoyette
98 1.77 pgoyette /*
99 1.77 pgoyette * Some validation first for limit-checking events
100 1.77 pgoyette *
101 1.77 pgoyette * Capacity limits are permitted only if the sensor has the
102 1.77 pgoyette * ENVSYS_FPERCENT flag set.
103 1.77 pgoyette * Value limits are permitted only if the ENVSYS_FPERCENT
104 1.77 pgoyette * flag is not set and the units is not ENVSYS_INDICATOR.
105 1.77 pgoyette */
106 1.77 pgoyette
107 1.77 pgoyette DPRINTF(("%s: units %d lim-flags 0x%04x edata-flags 0x%04x\n",
108 1.77 pgoyette __func__, edata->units, lims->sel_flags, edata->flags));
109 1.77 pgoyette
110 1.77 pgoyette if ((lims->sel_flags & PROP_VAL_LIMITS) &&
111 1.77 pgoyette ((edata->flags & ENVSYS_FPERCENT) ||
112 1.77 pgoyette (edata->units == ENVSYS_INDICATOR)))
113 1.77 pgoyette return ENOTSUP;
114 1.77 pgoyette if ((lims->sel_flags & PROP_CAP_LIMITS) &&
115 1.77 pgoyette !(edata->flags & ENVSYS_FPERCENT))
116 1.77 pgoyette return ENOTSUP;
117 1.56 pgoyette
118 1.1 xtraeme /*
119 1.24 xtraeme * check if the event is already on the list and return
120 1.24 xtraeme * EEXIST if value provided hasn't been changed.
121 1.1 xtraeme */
122 1.51 xtraeme mutex_enter(&sme->sme_mtx);
123 1.51 xtraeme LIST_FOREACH(osee, &sme->sme_events_list, see_list) {
124 1.65 pgoyette if (strcmp(edata->desc, osee->see_pes.pes_sensname) != 0)
125 1.65 pgoyette continue;
126 1.65 pgoyette if (crittype != osee->see_type)
127 1.65 pgoyette continue;
128 1.65 pgoyette
129 1.76 pgoyette /*
130 1.76 pgoyette * We found an existing event for this sensor. Make
131 1.76 pgoyette * sure it references the correct edata
132 1.76 pgoyette */
133 1.76 pgoyette KASSERT(edata == osee->see_edata);
134 1.76 pgoyette
135 1.77 pgoyette DPRINTF(("%s: dev %s sensor %s: event type %d exists\n",
136 1.77 pgoyette __func__, sme->sme_name, edata->desc, crittype));
137 1.65 pgoyette
138 1.65 pgoyette see = osee;
139 1.67 pgoyette if (lims->sel_flags & PROP_CRITMAX) {
140 1.76 pgoyette if (lims->sel_critmax == edata->limits.sel_critmax) {
141 1.65 pgoyette DPRINTF(("%s: type=%d (critmax exists)\n",
142 1.65 pgoyette __func__, crittype));
143 1.65 pgoyette error = EEXIST;
144 1.67 pgoyette lims->sel_flags &= ~PROP_CRITMAX;
145 1.65 pgoyette }
146 1.65 pgoyette }
147 1.67 pgoyette if (lims->sel_flags & PROP_WARNMAX) {
148 1.76 pgoyette if (lims->sel_warnmax == edata->limits.sel_warnmax) {
149 1.77 pgoyette DPRINTF(("%s: warnmax exists\n", __func__));
150 1.65 pgoyette error = EEXIST;
151 1.67 pgoyette lims->sel_flags &= ~PROP_WARNMAX;
152 1.65 pgoyette }
153 1.65 pgoyette }
154 1.67 pgoyette if (lims->sel_flags & (PROP_WARNMIN | PROP_BATTWARN)) {
155 1.76 pgoyette if (lims->sel_warnmin == edata->limits.sel_warnmin) {
156 1.77 pgoyette DPRINTF(("%s: warnmin exists\n", __func__));
157 1.65 pgoyette error = EEXIST;
158 1.76 pgoyette lims->sel_flags &=
159 1.76 pgoyette ~(PROP_WARNMIN | PROP_BATTWARN);
160 1.1 xtraeme }
161 1.65 pgoyette }
162 1.67 pgoyette if (lims->sel_flags & (PROP_CRITMIN | PROP_BATTCAP)) {
163 1.76 pgoyette if (lims->sel_critmin == edata->limits.sel_critmin) {
164 1.77 pgoyette DPRINTF(("%s: critmin exists\n", __func__));
165 1.65 pgoyette error = EEXIST;
166 1.76 pgoyette lims->sel_flags &=
167 1.76 pgoyette ~(PROP_CRITMIN | PROP_BATTCAP);
168 1.56 pgoyette }
169 1.1 xtraeme }
170 1.65 pgoyette break;
171 1.1 xtraeme }
172 1.65 pgoyette if (see == NULL) {
173 1.65 pgoyette /*
174 1.65 pgoyette * New event requested - allocate a sysmon_envsys event.
175 1.65 pgoyette */
176 1.65 pgoyette see = kmem_zalloc(sizeof(*see), KM_SLEEP);
177 1.65 pgoyette if (see == NULL)
178 1.65 pgoyette return ENOMEM;
179 1.65 pgoyette
180 1.77 pgoyette DPRINTF(("%s: dev %s sensor %s: new event\n",
181 1.77 pgoyette __func__, sme->sme_name, edata->des));
182 1.65 pgoyette
183 1.65 pgoyette see->see_type = crittype;
184 1.65 pgoyette see->see_sme = sme;
185 1.65 pgoyette see->see_edata = edata;
186 1.65 pgoyette
187 1.65 pgoyette /* Initialize sensor type and previously-sent state */
188 1.65 pgoyette
189 1.65 pgoyette see->see_pes.pes_type = powertype;
190 1.1 xtraeme
191 1.56 pgoyette switch (crittype) {
192 1.65 pgoyette case PENVSYS_EVENT_LIMITS:
193 1.65 pgoyette see->see_evsent = ENVSYS_SVALID;
194 1.65 pgoyette break;
195 1.65 pgoyette case PENVSYS_EVENT_CAPACITY:
196 1.65 pgoyette see->see_evsent = ENVSYS_BATTERY_CAPACITY_NORMAL;
197 1.56 pgoyette break;
198 1.65 pgoyette case PENVSYS_EVENT_STATE_CHANGED:
199 1.65 pgoyette if (edata->units == ENVSYS_BATTERY_CAPACITY)
200 1.65 pgoyette see->see_evsent = ENVSYS_BATTERY_CAPACITY_NORMAL;
201 1.65 pgoyette else if (edata->units == ENVSYS_DRIVE)
202 1.65 pgoyette see->see_evsent = ENVSYS_DRIVE_EMPTY;
203 1.65 pgoyette else
204 1.65 pgoyette panic("%s: bad units for "
205 1.65 pgoyette "PENVSYS_EVENT_STATE_CHANGED", __func__);
206 1.56 pgoyette break;
207 1.65 pgoyette case PENVSYS_EVENT_CRITICAL:
208 1.56 pgoyette default:
209 1.65 pgoyette see->see_evsent = 0;
210 1.56 pgoyette break;
211 1.56 pgoyette }
212 1.65 pgoyette
213 1.65 pgoyette (void)strlcpy(see->see_pes.pes_dvname, sme->sme_name,
214 1.65 pgoyette sizeof(see->see_pes.pes_dvname));
215 1.65 pgoyette (void)strlcpy(see->see_pes.pes_sensname, edata->desc,
216 1.65 pgoyette sizeof(see->see_pes.pes_sensname));
217 1.56 pgoyette }
218 1.65 pgoyette
219 1.56 pgoyette /*
220 1.65 pgoyette * Limit operation requested.
221 1.24 xtraeme */
222 1.67 pgoyette if (lims->sel_flags & PROP_CRITMAX) {
223 1.65 pgoyette objkey = "critical-max";
224 1.65 pgoyette obj = prop_dictionary_get(sdict, objkey);
225 1.65 pgoyette if (obj && prop_object_type(obj) != PROP_TYPE_NUMBER) {
226 1.65 pgoyette DPRINTF(("%s: (%s) %s object not TYPE_NUMBER\n",
227 1.65 pgoyette __func__, sme->sme_name, objkey));
228 1.65 pgoyette error = ENOTSUP;
229 1.65 pgoyette } else {
230 1.76 pgoyette edata->limits.sel_critmax = lims->sel_critmax;
231 1.67 pgoyette error = sme_sensor_upint32(sdict, objkey,
232 1.67 pgoyette lims->sel_critmax);
233 1.65 pgoyette DPRINTF(("%s: (%s) event [sensor=%s type=%d] "
234 1.65 pgoyette "(%s updated)\n", __func__, sme->sme_name,
235 1.65 pgoyette edata->desc, crittype, objkey));
236 1.65 pgoyette }
237 1.67 pgoyette if (error && error != EEXIST)
238 1.67 pgoyette goto out;
239 1.76 pgoyette edata->upropset |= PROP_CRITMAX;
240 1.65 pgoyette }
241 1.65 pgoyette
242 1.67 pgoyette if (lims->sel_flags & PROP_WARNMAX) {
243 1.65 pgoyette objkey = "warning-max";
244 1.65 pgoyette obj = prop_dictionary_get(sdict, objkey);
245 1.65 pgoyette if (obj && prop_object_type(obj) != PROP_TYPE_NUMBER) {
246 1.65 pgoyette DPRINTF(("%s: (%s) %s object not TYPE_NUMBER\n",
247 1.65 pgoyette __func__, sme->sme_name, objkey));
248 1.65 pgoyette error = ENOTSUP;
249 1.65 pgoyette } else {
250 1.76 pgoyette edata->limits.sel_warnmax = lims->sel_warnmax;
251 1.67 pgoyette error = sme_sensor_upint32(sdict, objkey,
252 1.67 pgoyette lims->sel_warnmax);
253 1.65 pgoyette DPRINTF(("%s: (%s) event [sensor=%s type=%d] "
254 1.65 pgoyette "(%s updated)\n", __func__, sme->sme_name,
255 1.65 pgoyette edata->desc, crittype, objkey));
256 1.65 pgoyette }
257 1.67 pgoyette if (error && error != EEXIST)
258 1.67 pgoyette goto out;
259 1.76 pgoyette edata->upropset |= PROP_WARNMAX;
260 1.56 pgoyette }
261 1.57 pgoyette
262 1.67 pgoyette if (lims->sel_flags & PROP_WARNMIN) {
263 1.65 pgoyette objkey = "warning-min";
264 1.65 pgoyette obj = prop_dictionary_get(sdict, objkey);
265 1.65 pgoyette if (obj && prop_object_type(obj) != PROP_TYPE_NUMBER) {
266 1.65 pgoyette DPRINTF(("%s: (%s) %s object not TYPE_NUMBER\n",
267 1.65 pgoyette __func__, sme->sme_name, objkey));
268 1.65 pgoyette error = ENOTSUP;
269 1.65 pgoyette } else {
270 1.76 pgoyette edata->limits.sel_warnmin = lims->sel_warnmin;
271 1.67 pgoyette error = sme_sensor_upint32(sdict, objkey,
272 1.67 pgoyette lims->sel_warnmin);
273 1.65 pgoyette DPRINTF(("%s: (%s) event [sensor=%s type=%d] "
274 1.65 pgoyette "(%s updated)\n", __func__, sme->sme_name,
275 1.65 pgoyette edata->desc, crittype, objkey));
276 1.65 pgoyette }
277 1.67 pgoyette if (error && error != EEXIST)
278 1.67 pgoyette goto out;
279 1.76 pgoyette edata->upropset |= PROP_WARNMIN;
280 1.65 pgoyette }
281 1.57 pgoyette
282 1.67 pgoyette if (lims->sel_flags & PROP_CRITMIN) {
283 1.65 pgoyette objkey = "critical-min";
284 1.65 pgoyette obj = prop_dictionary_get(sdict, objkey);
285 1.65 pgoyette if (obj && prop_object_type(obj) != PROP_TYPE_NUMBER) {
286 1.65 pgoyette DPRINTF(("%s: (%s) %s object not TYPE_NUMBER\n",
287 1.65 pgoyette __func__, sme->sme_name, objkey));
288 1.65 pgoyette error = ENOTSUP;
289 1.65 pgoyette } else {
290 1.76 pgoyette edata->limits.sel_critmin = lims->sel_critmin;
291 1.67 pgoyette error = sme_sensor_upint32(sdict, objkey,
292 1.67 pgoyette lims->sel_critmin);
293 1.65 pgoyette DPRINTF(("%s: (%s) event [sensor=%s type=%d] "
294 1.65 pgoyette "(%s updated)\n", __func__, sme->sme_name,
295 1.65 pgoyette edata->desc, crittype, objkey));
296 1.65 pgoyette }
297 1.67 pgoyette if (error && error != EEXIST)
298 1.67 pgoyette goto out;
299 1.76 pgoyette edata->upropset |= PROP_CRITMIN;
300 1.65 pgoyette }
301 1.65 pgoyette
302 1.67 pgoyette if (lims->sel_flags & PROP_BATTWARN) {
303 1.65 pgoyette objkey = "warning-capacity";
304 1.65 pgoyette obj = prop_dictionary_get(sdict, objkey);
305 1.65 pgoyette if (obj && prop_object_type(obj) != PROP_TYPE_NUMBER) {
306 1.65 pgoyette DPRINTF(("%s: (%s) %s object not TYPE_NUMBER\n",
307 1.65 pgoyette __func__, sme->sme_name, objkey));
308 1.65 pgoyette error = ENOTSUP;
309 1.65 pgoyette } else {
310 1.76 pgoyette edata->limits.sel_warnmin = lims->sel_warnmin;
311 1.67 pgoyette error = sme_sensor_upint32(sdict, objkey,
312 1.67 pgoyette lims->sel_warnmin);
313 1.65 pgoyette DPRINTF(("%s: (%s) event [sensor=%s type=%d] "
314 1.65 pgoyette "(%s updated)\n", __func__, sme->sme_name,
315 1.65 pgoyette edata->desc, crittype, objkey));
316 1.65 pgoyette }
317 1.67 pgoyette if (error && error != EEXIST)
318 1.67 pgoyette goto out;
319 1.76 pgoyette edata->upropset |= PROP_BATTWARN;
320 1.57 pgoyette }
321 1.57 pgoyette
322 1.67 pgoyette if (lims->sel_flags & PROP_BATTCAP) {
323 1.65 pgoyette objkey = "critical-capacity";
324 1.65 pgoyette obj = prop_dictionary_get(sdict, objkey);
325 1.65 pgoyette if (obj && prop_object_type(obj) != PROP_TYPE_NUMBER) {
326 1.65 pgoyette DPRINTF(("%s: (%s) %s object not TYPE_NUMBER\n",
327 1.65 pgoyette __func__, sme->sme_name, objkey));
328 1.65 pgoyette error = ENOTSUP;
329 1.65 pgoyette } else {
330 1.76 pgoyette edata->limits.sel_critmin = lims->sel_critmin;
331 1.67 pgoyette error = sme_sensor_upint32(sdict, objkey,
332 1.67 pgoyette lims->sel_critmin);
333 1.65 pgoyette DPRINTF(("%s: (%s) event [sensor=%s type=%d] "
334 1.65 pgoyette "(%s updated)\n", __func__, sme->sme_name,
335 1.65 pgoyette edata->desc, crittype, objkey));
336 1.65 pgoyette }
337 1.67 pgoyette if (error && error != EEXIST)
338 1.67 pgoyette goto out;
339 1.76 pgoyette edata->upropset |= PROP_BATTCAP;
340 1.27 xtraeme }
341 1.65 pgoyette
342 1.74 pgoyette if (lims->sel_flags & PROP_DRIVER_LIMITS)
343 1.76 pgoyette edata->upropset |= PROP_DRIVER_LIMITS;
344 1.76 pgoyette else
345 1.76 pgoyette edata->upropset &= ~PROP_DRIVER_LIMITS;
346 1.74 pgoyette
347 1.51 xtraeme DPRINTF(("%s: (%s) event registered (sensor=%s snum=%d type=%d "
348 1.56 pgoyette "critmin=%" PRIu32 " warnmin=%" PRIu32 " warnmax=%" PRIu32
349 1.65 pgoyette " critmax=%" PRIu32 " props 0x%04x)\n", __func__,
350 1.45 xtraeme see->see_sme->sme_name, see->see_pes.pes_sensname,
351 1.76 pgoyette edata->sensor, see->see_type, edata->limits.sel_critmin,
352 1.76 pgoyette edata->limits.sel_warnmin, edata->limits.sel_warnmax,
353 1.76 pgoyette edata->limits.sel_critmax, edata->upropset));
354 1.1 xtraeme /*
355 1.45 xtraeme * Initialize the events framework if it wasn't initialized before.
356 1.1 xtraeme */
357 1.45 xtraeme if ((sme->sme_flags & SME_CALLOUT_INITIALIZED) == 0)
358 1.45 xtraeme error = sme_events_init(sme);
359 1.67 pgoyette
360 1.67 pgoyette /*
361 1.67 pgoyette * If driver requested notification, advise it of new
362 1.67 pgoyette * limit values
363 1.67 pgoyette */
364 1.67 pgoyette if (sme->sme_set_limits) {
365 1.76 pgoyette edata->limits.sel_flags = edata->upropset & PROP_LIMITS;
366 1.76 pgoyette (*sme->sme_set_limits)(sme, edata, &(edata->limits));
367 1.67 pgoyette }
368 1.67 pgoyette
369 1.27 xtraeme out:
370 1.65 pgoyette if ((error == 0 || error == EEXIST) && osee == NULL)
371 1.65 pgoyette LIST_INSERT_HEAD(&sme->sme_events_list, see, see_list);
372 1.65 pgoyette
373 1.51 xtraeme mutex_exit(&sme->sme_mtx);
374 1.65 pgoyette
375 1.1 xtraeme return error;
376 1.1 xtraeme }
377 1.1 xtraeme
378 1.1 xtraeme /*
379 1.18 xtraeme * sme_event_unregister_all:
380 1.18 xtraeme *
381 1.51 xtraeme * + Unregisters all events associated with a sysmon envsys device.
382 1.18 xtraeme */
383 1.18 xtraeme void
384 1.45 xtraeme sme_event_unregister_all(struct sysmon_envsys *sme)
385 1.18 xtraeme {
386 1.18 xtraeme sme_event_t *see;
387 1.18 xtraeme int evcounter = 0;
388 1.18 xtraeme
389 1.45 xtraeme KASSERT(sme != NULL);
390 1.18 xtraeme
391 1.51 xtraeme mutex_enter(&sme->sme_mtx);
392 1.45 xtraeme LIST_FOREACH(see, &sme->sme_events_list, see_list) {
393 1.56 pgoyette while (see->see_flags & SEE_EVENT_WORKING)
394 1.51 xtraeme cv_wait(&sme->sme_condvar, &sme->sme_mtx);
395 1.51 xtraeme
396 1.45 xtraeme if (strcmp(see->see_pes.pes_dvname, sme->sme_name) == 0)
397 1.18 xtraeme evcounter++;
398 1.18 xtraeme }
399 1.18 xtraeme
400 1.18 xtraeme DPRINTF(("%s: total events %d (%s)\n", __func__,
401 1.45 xtraeme evcounter, sme->sme_name));
402 1.18 xtraeme
403 1.45 xtraeme while ((see = LIST_FIRST(&sme->sme_events_list))) {
404 1.18 xtraeme if (evcounter == 0)
405 1.18 xtraeme break;
406 1.18 xtraeme
407 1.45 xtraeme if (strcmp(see->see_pes.pes_dvname, sme->sme_name) == 0) {
408 1.51 xtraeme LIST_REMOVE(see, see_list);
409 1.18 xtraeme DPRINTF(("%s: event %s %d removed (%s)\n", __func__,
410 1.45 xtraeme see->see_pes.pes_sensname, see->see_type,
411 1.45 xtraeme sme->sme_name));
412 1.18 xtraeme kmem_free(see, sizeof(*see));
413 1.18 xtraeme evcounter--;
414 1.18 xtraeme }
415 1.18 xtraeme }
416 1.18 xtraeme
417 1.51 xtraeme if (LIST_EMPTY(&sme->sme_events_list))
418 1.45 xtraeme if (sme->sme_flags & SME_CALLOUT_INITIALIZED)
419 1.45 xtraeme sme_events_destroy(sme);
420 1.51 xtraeme mutex_exit(&sme->sme_mtx);
421 1.18 xtraeme }
422 1.18 xtraeme
423 1.18 xtraeme /*
424 1.1 xtraeme * sme_event_unregister:
425 1.1 xtraeme *
426 1.45 xtraeme * + Unregisters an event from the specified sysmon envsys device.
427 1.1 xtraeme */
428 1.1 xtraeme int
429 1.45 xtraeme sme_event_unregister(struct sysmon_envsys *sme, const char *sensor, int type)
430 1.1 xtraeme {
431 1.1 xtraeme sme_event_t *see;
432 1.1 xtraeme bool found = false;
433 1.1 xtraeme
434 1.1 xtraeme KASSERT(sensor != NULL);
435 1.1 xtraeme
436 1.51 xtraeme mutex_enter(&sme->sme_mtx);
437 1.45 xtraeme LIST_FOREACH(see, &sme->sme_events_list, see_list) {
438 1.45 xtraeme if (strcmp(see->see_pes.pes_sensname, sensor) == 0) {
439 1.45 xtraeme if (see->see_type == type) {
440 1.1 xtraeme found = true;
441 1.1 xtraeme break;
442 1.1 xtraeme }
443 1.1 xtraeme }
444 1.1 xtraeme }
445 1.1 xtraeme
446 1.51 xtraeme if (!found) {
447 1.51 xtraeme mutex_exit(&sme->sme_mtx);
448 1.1 xtraeme return EINVAL;
449 1.51 xtraeme }
450 1.1 xtraeme
451 1.51 xtraeme /*
452 1.51 xtraeme * Wait for the event to finish its work, remove from the list
453 1.51 xtraeme * and release resouces.
454 1.51 xtraeme */
455 1.56 pgoyette while (see->see_flags & SEE_EVENT_WORKING)
456 1.51 xtraeme cv_wait(&sme->sme_condvar, &sme->sme_mtx);
457 1.15 xtraeme
458 1.51 xtraeme DPRINTF(("%s: removed dev=%s sensor=%s type=%d\n",
459 1.45 xtraeme __func__, see->see_pes.pes_dvname, sensor, type));
460 1.1 xtraeme LIST_REMOVE(see, see_list);
461 1.1 xtraeme /*
462 1.1 xtraeme * So the events list is empty, we'll do the following:
463 1.1 xtraeme *
464 1.9 xtraeme * - stop and destroy the callout.
465 1.1 xtraeme * - destroy the workqueue.
466 1.1 xtraeme */
467 1.51 xtraeme if (LIST_EMPTY(&sme->sme_events_list))
468 1.45 xtraeme sme_events_destroy(sme);
469 1.51 xtraeme mutex_exit(&sme->sme_mtx);
470 1.1 xtraeme
471 1.20 xtraeme kmem_free(see, sizeof(*see));
472 1.1 xtraeme return 0;
473 1.1 xtraeme }
474 1.1 xtraeme
475 1.1 xtraeme /*
476 1.1 xtraeme * sme_event_drvadd:
477 1.1 xtraeme *
478 1.45 xtraeme * + Registers a new event for a device that had enabled any of
479 1.45 xtraeme * the monitoring flags in the driver.
480 1.1 xtraeme */
481 1.1 xtraeme void
482 1.1 xtraeme sme_event_drvadd(void *arg)
483 1.1 xtraeme {
484 1.1 xtraeme sme_event_drv_t *sed_t = arg;
485 1.67 pgoyette sysmon_envsys_lim_t lims;
486 1.2 xtraeme int error = 0;
487 1.1 xtraeme
488 1.1 xtraeme KASSERT(sed_t != NULL);
489 1.1 xtraeme
490 1.1 xtraeme #define SEE_REGEVENT(a, b, c) \
491 1.1 xtraeme do { \
492 1.45 xtraeme if (sed_t->sed_edata->flags & (a)) { \
493 1.36 xtraeme char str[ENVSYS_DESCLEN] = "monitoring-state-"; \
494 1.1 xtraeme \
495 1.45 xtraeme error = sme_event_register(sed_t->sed_sdict, \
496 1.45 xtraeme sed_t->sed_edata, \
497 1.45 xtraeme sed_t->sed_sme, \
498 1.67 pgoyette &lims, \
499 1.2 xtraeme (b), \
500 1.45 xtraeme sed_t->sed_powertype); \
501 1.2 xtraeme if (error && error != EEXIST) \
502 1.2 xtraeme printf("%s: failed to add event! " \
503 1.2 xtraeme "error=%d sensor=%s event=%s\n", \
504 1.45 xtraeme __func__, error, \
505 1.45 xtraeme sed_t->sed_edata->desc, (c)); \
506 1.2 xtraeme else { \
507 1.2 xtraeme (void)strlcat(str, (c), sizeof(str)); \
508 1.45 xtraeme prop_dictionary_set_bool(sed_t->sed_sdict, \
509 1.2 xtraeme str, \
510 1.2 xtraeme true); \
511 1.2 xtraeme } \
512 1.1 xtraeme } \
513 1.1 xtraeme } while (/* CONSTCOND */ 0)
514 1.1 xtraeme
515 1.71 pgoyette /*
516 1.73 pgoyette * If driver provides a method to retrieve its internal limit
517 1.74 pgoyette * values, call it and use those returned values as initial
518 1.73 pgoyette * limits for event monitoring.
519 1.71 pgoyette */
520 1.70 pgoyette lims.sel_flags = 0;
521 1.71 pgoyette if (sed_t->sed_edata->flags & ENVSYS_FMONLIMITS)
522 1.67 pgoyette if (sed_t->sed_sme->sme_get_limits)
523 1.67 pgoyette (*sed_t->sed_sme->sme_get_limits)(sed_t->sed_sme,
524 1.68 pgoyette sed_t->sed_edata,
525 1.67 pgoyette &lims);
526 1.73 pgoyette /*
527 1.73 pgoyette * If no values returned, don't create the event monitor at
528 1.73 pgoyette * this time. We'll get another chance later when the user
529 1.73 pgoyette * provides us with limits.
530 1.73 pgoyette */
531 1.73 pgoyette if (lims.sel_flags == 0)
532 1.73 pgoyette sed_t->sed_edata->flags &= ~ENVSYS_FMONLIMITS;
533 1.73 pgoyette
534 1.73 pgoyette /*
535 1.73 pgoyette * If driver doesn't provide a way to "absorb" user-specified
536 1.73 pgoyette * limit values, we must monitor all limits ourselves
537 1.73 pgoyette */
538 1.74 pgoyette else if (sed_t->sed_sme->sme_set_limits == NULL)
539 1.74 pgoyette lims.sel_flags &= ~PROP_DRIVER_LIMITS;
540 1.71 pgoyette
541 1.71 pgoyette /* Register the events that were specified */
542 1.67 pgoyette
543 1.1 xtraeme SEE_REGEVENT(ENVSYS_FMONCRITICAL,
544 1.1 xtraeme PENVSYS_EVENT_CRITICAL,
545 1.1 xtraeme "critical");
546 1.1 xtraeme
547 1.67 pgoyette SEE_REGEVENT(ENVSYS_FMONSTCHANGED,
548 1.67 pgoyette PENVSYS_EVENT_STATE_CHANGED,
549 1.67 pgoyette "state-changed");
550 1.67 pgoyette
551 1.64 pgoyette SEE_REGEVENT(ENVSYS_FMONLIMITS,
552 1.65 pgoyette PENVSYS_EVENT_LIMITS,
553 1.56 pgoyette "hw-range-limits");
554 1.1 xtraeme
555 1.45 xtraeme /*
556 1.45 xtraeme * we are done, free memory now.
557 1.45 xtraeme */
558 1.1 xtraeme kmem_free(sed_t, sizeof(*sed_t));
559 1.1 xtraeme }
560 1.1 xtraeme
561 1.1 xtraeme /*
562 1.1 xtraeme * sme_events_init:
563 1.1 xtraeme *
564 1.45 xtraeme * + Initialize the events framework for this device.
565 1.1 xtraeme */
566 1.1 xtraeme int
567 1.45 xtraeme sme_events_init(struct sysmon_envsys *sme)
568 1.1 xtraeme {
569 1.51 xtraeme int error = 0;
570 1.45 xtraeme uint64_t timo;
571 1.1 xtraeme
572 1.45 xtraeme KASSERT(sme != NULL);
573 1.51 xtraeme KASSERT(mutex_owned(&sme->sme_mtx));
574 1.22 xtraeme
575 1.45 xtraeme if (sme->sme_events_timeout)
576 1.45 xtraeme timo = sme->sme_events_timeout * hz;
577 1.45 xtraeme else
578 1.45 xtraeme timo = SME_EVTIMO;
579 1.45 xtraeme
580 1.45 xtraeme error = workqueue_create(&sme->sme_wq, sme->sme_name,
581 1.45 xtraeme sme_events_worker, sme, PRI_NONE, IPL_SOFTCLOCK, WQ_MPSAFE);
582 1.1 xtraeme if (error)
583 1.51 xtraeme return error;
584 1.1 xtraeme
585 1.51 xtraeme mutex_init(&sme->sme_callout_mtx, MUTEX_DEFAULT, IPL_SOFTCLOCK);
586 1.54 xtraeme callout_init(&sme->sme_callout, CALLOUT_MPSAFE);
587 1.45 xtraeme callout_setfunc(&sme->sme_callout, sme_events_check, sme);
588 1.45 xtraeme callout_schedule(&sme->sme_callout, timo);
589 1.45 xtraeme sme->sme_flags |= SME_CALLOUT_INITIALIZED;
590 1.45 xtraeme DPRINTF(("%s: events framework initialized for '%s'\n",
591 1.45 xtraeme __func__, sme->sme_name));
592 1.1 xtraeme
593 1.1 xtraeme return error;
594 1.1 xtraeme }
595 1.1 xtraeme
596 1.1 xtraeme /*
597 1.18 xtraeme * sme_events_destroy:
598 1.18 xtraeme *
599 1.51 xtraeme * + Destroys the event framework for this device: callout
600 1.51 xtraeme * stopped, workqueue destroyed and callout mutex destroyed.
601 1.18 xtraeme */
602 1.18 xtraeme void
603 1.45 xtraeme sme_events_destroy(struct sysmon_envsys *sme)
604 1.18 xtraeme {
605 1.51 xtraeme KASSERT(mutex_owned(&sme->sme_mtx));
606 1.22 xtraeme
607 1.45 xtraeme callout_stop(&sme->sme_callout);
608 1.54 xtraeme workqueue_destroy(sme->sme_wq);
609 1.54 xtraeme mutex_destroy(&sme->sme_callout_mtx);
610 1.54 xtraeme callout_destroy(&sme->sme_callout);
611 1.45 xtraeme sme->sme_flags &= ~SME_CALLOUT_INITIALIZED;
612 1.45 xtraeme DPRINTF(("%s: events framework destroyed for '%s'\n",
613 1.45 xtraeme __func__, sme->sme_name));
614 1.18 xtraeme }
615 1.18 xtraeme
616 1.18 xtraeme /*
617 1.1 xtraeme * sme_events_check:
618 1.1 xtraeme *
619 1.51 xtraeme * + Passes the events to the workqueue thread and stops
620 1.51 xtraeme * the callout if the 'low-power' condition is triggered.
621 1.1 xtraeme */
622 1.1 xtraeme void
623 1.1 xtraeme sme_events_check(void *arg)
624 1.1 xtraeme {
625 1.45 xtraeme struct sysmon_envsys *sme = arg;
626 1.1 xtraeme sme_event_t *see;
627 1.45 xtraeme uint64_t timo;
628 1.45 xtraeme
629 1.45 xtraeme KASSERT(sme != NULL);
630 1.45 xtraeme
631 1.51 xtraeme mutex_enter(&sme->sme_callout_mtx);
632 1.51 xtraeme LIST_FOREACH(see, &sme->sme_events_list, see_list) {
633 1.45 xtraeme workqueue_enqueue(sme->sme_wq, &see->see_wk, NULL);
634 1.56 pgoyette see->see_edata->flags |= ENVSYS_FNEED_REFRESH;
635 1.51 xtraeme }
636 1.45 xtraeme if (sme->sme_events_timeout)
637 1.45 xtraeme timo = sme->sme_events_timeout * hz;
638 1.45 xtraeme else
639 1.45 xtraeme timo = SME_EVTIMO;
640 1.38 xtraeme if (!sysmon_low_power)
641 1.45 xtraeme callout_schedule(&sme->sme_callout, timo);
642 1.51 xtraeme mutex_exit(&sme->sme_callout_mtx);
643 1.1 xtraeme }
644 1.1 xtraeme
645 1.1 xtraeme /*
646 1.1 xtraeme * sme_events_worker:
647 1.1 xtraeme *
648 1.1 xtraeme * + workqueue thread that checks if there's a critical condition
649 1.51 xtraeme * and sends an event if it was triggered.
650 1.1 xtraeme */
651 1.1 xtraeme void
652 1.1 xtraeme sme_events_worker(struct work *wk, void *arg)
653 1.1 xtraeme {
654 1.28 xtraeme const struct sme_description_table *sdt = NULL;
655 1.10 xtraeme const struct sme_sensor_event *sse = sme_sensor_event;
656 1.1 xtraeme sme_event_t *see = (void *)wk;
657 1.51 xtraeme struct sysmon_envsys *sme = see->see_sme;
658 1.51 xtraeme envsys_data_t *edata = see->see_edata;
659 1.51 xtraeme int i, state = 0;
660 1.1 xtraeme
661 1.1 xtraeme KASSERT(wk == &see->see_wk);
662 1.51 xtraeme KASSERT(sme != NULL || edata != NULL);
663 1.1 xtraeme
664 1.51 xtraeme mutex_enter(&sme->sme_mtx);
665 1.56 pgoyette if ((see->see_flags & SEE_EVENT_WORKING) == 0)
666 1.56 pgoyette see->see_flags |= SEE_EVENT_WORKING;
667 1.1 xtraeme /*
668 1.65 pgoyette * sme_events_check marks the sensors to make us refresh them here.
669 1.65 pgoyette * Don't refresh if the driver uses its own method for refreshing.
670 1.1 xtraeme */
671 1.45 xtraeme if ((sme->sme_flags & SME_DISABLE_REFRESH) == 0) {
672 1.65 pgoyette if ((edata->flags & ENVSYS_FNEED_REFRESH) != 0) {
673 1.51 xtraeme /* refresh sensor in device */
674 1.51 xtraeme (*sme->sme_refresh)(sme, edata);
675 1.65 pgoyette edata->flags &= ~ENVSYS_FNEED_REFRESH;
676 1.42 xtraeme }
677 1.1 xtraeme }
678 1.1 xtraeme
679 1.56 pgoyette DPRINTFOBJ(("%s: (%s) desc=%s sensor=%d type=%d state=%d units=%d "
680 1.51 xtraeme "value_cur=%d\n", __func__, sme->sme_name, edata->desc,
681 1.56 pgoyette edata->sensor, see->see_type, edata->state, edata->units,
682 1.56 pgoyette edata->value_cur));
683 1.1 xtraeme
684 1.50 xtraeme /* skip the event if current sensor is in invalid state */
685 1.51 xtraeme if (edata->state == ENVSYS_SINVALID)
686 1.50 xtraeme goto out;
687 1.50 xtraeme
688 1.45 xtraeme switch (see->see_type) {
689 1.10 xtraeme /*
690 1.67 pgoyette * For range limits, if the driver claims responsibility for
691 1.67 pgoyette * limit/range checking, just user driver-supplied status.
692 1.67 pgoyette * Else calculate our own status. Note that driver must
693 1.67 pgoyette * relinquish responsibility for ALL limits if there is even
694 1.67 pgoyette * one limit that it cannot handle!
695 1.56 pgoyette */
696 1.65 pgoyette case PENVSYS_EVENT_LIMITS:
697 1.65 pgoyette case PENVSYS_EVENT_CAPACITY:
698 1.71 pgoyette #define __EXCEED_LIM(valid, lim, rel) \
699 1.76 pgoyette ((edata->limits.sel_flags & (valid)) && \
700 1.76 pgoyette (edata->value_cur rel (edata->limits.lim)))
701 1.71 pgoyette
702 1.76 pgoyette if ((edata->limits.sel_flags & PROP_DRIVER_LIMITS) == 0) {
703 1.71 pgoyette if __EXCEED_LIM(PROP_CRITMIN | PROP_BATTCAP,
704 1.71 pgoyette sel_critmin, <)
705 1.67 pgoyette edata->state = ENVSYS_SCRITUNDER;
706 1.71 pgoyette else if __EXCEED_LIM(PROP_WARNMIN | PROP_BATTWARN,
707 1.71 pgoyette sel_warnmin, <)
708 1.67 pgoyette edata->state = ENVSYS_SWARNUNDER;
709 1.72 pgoyette else if __EXCEED_LIM(PROP_CRITMAX, sel_critmax, >)
710 1.72 pgoyette edata->state = ENVSYS_SCRITOVER;
711 1.71 pgoyette else if __EXCEED_LIM(PROP_WARNMAX, sel_warnmax, >)
712 1.67 pgoyette edata->state = ENVSYS_SWARNOVER;
713 1.75 pgoyette else
714 1.75 pgoyette edata->state = ENVSYS_SVALID;
715 1.67 pgoyette }
716 1.67 pgoyette #undef __EXCEED_LIM
717 1.65 pgoyette
718 1.67 pgoyette /*
719 1.67 pgoyette * Send event if state has changed
720 1.67 pgoyette */
721 1.58 pgoyette if (edata->state == see->see_evsent)
722 1.58 pgoyette break;
723 1.56 pgoyette
724 1.58 pgoyette for (i = 0; sse[i].state != -1; i++)
725 1.58 pgoyette if (sse[i].state == edata->state)
726 1.10 xtraeme break;
727 1.1 xtraeme
728 1.58 pgoyette if (sse[i].state == -1)
729 1.58 pgoyette break;
730 1.58 pgoyette
731 1.58 pgoyette if (edata->state == ENVSYS_SVALID)
732 1.58 pgoyette sysmon_penvsys_event(&see->see_pes,
733 1.58 pgoyette PENVSYS_EVENT_NORMAL);
734 1.58 pgoyette else
735 1.58 pgoyette sysmon_penvsys_event(&see->see_pes, sse[i].event);
736 1.58 pgoyette
737 1.58 pgoyette see->see_evsent = edata->state;
738 1.58 pgoyette
739 1.58 pgoyette break;
740 1.1 xtraeme
741 1.58 pgoyette /*
742 1.59 pgoyette * Send PENVSYS_EVENT_CRITICAL event if:
743 1.59 pgoyette * State has gone from non-CRITICAL to CRITICAL,
744 1.59 pgoyette * State remains CRITICAL and value has changed, or
745 1.59 pgoyette * State has returned from CRITICAL to non-CRITICAL
746 1.58 pgoyette */
747 1.58 pgoyette case PENVSYS_EVENT_CRITICAL:
748 1.59 pgoyette if (edata->state == ENVSYS_SVALID &&
749 1.59 pgoyette see->see_evsent != 0) {
750 1.58 pgoyette sysmon_penvsys_event(&see->see_pes,
751 1.58 pgoyette PENVSYS_EVENT_NORMAL);
752 1.59 pgoyette see->see_evsent = 0;
753 1.59 pgoyette } else if (edata->state == ENVSYS_SCRITICAL &&
754 1.59 pgoyette see->see_evsent != edata->value_cur) {
755 1.58 pgoyette sysmon_penvsys_event(&see->see_pes,
756 1.58 pgoyette PENVSYS_EVENT_CRITICAL);
757 1.60 pgoyette see->see_evsent = edata->value_cur;
758 1.56 pgoyette }
759 1.1 xtraeme break;
760 1.1 xtraeme
761 1.10 xtraeme /*
762 1.28 xtraeme * if value_cur is not normal (battery) or online (drive),
763 1.28 xtraeme * send the event...
764 1.10 xtraeme */
765 1.28 xtraeme case PENVSYS_EVENT_STATE_CHANGED:
766 1.45 xtraeme /*
767 1.45 xtraeme * the state has not been changed, just ignore the event.
768 1.45 xtraeme */
769 1.51 xtraeme if (edata->value_cur == see->see_evsent)
770 1.1 xtraeme break;
771 1.1 xtraeme
772 1.51 xtraeme switch (edata->units) {
773 1.28 xtraeme case ENVSYS_DRIVE:
774 1.28 xtraeme sdt = sme_get_description_table(SME_DESC_DRIVE_STATES);
775 1.28 xtraeme state = ENVSYS_DRIVE_ONLINE;
776 1.28 xtraeme break;
777 1.44 xtraeme case ENVSYS_BATTERY_CAPACITY:
778 1.51 xtraeme sdt = sme_get_description_table(
779 1.51 xtraeme SME_DESC_BATTERY_CAPACITY);
780 1.44 xtraeme state = ENVSYS_BATTERY_CAPACITY_NORMAL;
781 1.28 xtraeme break;
782 1.34 xtraeme default:
783 1.65 pgoyette panic("%s: bad units for PENVSYS_EVENT_STATE_CHANGED",
784 1.35 xtraeme __func__);
785 1.28 xtraeme }
786 1.28 xtraeme
787 1.28 xtraeme for (i = 0; sdt[i].type != -1; i++)
788 1.51 xtraeme if (sdt[i].type == edata->value_cur)
789 1.1 xtraeme break;
790 1.1 xtraeme
791 1.51 xtraeme if (sdt[i].type == -1)
792 1.51 xtraeme break;
793 1.51 xtraeme
794 1.45 xtraeme /*
795 1.45 xtraeme * copy current state description.
796 1.45 xtraeme */
797 1.45 xtraeme (void)strlcpy(see->see_pes.pes_statedesc, sdt[i].desc,
798 1.45 xtraeme sizeof(see->see_pes.pes_statedesc));
799 1.1 xtraeme
800 1.65 pgoyette if (edata->value_cur == state)
801 1.65 pgoyette /*
802 1.65 pgoyette * state returned to normal condition
803 1.65 pgoyette */
804 1.56 pgoyette sysmon_penvsys_event(&see->see_pes,
805 1.56 pgoyette PENVSYS_EVENT_NORMAL);
806 1.65 pgoyette else
807 1.65 pgoyette /*
808 1.65 pgoyette * state changed to abnormal condition
809 1.45 xtraeme */
810 1.45 xtraeme sysmon_penvsys_event(&see->see_pes, see->see_type);
811 1.65 pgoyette
812 1.65 pgoyette see->see_evsent = edata->value_cur;
813 1.1 xtraeme
814 1.49 xtraeme /*
815 1.49 xtraeme * There's no need to continue if it's a drive sensor.
816 1.49 xtraeme */
817 1.51 xtraeme if (edata->units == ENVSYS_DRIVE)
818 1.49 xtraeme break;
819 1.49 xtraeme
820 1.39 xtraeme /*
821 1.39 xtraeme * Check if the system is running in low power and send the
822 1.39 xtraeme * event to powerd (if running) or shutdown the system
823 1.39 xtraeme * otherwise.
824 1.39 xtraeme */
825 1.39 xtraeme if (!sysmon_low_power && sme_event_check_low_power()) {
826 1.39 xtraeme struct penvsys_state pes;
827 1.39 xtraeme
828 1.45 xtraeme /*
829 1.45 xtraeme * Stop the callout and send the 'low-power' event.
830 1.45 xtraeme */
831 1.45 xtraeme sysmon_low_power = true;
832 1.45 xtraeme callout_stop(&sme->sme_callout);
833 1.39 xtraeme pes.pes_type = PENVSYS_TYPE_BATTERY;
834 1.39 xtraeme sysmon_penvsys_event(&pes, PENVSYS_EVENT_LOW_POWER);
835 1.39 xtraeme }
836 1.1 xtraeme break;
837 1.56 pgoyette default:
838 1.56 pgoyette panic("%s: invalid event type %d", __func__, see->see_type);
839 1.1 xtraeme }
840 1.45 xtraeme
841 1.50 xtraeme out:
842 1.56 pgoyette see->see_flags &= ~SEE_EVENT_WORKING;
843 1.51 xtraeme cv_broadcast(&sme->sme_condvar);
844 1.51 xtraeme mutex_exit(&sme->sme_mtx);
845 1.1 xtraeme }
846 1.38 xtraeme
847 1.47 xtraeme /*
848 1.51 xtraeme * Returns true if the system is in low power state: an AC adapter
849 1.51 xtraeme * is OFF and all batteries are in LOW/CRITICAL state.
850 1.47 xtraeme */
851 1.44 xtraeme static bool
852 1.38 xtraeme sme_event_check_low_power(void)
853 1.38 xtraeme {
854 1.47 xtraeme if (!sme_acadapter_check())
855 1.47 xtraeme return false;
856 1.47 xtraeme
857 1.47 xtraeme return sme_battery_check();
858 1.47 xtraeme }
859 1.47 xtraeme
860 1.51 xtraeme /*
861 1.51 xtraeme * Called with the sysmon_envsys device mtx held through the
862 1.51 xtraeme * workqueue thread.
863 1.51 xtraeme */
864 1.47 xtraeme static bool
865 1.47 xtraeme sme_acadapter_check(void)
866 1.47 xtraeme {
867 1.38 xtraeme struct sysmon_envsys *sme;
868 1.38 xtraeme envsys_data_t *edata;
869 1.50 xtraeme bool dev = false, sensor = false;
870 1.38 xtraeme
871 1.50 xtraeme LIST_FOREACH(sme, &sysmon_envsys_list, sme_list) {
872 1.50 xtraeme if (sme->sme_class == SME_CLASS_ACADAPTER) {
873 1.50 xtraeme dev = true;
874 1.38 xtraeme break;
875 1.50 xtraeme }
876 1.50 xtraeme }
877 1.51 xtraeme
878 1.38 xtraeme /*
879 1.47 xtraeme * No AC Adapter devices were found.
880 1.38 xtraeme */
881 1.50 xtraeme if (!dev)
882 1.44 xtraeme return false;
883 1.51 xtraeme
884 1.44 xtraeme /*
885 1.47 xtraeme * Check if there's an AC adapter device connected.
886 1.44 xtraeme */
887 1.45 xtraeme TAILQ_FOREACH(edata, &sme->sme_sensors_list, sensors_head) {
888 1.38 xtraeme if (edata->units == ENVSYS_INDICATOR) {
889 1.47 xtraeme sensor = true;
890 1.50 xtraeme /* refresh current sensor */
891 1.50 xtraeme (*sme->sme_refresh)(sme, edata);
892 1.44 xtraeme if (edata->value_cur)
893 1.44 xtraeme return false;
894 1.38 xtraeme }
895 1.38 xtraeme }
896 1.51 xtraeme
897 1.47 xtraeme if (!sensor)
898 1.47 xtraeme return false;
899 1.47 xtraeme
900 1.51 xtraeme /*
901 1.51 xtraeme * AC adapter found and not connected.
902 1.51 xtraeme */
903 1.47 xtraeme return true;
904 1.47 xtraeme }
905 1.47 xtraeme
906 1.51 xtraeme /*
907 1.51 xtraeme * Called with the sysmon_envsys device mtx held through the
908 1.51 xtraeme * workqueue thread.
909 1.51 xtraeme */
910 1.47 xtraeme static bool
911 1.47 xtraeme sme_battery_check(void)
912 1.47 xtraeme {
913 1.47 xtraeme struct sysmon_envsys *sme;
914 1.47 xtraeme envsys_data_t *edata;
915 1.55 drochner int batteriesfound = 0;
916 1.55 drochner bool present, batterycap, batterycharge;
917 1.44 xtraeme
918 1.38 xtraeme /*
919 1.44 xtraeme * Check for battery devices and its state.
920 1.38 xtraeme */
921 1.44 xtraeme LIST_FOREACH(sme, &sysmon_envsys_list, sme_list) {
922 1.44 xtraeme if (sme->sme_class != SME_CLASS_BATTERY)
923 1.44 xtraeme continue;
924 1.38 xtraeme
925 1.55 drochner present = true;
926 1.55 drochner TAILQ_FOREACH(edata, &sme->sme_sensors_list, sensors_head) {
927 1.55 drochner if (edata->units == ENVSYS_INDICATOR &&
928 1.55 drochner !edata->value_cur) {
929 1.55 drochner present = false;
930 1.55 drochner break;
931 1.55 drochner }
932 1.55 drochner }
933 1.55 drochner if (!present)
934 1.55 drochner continue;
935 1.44 xtraeme /*
936 1.44 xtraeme * We've found a battery device...
937 1.44 xtraeme */
938 1.55 drochner batteriesfound++;
939 1.55 drochner batterycap = batterycharge = false;
940 1.45 xtraeme TAILQ_FOREACH(edata, &sme->sme_sensors_list, sensors_head) {
941 1.44 xtraeme if (edata->units == ENVSYS_BATTERY_CAPACITY) {
942 1.44 xtraeme batterycap = true;
943 1.44 xtraeme if (!sme_battery_critical(edata))
944 1.44 xtraeme return false;
945 1.44 xtraeme } else if (edata->units == ENVSYS_BATTERY_CHARGE) {
946 1.44 xtraeme batterycharge = true;
947 1.44 xtraeme if (edata->value_cur)
948 1.44 xtraeme return false;
949 1.38 xtraeme }
950 1.38 xtraeme }
951 1.55 drochner if (!batterycap || !batterycharge)
952 1.55 drochner return false;
953 1.38 xtraeme }
954 1.51 xtraeme
955 1.55 drochner if (!batteriesfound)
956 1.44 xtraeme return false;
957 1.38 xtraeme
958 1.38 xtraeme /*
959 1.44 xtraeme * All batteries in low/critical capacity and discharging.
960 1.38 xtraeme */
961 1.44 xtraeme return true;
962 1.44 xtraeme }
963 1.38 xtraeme
964 1.44 xtraeme static bool
965 1.44 xtraeme sme_battery_critical(envsys_data_t *edata)
966 1.44 xtraeme {
967 1.44 xtraeme if (edata->value_cur == ENVSYS_BATTERY_CAPACITY_CRITICAL ||
968 1.44 xtraeme edata->value_cur == ENVSYS_BATTERY_CAPACITY_LOW)
969 1.44 xtraeme return true;
970 1.44 xtraeme
971 1.44 xtraeme return false;
972 1.38 xtraeme }
973