sysmon_envsys.c revision 1.84 1 1.84 jmcneill /* $NetBSD: sysmon_envsys.c,v 1.84 2008/06/03 15:00:57 jmcneill Exp $ */
2 1.18 xtraeme
3 1.18 xtraeme /*-
4 1.81 xtraeme * Copyright (c) 2007, 2008 Juan Romero Pardines.
5 1.18 xtraeme * All rights reserved.
6 1.18 xtraeme *
7 1.18 xtraeme * Redistribution and use in source and binary forms, with or without
8 1.18 xtraeme * modification, are permitted provided that the following conditions
9 1.18 xtraeme * are met:
10 1.18 xtraeme * 1. Redistributions of source code must retain the above copyright
11 1.18 xtraeme * notice, this list of conditions and the following disclaimer.
12 1.18 xtraeme * 2. Redistributions in binary form must reproduce the above copyright
13 1.18 xtraeme * notice, this list of conditions and the following disclaimer in the
14 1.18 xtraeme * documentation and/or other materials provided with the distribution.
15 1.69 xtraeme *
16 1.69 xtraeme * THIS SOFTWARE IS PROVIDED BY THE AUTHOR ``AS IS'' AND ANY EXPRESS OR
17 1.69 xtraeme * IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE IMPLIED WARRANTIES
18 1.69 xtraeme * OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE ARE DISCLAIMED.
19 1.69 xtraeme * IN NO EVENT SHALL THE AUTHOR BE LIABLE FOR ANY DIRECT, INDIRECT,
20 1.69 xtraeme * INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT
21 1.69 xtraeme * NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE,
22 1.69 xtraeme * DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY
23 1.69 xtraeme * THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT
24 1.69 xtraeme * (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE OF
25 1.69 xtraeme * THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.
26 1.18 xtraeme */
27 1.1 thorpej
28 1.1 thorpej /*-
29 1.1 thorpej * Copyright (c) 2000 Zembu Labs, Inc.
30 1.1 thorpej * All rights reserved.
31 1.1 thorpej *
32 1.1 thorpej * Author: Jason R. Thorpe <thorpej (at) zembu.com>
33 1.1 thorpej *
34 1.1 thorpej * Redistribution and use in source and binary forms, with or without
35 1.1 thorpej * modification, are permitted provided that the following conditions
36 1.1 thorpej * are met:
37 1.1 thorpej * 1. Redistributions of source code must retain the above copyright
38 1.1 thorpej * notice, this list of conditions and the following disclaimer.
39 1.1 thorpej * 2. Redistributions in binary form must reproduce the above copyright
40 1.1 thorpej * notice, this list of conditions and the following disclaimer in the
41 1.1 thorpej * documentation and/or other materials provided with the distribution.
42 1.1 thorpej * 3. All advertising materials mentioning features or use of this software
43 1.1 thorpej * must display the following acknowledgement:
44 1.1 thorpej * This product includes software developed by Zembu Labs, Inc.
45 1.1 thorpej * 4. Neither the name of Zembu Labs nor the names of its employees may
46 1.1 thorpej * be used to endorse or promote products derived from this software
47 1.1 thorpej * without specific prior written permission.
48 1.1 thorpej *
49 1.1 thorpej * THIS SOFTWARE IS PROVIDED BY ZEMBU LABS, INC. ``AS IS'' AND ANY EXPRESS
50 1.1 thorpej * OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE IMPLIED WAR-
51 1.1 thorpej * RANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE ARE DIS-
52 1.1 thorpej * CLAIMED. IN NO EVENT SHALL ZEMBU LABS BE LIABLE FOR ANY DIRECT, INDIRECT,
53 1.1 thorpej * INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT
54 1.1 thorpej * NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE,
55 1.1 thorpej * DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY
56 1.1 thorpej * THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT
57 1.1 thorpej * (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE OF
58 1.1 thorpej * THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.
59 1.1 thorpej */
60 1.1 thorpej
61 1.1 thorpej /*
62 1.18 xtraeme * Environmental sensor framework for sysmon, exported to userland
63 1.18 xtraeme * with proplib(3).
64 1.1 thorpej */
65 1.2 lukem
66 1.2 lukem #include <sys/cdefs.h>
67 1.84 jmcneill __KERNEL_RCSID(0, "$NetBSD: sysmon_envsys.c,v 1.84 2008/06/03 15:00:57 jmcneill Exp $");
68 1.1 thorpej
69 1.1 thorpej #include <sys/param.h>
70 1.18 xtraeme #include <sys/types.h>
71 1.1 thorpej #include <sys/conf.h>
72 1.1 thorpej #include <sys/errno.h>
73 1.22 xtraeme #include <sys/fcntl.h>
74 1.1 thorpej #include <sys/kernel.h>
75 1.1 thorpej #include <sys/systm.h>
76 1.1 thorpej #include <sys/proc.h>
77 1.18 xtraeme #include <sys/mutex.h>
78 1.18 xtraeme #include <sys/kmem.h>
79 1.1 thorpej
80 1.60 xtraeme /* #define ENVSYS_DEBUG */
81 1.1 thorpej #include <dev/sysmon/sysmonvar.h>
82 1.18 xtraeme #include <dev/sysmon/sysmon_envsysvar.h>
83 1.18 xtraeme #include <dev/sysmon/sysmon_taskq.h>
84 1.1 thorpej
85 1.82 xtraeme kmutex_t sme_global_mtx;
86 1.41 xtraeme
87 1.69 xtraeme /*
88 1.69 xtraeme * Types of properties that can be set via userland.
89 1.69 xtraeme */
90 1.69 xtraeme enum {
91 1.69 xtraeme USERPROP_DESC = 0x0001,
92 1.69 xtraeme USERPROP_BATTCAP = 0x0002,
93 1.69 xtraeme USERPROP_CRITMAX = 0x0004,
94 1.69 xtraeme USERPROP_CRITMIN = 0x0008,
95 1.69 xtraeme USERPROP_RFACT = 0x0010
96 1.69 xtraeme };
97 1.69 xtraeme
98 1.61 xtraeme static prop_dictionary_t sme_propd;
99 1.82 xtraeme static uint32_t sysmon_envsys_next_sensor_index;
100 1.18 xtraeme static struct sysmon_envsys *sysmon_envsys_find_40(u_int);
101 1.1 thorpej
102 1.53 xtraeme static void sysmon_envsys_destroy_plist(prop_array_t);
103 1.69 xtraeme static void sme_remove_userprops(void);
104 1.72 xtraeme static int sme_add_property_dictionary(struct sysmon_envsys *, prop_array_t,
105 1.72 xtraeme prop_dictionary_t);
106 1.81 xtraeme static void sme_initial_refresh(void *);
107 1.1 thorpej
108 1.18 xtraeme /*
109 1.18 xtraeme * sysmon_envsys_init:
110 1.18 xtraeme *
111 1.82 xtraeme * + Initialize global mutex, dictionary and the linked list.
112 1.18 xtraeme */
113 1.18 xtraeme void
114 1.18 xtraeme sysmon_envsys_init(void)
115 1.18 xtraeme {
116 1.18 xtraeme LIST_INIT(&sysmon_envsys_list);
117 1.82 xtraeme mutex_init(&sme_global_mtx, MUTEX_DEFAULT, IPL_NONE);
118 1.18 xtraeme sme_propd = prop_dictionary_create();
119 1.18 xtraeme }
120 1.1 thorpej
121 1.1 thorpej /*
122 1.1 thorpej * sysmonopen_envsys:
123 1.1 thorpej *
124 1.18 xtraeme * + Open the system monitor device.
125 1.1 thorpej */
126 1.1 thorpej int
127 1.18 xtraeme sysmonopen_envsys(dev_t dev, int flag, int mode, struct lwp *l)
128 1.1 thorpej {
129 1.18 xtraeme return 0;
130 1.1 thorpej }
131 1.1 thorpej
132 1.1 thorpej /*
133 1.1 thorpej * sysmonclose_envsys:
134 1.1 thorpej *
135 1.18 xtraeme * + Close the system monitor device.
136 1.1 thorpej */
137 1.1 thorpej int
138 1.18 xtraeme sysmonclose_envsys(dev_t dev, int flag, int mode, struct lwp *l)
139 1.1 thorpej {
140 1.18 xtraeme return 0;
141 1.1 thorpej }
142 1.1 thorpej
143 1.1 thorpej /*
144 1.1 thorpej * sysmonioctl_envsys:
145 1.1 thorpej *
146 1.52 xtraeme * + Perform a sysmon envsys control request.
147 1.1 thorpej */
148 1.1 thorpej int
149 1.18 xtraeme sysmonioctl_envsys(dev_t dev, u_long cmd, void *data, int flag, struct lwp *l)
150 1.1 thorpej {
151 1.18 xtraeme struct sysmon_envsys *sme = NULL;
152 1.1 thorpej int error = 0;
153 1.1 thorpej u_int oidx;
154 1.1 thorpej
155 1.1 thorpej switch (cmd) {
156 1.72 xtraeme /*
157 1.72 xtraeme * To update the global dictionary with latest data from devices.
158 1.72 xtraeme */
159 1.18 xtraeme case ENVSYS_GETDICTIONARY:
160 1.18 xtraeme {
161 1.18 xtraeme struct plistref *plist = (struct plistref *)data;
162 1.56 xtraeme
163 1.18 xtraeme /*
164 1.72 xtraeme * Update dictionaries on all sysmon envsys devices
165 1.72 xtraeme * registered.
166 1.18 xtraeme */
167 1.82 xtraeme mutex_enter(&sme_global_mtx);
168 1.18 xtraeme LIST_FOREACH(sme, &sysmon_envsys_list, sme_list) {
169 1.82 xtraeme sysmon_envsys_acquire(sme, false);
170 1.18 xtraeme error = sme_update_dictionary(sme);
171 1.18 xtraeme if (error) {
172 1.18 xtraeme DPRINTF(("%s: sme_update_dictionary, "
173 1.18 xtraeme "error=%d\n", __func__, error));
174 1.82 xtraeme sysmon_envsys_release(sme, false);
175 1.82 xtraeme mutex_exit(&sme_global_mtx);
176 1.18 xtraeme return error;
177 1.18 xtraeme }
178 1.82 xtraeme sysmon_envsys_release(sme, false);
179 1.18 xtraeme }
180 1.82 xtraeme mutex_exit(&sme_global_mtx);
181 1.18 xtraeme /*
182 1.18 xtraeme * Copy global dictionary to userland.
183 1.18 xtraeme */
184 1.18 xtraeme error = prop_dictionary_copyout_ioctl(plist, cmd, sme_propd);
185 1.1 thorpej break;
186 1.18 xtraeme }
187 1.72 xtraeme /*
188 1.72 xtraeme * To set properties on multiple devices.
189 1.72 xtraeme */
190 1.18 xtraeme case ENVSYS_SETDICTIONARY:
191 1.1 thorpej {
192 1.18 xtraeme const struct plistref *plist = (const struct plistref *)data;
193 1.18 xtraeme prop_dictionary_t udict;
194 1.69 xtraeme prop_object_iterator_t iter, iter2;
195 1.69 xtraeme prop_object_t obj, obj2;
196 1.69 xtraeme prop_array_t array_u, array_k;
197 1.18 xtraeme const char *devname = NULL;
198 1.18 xtraeme
199 1.22 xtraeme if ((flag & FWRITE) == 0)
200 1.22 xtraeme return EPERM;
201 1.22 xtraeme
202 1.18 xtraeme /*
203 1.18 xtraeme * Get dictionary from userland.
204 1.18 xtraeme */
205 1.18 xtraeme error = prop_dictionary_copyin_ioctl(plist, cmd, &udict);
206 1.41 xtraeme if (error) {
207 1.41 xtraeme DPRINTF(("%s: copyin_ioctl error=%d\n",
208 1.41 xtraeme __func__, error));
209 1.18 xtraeme break;
210 1.41 xtraeme }
211 1.4 explorer
212 1.69 xtraeme iter = prop_dictionary_iterator(udict);
213 1.69 xtraeme if (!iter) {
214 1.69 xtraeme prop_object_release(udict);
215 1.69 xtraeme return ENOMEM;
216 1.69 xtraeme }
217 1.69 xtraeme
218 1.18 xtraeme /*
219 1.69 xtraeme * Iterate over the userland dictionary and process
220 1.69 xtraeme * the list of devices.
221 1.18 xtraeme */
222 1.69 xtraeme while ((obj = prop_object_iterator_next(iter))) {
223 1.69 xtraeme array_u = prop_dictionary_get_keysym(udict, obj);
224 1.69 xtraeme if (prop_object_type(array_u) != PROP_TYPE_ARRAY) {
225 1.69 xtraeme prop_object_iterator_release(iter);
226 1.69 xtraeme prop_object_release(udict);
227 1.69 xtraeme return EINVAL;
228 1.69 xtraeme }
229 1.69 xtraeme
230 1.69 xtraeme devname = prop_dictionary_keysym_cstring_nocopy(obj);
231 1.69 xtraeme DPRINTF(("%s: processing the '%s' array requests\n",
232 1.69 xtraeme __func__, devname));
233 1.69 xtraeme
234 1.69 xtraeme /*
235 1.69 xtraeme * find the correct sme device.
236 1.69 xtraeme */
237 1.69 xtraeme sme = sysmon_envsys_find(devname);
238 1.69 xtraeme if (!sme) {
239 1.69 xtraeme DPRINTF(("%s: NULL sme\n", __func__));
240 1.69 xtraeme prop_object_iterator_release(iter);
241 1.69 xtraeme prop_object_release(udict);
242 1.69 xtraeme return EINVAL;
243 1.69 xtraeme }
244 1.69 xtraeme
245 1.69 xtraeme /*
246 1.69 xtraeme * Find the correct array object with the string
247 1.69 xtraeme * supplied by the userland dictionary.
248 1.69 xtraeme */
249 1.69 xtraeme array_k = prop_dictionary_get(sme_propd, devname);
250 1.69 xtraeme if (prop_object_type(array_k) != PROP_TYPE_ARRAY) {
251 1.69 xtraeme DPRINTF(("%s: array device failed\n",
252 1.69 xtraeme __func__));
253 1.82 xtraeme sysmon_envsys_release(sme, false);
254 1.69 xtraeme prop_object_iterator_release(iter);
255 1.69 xtraeme prop_object_release(udict);
256 1.69 xtraeme return EINVAL;
257 1.69 xtraeme }
258 1.69 xtraeme
259 1.69 xtraeme iter2 = prop_array_iterator(array_u);
260 1.69 xtraeme if (!iter2) {
261 1.82 xtraeme sysmon_envsys_release(sme, false);
262 1.69 xtraeme prop_object_iterator_release(iter);
263 1.69 xtraeme prop_object_release(udict);
264 1.69 xtraeme return ENOMEM;
265 1.69 xtraeme }
266 1.69 xtraeme
267 1.69 xtraeme /*
268 1.69 xtraeme * Iterate over the array of dictionaries to
269 1.72 xtraeme * process the list of sensors and properties.
270 1.69 xtraeme */
271 1.69 xtraeme while ((obj2 = prop_object_iterator_next(iter2))) {
272 1.72 xtraeme /*
273 1.72 xtraeme * do the real work now.
274 1.72 xtraeme */
275 1.69 xtraeme error = sme_userset_dictionary(sme,
276 1.69 xtraeme obj2,
277 1.69 xtraeme array_k);
278 1.69 xtraeme if (error) {
279 1.82 xtraeme sysmon_envsys_release(sme, false);
280 1.69 xtraeme prop_object_iterator_release(iter2);
281 1.69 xtraeme prop_object_iterator_release(iter);
282 1.69 xtraeme prop_object_release(udict);
283 1.72 xtraeme return error;
284 1.69 xtraeme }
285 1.69 xtraeme }
286 1.69 xtraeme
287 1.82 xtraeme sysmon_envsys_release(sme, false);
288 1.69 xtraeme prop_object_iterator_release(iter2);
289 1.18 xtraeme }
290 1.4 explorer
291 1.69 xtraeme prop_object_iterator_release(iter);
292 1.69 xtraeme prop_object_release(udict);
293 1.69 xtraeme break;
294 1.69 xtraeme }
295 1.72 xtraeme /*
296 1.72 xtraeme * To remove all properties from all devices registered.
297 1.72 xtraeme */
298 1.69 xtraeme case ENVSYS_REMOVEPROPS:
299 1.69 xtraeme {
300 1.69 xtraeme const struct plistref *plist = (const struct plistref *)data;
301 1.69 xtraeme prop_dictionary_t udict;
302 1.69 xtraeme prop_object_t obj;
303 1.69 xtraeme
304 1.69 xtraeme if ((flag & FWRITE) == 0)
305 1.69 xtraeme return EPERM;
306 1.4 explorer
307 1.69 xtraeme error = prop_dictionary_copyin_ioctl(plist, cmd, &udict);
308 1.69 xtraeme if (error) {
309 1.69 xtraeme DPRINTF(("%s: copyin_ioctl error=%d\n",
310 1.69 xtraeme __func__, error));
311 1.4 explorer break;
312 1.4 explorer }
313 1.1 thorpej
314 1.69 xtraeme obj = prop_dictionary_get(udict, "envsys-remove-props");
315 1.69 xtraeme if (!obj || !prop_bool_true(obj)) {
316 1.69 xtraeme DPRINTF(("%s: invalid 'envsys-remove-props'\n",
317 1.69 xtraeme __func__));
318 1.69 xtraeme return EINVAL;
319 1.1 thorpej }
320 1.18 xtraeme
321 1.72 xtraeme prop_object_release(udict);
322 1.69 xtraeme sme_remove_userprops();
323 1.69 xtraeme
324 1.1 thorpej break;
325 1.1 thorpej }
326 1.72 xtraeme /*
327 1.72 xtraeme * Compatibility ioctls with the old interface, only implemented
328 1.72 xtraeme * ENVSYS_GTREDATA and ENVSYS_GTREINFO; enough to make old
329 1.72 xtraeme * applications work.
330 1.72 xtraeme */
331 1.1 thorpej case ENVSYS_GTREDATA:
332 1.1 thorpej {
333 1.18 xtraeme struct envsys_tre_data *tred = (void *)data;
334 1.18 xtraeme envsys_data_t *edata = NULL;
335 1.72 xtraeme bool found = false;
336 1.1 thorpej
337 1.1 thorpej tred->validflags = 0;
338 1.1 thorpej
339 1.18 xtraeme sme = sysmon_envsys_find_40(tred->sensor);
340 1.82 xtraeme if (!sme)
341 1.1 thorpej break;
342 1.18 xtraeme
343 1.1 thorpej oidx = tred->sensor;
344 1.1 thorpej tred->sensor = SME_SENSOR_IDX(sme, tred->sensor);
345 1.18 xtraeme
346 1.18 xtraeme DPRINTFOBJ(("%s: sensor=%d oidx=%d dev=%s nsensors=%d\n",
347 1.18 xtraeme __func__, tred->sensor, oidx, sme->sme_name,
348 1.18 xtraeme sme->sme_nsensors));
349 1.18 xtraeme
350 1.72 xtraeme TAILQ_FOREACH(edata, &sme->sme_sensors_list, sensors_head) {
351 1.72 xtraeme if (edata->sensor == tred->sensor) {
352 1.72 xtraeme found = true;
353 1.72 xtraeme break;
354 1.72 xtraeme }
355 1.72 xtraeme }
356 1.72 xtraeme
357 1.72 xtraeme if (!found) {
358 1.82 xtraeme sysmon_envsys_release(sme, false);
359 1.72 xtraeme error = ENODEV;
360 1.72 xtraeme break;
361 1.72 xtraeme }
362 1.18 xtraeme
363 1.18 xtraeme if (tred->sensor < sme->sme_nsensors) {
364 1.84 jmcneill if ((sme->sme_flags & SME_DISABLE_REFRESH) == 0 &&
365 1.84 jmcneill (sme->sme_flags & SME_POLL_ONLY) == 0) {
366 1.82 xtraeme mutex_enter(&sme->sme_mtx);
367 1.72 xtraeme (*sme->sme_refresh)(sme, edata);
368 1.82 xtraeme mutex_exit(&sme->sme_mtx);
369 1.82 xtraeme }
370 1.18 xtraeme
371 1.72 xtraeme /*
372 1.72 xtraeme * copy required values to the old interface.
373 1.72 xtraeme */
374 1.18 xtraeme tred->sensor = edata->sensor;
375 1.18 xtraeme tred->cur.data_us = edata->value_cur;
376 1.18 xtraeme tred->cur.data_s = edata->value_cur;
377 1.18 xtraeme tred->max.data_us = edata->value_max;
378 1.18 xtraeme tred->max.data_s = edata->value_max;
379 1.18 xtraeme tred->min.data_us = edata->value_min;
380 1.18 xtraeme tred->min.data_s = edata->value_min;
381 1.18 xtraeme tred->avg.data_us = edata->value_avg;
382 1.18 xtraeme tred->avg.data_s = edata->value_avg;
383 1.71 xtraeme if (edata->units == ENVSYS_BATTERY_CHARGE)
384 1.71 xtraeme tred->units = ENVSYS_INDICATOR;
385 1.71 xtraeme else
386 1.72 xtraeme tred->units = edata->units;
387 1.18 xtraeme
388 1.20 xtraeme tred->validflags |= ENVSYS_FVALID;
389 1.20 xtraeme tred->validflags |= ENVSYS_FCURVALID;
390 1.20 xtraeme
391 1.20 xtraeme if (edata->flags & ENVSYS_FPERCENT) {
392 1.20 xtraeme tred->validflags |= ENVSYS_FMAXVALID;
393 1.20 xtraeme tred->validflags |= ENVSYS_FFRACVALID;
394 1.20 xtraeme }
395 1.20 xtraeme
396 1.72 xtraeme if (edata->state == ENVSYS_SINVALID) {
397 1.20 xtraeme tred->validflags &= ~ENVSYS_FCURVALID;
398 1.18 xtraeme tred->cur.data_us = tred->cur.data_s = 0;
399 1.18 xtraeme }
400 1.18 xtraeme
401 1.18 xtraeme DPRINTFOBJ(("%s: sensor=%s tred->cur.data_s=%d\n",
402 1.18 xtraeme __func__, edata->desc, tred->cur.data_s));
403 1.18 xtraeme DPRINTFOBJ(("%s: tred->validflags=%d tred->units=%d"
404 1.18 xtraeme " tred->sensor=%d\n", __func__, tred->validflags,
405 1.18 xtraeme tred->units, tred->sensor));
406 1.3 jdolecek }
407 1.1 thorpej tred->sensor = oidx;
408 1.82 xtraeme sysmon_envsys_release(sme, false);
409 1.1 thorpej
410 1.1 thorpej break;
411 1.1 thorpej }
412 1.1 thorpej case ENVSYS_GTREINFO:
413 1.1 thorpej {
414 1.18 xtraeme struct envsys_basic_info *binfo = (void *)data;
415 1.18 xtraeme envsys_data_t *edata = NULL;
416 1.72 xtraeme bool found = false;
417 1.1 thorpej
418 1.1 thorpej binfo->validflags = 0;
419 1.1 thorpej
420 1.18 xtraeme sme = sysmon_envsys_find_40(binfo->sensor);
421 1.82 xtraeme if (!sme)
422 1.1 thorpej break;
423 1.18 xtraeme
424 1.1 thorpej oidx = binfo->sensor;
425 1.1 thorpej binfo->sensor = SME_SENSOR_IDX(sme, binfo->sensor);
426 1.18 xtraeme
427 1.72 xtraeme TAILQ_FOREACH(edata, &sme->sme_sensors_list, sensors_head) {
428 1.72 xtraeme if (edata->sensor == binfo->sensor) {
429 1.72 xtraeme found = true;
430 1.72 xtraeme break;
431 1.72 xtraeme }
432 1.72 xtraeme }
433 1.72 xtraeme
434 1.72 xtraeme if (!found) {
435 1.82 xtraeme sysmon_envsys_release(sme, false);
436 1.72 xtraeme error = ENODEV;
437 1.72 xtraeme break;
438 1.72 xtraeme }
439 1.18 xtraeme
440 1.20 xtraeme binfo->validflags |= ENVSYS_FVALID;
441 1.18 xtraeme
442 1.18 xtraeme if (binfo->sensor < sme->sme_nsensors) {
443 1.71 xtraeme if (edata->units == ENVSYS_BATTERY_CHARGE)
444 1.71 xtraeme binfo->units = ENVSYS_INDICATOR;
445 1.71 xtraeme else
446 1.72 xtraeme binfo->units = edata->units;
447 1.70 plunky
448 1.70 plunky /*
449 1.70 plunky * previously, the ACPI sensor names included the
450 1.70 plunky * device name. Include that in compatibility code.
451 1.70 plunky */
452 1.70 plunky if (strncmp(sme->sme_name, "acpi", 4) == 0)
453 1.70 plunky (void)snprintf(binfo->desc, sizeof(binfo->desc),
454 1.70 plunky "%s %s", sme->sme_name, edata->desc);
455 1.70 plunky else
456 1.70 plunky (void)strlcpy(binfo->desc, edata->desc,
457 1.70 plunky sizeof(binfo->desc));
458 1.18 xtraeme }
459 1.18 xtraeme
460 1.18 xtraeme DPRINTFOBJ(("%s: binfo->units=%d binfo->validflags=%d\n",
461 1.18 xtraeme __func__, binfo->units, binfo->validflags));
462 1.18 xtraeme DPRINTFOBJ(("%s: binfo->desc=%s binfo->sensor=%d\n",
463 1.18 xtraeme __func__, binfo->desc, binfo->sensor));
464 1.18 xtraeme
465 1.1 thorpej binfo->sensor = oidx;
466 1.82 xtraeme sysmon_envsys_release(sme, false);
467 1.18 xtraeme
468 1.1 thorpej break;
469 1.1 thorpej }
470 1.1 thorpej default:
471 1.1 thorpej error = ENOTTY;
472 1.18 xtraeme break;
473 1.1 thorpej }
474 1.1 thorpej
475 1.18 xtraeme return error;
476 1.1 thorpej }
477 1.1 thorpej
478 1.1 thorpej /*
479 1.72 xtraeme * sysmon_envsys_create:
480 1.72 xtraeme *
481 1.72 xtraeme * + Allocates a new sysmon_envsys object and initializes the
482 1.72 xtraeme * stuff for sensors and events.
483 1.72 xtraeme */
484 1.72 xtraeme struct sysmon_envsys *
485 1.72 xtraeme sysmon_envsys_create(void)
486 1.72 xtraeme {
487 1.72 xtraeme struct sysmon_envsys *sme;
488 1.72 xtraeme
489 1.72 xtraeme sme = kmem_zalloc(sizeof(*sme), KM_SLEEP);
490 1.72 xtraeme TAILQ_INIT(&sme->sme_sensors_list);
491 1.72 xtraeme LIST_INIT(&sme->sme_events_list);
492 1.82 xtraeme mutex_init(&sme->sme_mtx, MUTEX_DEFAULT, IPL_NONE);
493 1.82 xtraeme cv_init(&sme->sme_condvar, "sme_wait");
494 1.72 xtraeme
495 1.72 xtraeme return sme;
496 1.72 xtraeme }
497 1.72 xtraeme
498 1.72 xtraeme /*
499 1.72 xtraeme * sysmon_envsys_destroy:
500 1.72 xtraeme *
501 1.80 xtraeme * + Removes all sensors from the tail queue, destroys the callout
502 1.80 xtraeme * and frees the sysmon_envsys object.
503 1.72 xtraeme */
504 1.72 xtraeme void
505 1.72 xtraeme sysmon_envsys_destroy(struct sysmon_envsys *sme)
506 1.72 xtraeme {
507 1.72 xtraeme envsys_data_t *edata;
508 1.72 xtraeme
509 1.72 xtraeme KASSERT(sme != NULL);
510 1.72 xtraeme
511 1.72 xtraeme while (!TAILQ_EMPTY(&sme->sme_sensors_list)) {
512 1.72 xtraeme edata = TAILQ_FIRST(&sme->sme_sensors_list);
513 1.72 xtraeme TAILQ_REMOVE(&sme->sme_sensors_list, edata, sensors_head);
514 1.72 xtraeme }
515 1.82 xtraeme mutex_destroy(&sme->sme_mtx);
516 1.82 xtraeme cv_destroy(&sme->sme_condvar);
517 1.72 xtraeme kmem_free(sme, sizeof(*sme));
518 1.72 xtraeme }
519 1.72 xtraeme
520 1.72 xtraeme /*
521 1.72 xtraeme * sysmon_envsys_sensor_attach:
522 1.72 xtraeme *
523 1.72 xtraeme * + Attachs a sensor into a sysmon_envsys device checking that units
524 1.72 xtraeme * is set to a valid type and description is unique and not empty.
525 1.72 xtraeme */
526 1.72 xtraeme int
527 1.72 xtraeme sysmon_envsys_sensor_attach(struct sysmon_envsys *sme, envsys_data_t *edata)
528 1.72 xtraeme {
529 1.72 xtraeme const struct sme_description_table *sdt_units;
530 1.72 xtraeme envsys_data_t *oedata;
531 1.72 xtraeme int i;
532 1.72 xtraeme
533 1.72 xtraeme KASSERT(sme != NULL || edata != NULL);
534 1.72 xtraeme
535 1.72 xtraeme /*
536 1.72 xtraeme * Find the correct units for this sensor.
537 1.72 xtraeme */
538 1.72 xtraeme sdt_units = sme_get_description_table(SME_DESC_UNITS);
539 1.72 xtraeme for (i = 0; sdt_units[i].type != -1; i++)
540 1.72 xtraeme if (sdt_units[i].type == edata->units)
541 1.72 xtraeme break;
542 1.72 xtraeme
543 1.72 xtraeme if (strcmp(sdt_units[i].desc, "unknown") == 0)
544 1.72 xtraeme return EINVAL;
545 1.72 xtraeme
546 1.72 xtraeme /*
547 1.72 xtraeme * Check that description is not empty or duplicate.
548 1.72 xtraeme */
549 1.72 xtraeme if (strlen(edata->desc) == 0)
550 1.72 xtraeme return EINVAL;
551 1.72 xtraeme
552 1.82 xtraeme mutex_enter(&sme->sme_mtx);
553 1.82 xtraeme sysmon_envsys_acquire(sme, true);
554 1.72 xtraeme TAILQ_FOREACH(oedata, &sme->sme_sensors_list, sensors_head) {
555 1.72 xtraeme if (strcmp(oedata->desc, edata->desc) == 0) {
556 1.82 xtraeme sysmon_envsys_release(sme, true);
557 1.82 xtraeme mutex_exit(&sme->sme_mtx);
558 1.72 xtraeme return EEXIST;
559 1.72 xtraeme }
560 1.72 xtraeme }
561 1.72 xtraeme /*
562 1.72 xtraeme * Ok, the sensor has been added into the device queue.
563 1.72 xtraeme */
564 1.72 xtraeme TAILQ_INSERT_TAIL(&sme->sme_sensors_list, edata, sensors_head);
565 1.72 xtraeme
566 1.72 xtraeme /*
567 1.72 xtraeme * Give the sensor a index position.
568 1.72 xtraeme */
569 1.72 xtraeme edata->sensor = sme->sme_nsensors;
570 1.72 xtraeme sme->sme_nsensors++;
571 1.82 xtraeme sysmon_envsys_release(sme, true);
572 1.82 xtraeme mutex_exit(&sme->sme_mtx);
573 1.72 xtraeme
574 1.72 xtraeme return 0;
575 1.72 xtraeme }
576 1.72 xtraeme
577 1.72 xtraeme /*
578 1.72 xtraeme * sysmon_envsys_sensor_detach:
579 1.72 xtraeme *
580 1.72 xtraeme * + Detachs a sensor from a sysmon_envsys device and decrements the
581 1.72 xtraeme * sensors count on success.
582 1.72 xtraeme */
583 1.72 xtraeme int
584 1.72 xtraeme sysmon_envsys_sensor_detach(struct sysmon_envsys *sme, envsys_data_t *edata)
585 1.72 xtraeme {
586 1.72 xtraeme envsys_data_t *oedata;
587 1.72 xtraeme bool found = false;
588 1.72 xtraeme
589 1.72 xtraeme KASSERT(sme != NULL || edata != NULL);
590 1.72 xtraeme
591 1.72 xtraeme /*
592 1.72 xtraeme * Check the sensor is already on the list.
593 1.72 xtraeme */
594 1.82 xtraeme mutex_enter(&sme->sme_mtx);
595 1.82 xtraeme sysmon_envsys_acquire(sme, true);
596 1.72 xtraeme TAILQ_FOREACH(oedata, &sme->sme_sensors_list, sensors_head) {
597 1.72 xtraeme if (oedata->sensor == edata->sensor) {
598 1.72 xtraeme found = true;
599 1.72 xtraeme break;
600 1.72 xtraeme }
601 1.72 xtraeme }
602 1.72 xtraeme
603 1.72 xtraeme if (!found) {
604 1.82 xtraeme sysmon_envsys_release(sme, true);
605 1.82 xtraeme mutex_exit(&sme->sme_mtx);
606 1.72 xtraeme return EINVAL;
607 1.72 xtraeme }
608 1.72 xtraeme
609 1.72 xtraeme /*
610 1.72 xtraeme * remove it and decrement the sensors count.
611 1.72 xtraeme */
612 1.72 xtraeme TAILQ_REMOVE(&sme->sme_sensors_list, edata, sensors_head);
613 1.72 xtraeme sme->sme_nsensors--;
614 1.82 xtraeme sysmon_envsys_release(sme, true);
615 1.82 xtraeme mutex_exit(&sme->sme_mtx);
616 1.72 xtraeme
617 1.72 xtraeme return 0;
618 1.72 xtraeme }
619 1.72 xtraeme
620 1.72 xtraeme
621 1.72 xtraeme /*
622 1.1 thorpej * sysmon_envsys_register:
623 1.1 thorpej *
624 1.52 xtraeme * + Register a sysmon envsys device.
625 1.52 xtraeme * + Create array of dictionaries for a device.
626 1.1 thorpej */
627 1.1 thorpej int
628 1.1 thorpej sysmon_envsys_register(struct sysmon_envsys *sme)
629 1.1 thorpej {
630 1.58 xtraeme struct sme_evdrv {
631 1.58 xtraeme SLIST_ENTRY(sme_evdrv) evdrv_head;
632 1.58 xtraeme sme_event_drv_t *evdrv;
633 1.58 xtraeme };
634 1.58 xtraeme SLIST_HEAD(, sme_evdrv) sme_evdrv_list;
635 1.82 xtraeme struct sme_evdrv *evdv = NULL;
636 1.18 xtraeme struct sysmon_envsys *lsme;
637 1.82 xtraeme prop_array_t array = NULL;
638 1.72 xtraeme prop_dictionary_t dict, dict2;
639 1.47 xtraeme envsys_data_t *edata = NULL;
640 1.81 xtraeme int error = 0;
641 1.1 thorpej
642 1.47 xtraeme KASSERT(sme != NULL);
643 1.47 xtraeme KASSERT(sme->sme_name != NULL);
644 1.18 xtraeme
645 1.47 xtraeme /*
646 1.82 xtraeme * Check if requested sysmon_envsys device is valid
647 1.82 xtraeme * and does not exist already in the list.
648 1.82 xtraeme */
649 1.82 xtraeme mutex_enter(&sme_global_mtx);
650 1.82 xtraeme LIST_FOREACH(lsme, &sysmon_envsys_list, sme_list) {
651 1.82 xtraeme if (strcmp(lsme->sme_name, sme->sme_name) == 0) {
652 1.82 xtraeme mutex_exit(&sme_global_mtx);
653 1.82 xtraeme return EEXIST;
654 1.82 xtraeme }
655 1.82 xtraeme }
656 1.82 xtraeme mutex_exit(&sme_global_mtx);
657 1.82 xtraeme
658 1.82 xtraeme /*
659 1.72 xtraeme * sanity check: if SME_DISABLE_REFRESH is not set,
660 1.72 xtraeme * the sme_refresh function callback must be non NULL.
661 1.18 xtraeme */
662 1.72 xtraeme if ((sme->sme_flags & SME_DISABLE_REFRESH) == 0)
663 1.72 xtraeme if (!sme->sme_refresh)
664 1.72 xtraeme return EINVAL;
665 1.72 xtraeme
666 1.18 xtraeme /*
667 1.72 xtraeme * If the list of sensors is empty, there's no point to continue...
668 1.18 xtraeme */
669 1.72 xtraeme if (TAILQ_EMPTY(&sme->sme_sensors_list)) {
670 1.72 xtraeme DPRINTF(("%s: sensors list empty for %s\n", __func__,
671 1.72 xtraeme sme->sme_name));
672 1.72 xtraeme return ENOTSUP;
673 1.1 thorpej }
674 1.1 thorpej
675 1.72 xtraeme /*
676 1.82 xtraeme * Initialize the singly linked list for driver events.
677 1.72 xtraeme */
678 1.82 xtraeme SLIST_INIT(&sme_evdrv_list);
679 1.82 xtraeme
680 1.47 xtraeme array = prop_array_create();
681 1.69 xtraeme if (!array)
682 1.47 xtraeme return ENOMEM;
683 1.47 xtraeme
684 1.58 xtraeme /*
685 1.72 xtraeme * Iterate over all sensors and create a dictionary per sensor.
686 1.72 xtraeme * We must respect the order in which the sensors were added.
687 1.47 xtraeme */
688 1.76 dyoung TAILQ_FOREACH(edata, &sme->sme_sensors_list, sensors_head) {
689 1.53 xtraeme dict = prop_dictionary_create();
690 1.69 xtraeme if (!dict) {
691 1.53 xtraeme error = ENOMEM;
692 1.53 xtraeme goto out2;
693 1.53 xtraeme }
694 1.53 xtraeme
695 1.48 xtraeme /*
696 1.48 xtraeme * Create all objects in sensor's dictionary.
697 1.48 xtraeme */
698 1.82 xtraeme evdv = kmem_zalloc(sizeof(*evdv), KM_SLEEP);
699 1.82 xtraeme evdv->evdrv = sme_add_sensor_dictionary(sme, array,
700 1.82 xtraeme dict, edata);
701 1.82 xtraeme if (evdv->evdrv)
702 1.82 xtraeme SLIST_INSERT_HEAD(&sme_evdrv_list, evdv, evdrv_head);
703 1.47 xtraeme }
704 1.27 xtraeme
705 1.47 xtraeme /*
706 1.47 xtraeme * If the array does not contain any object (sensor), there's
707 1.47 xtraeme * no need to attach the driver.
708 1.47 xtraeme */
709 1.47 xtraeme if (prop_array_count(array) == 0) {
710 1.47 xtraeme error = EINVAL;
711 1.47 xtraeme DPRINTF(("%s: empty array for '%s'\n", __func__,
712 1.47 xtraeme sme->sme_name));
713 1.47 xtraeme goto out;
714 1.47 xtraeme }
715 1.72 xtraeme
716 1.72 xtraeme /*
717 1.72 xtraeme * Add the dictionary for the global properties of this device.
718 1.72 xtraeme */
719 1.72 xtraeme dict2 = prop_dictionary_create();
720 1.72 xtraeme if (!dict2) {
721 1.72 xtraeme error = ENOMEM;
722 1.72 xtraeme goto out;
723 1.72 xtraeme }
724 1.72 xtraeme
725 1.72 xtraeme error = sme_add_property_dictionary(sme, array, dict2);
726 1.72 xtraeme if (error) {
727 1.72 xtraeme prop_object_release(dict2);
728 1.72 xtraeme goto out;
729 1.72 xtraeme }
730 1.72 xtraeme
731 1.47 xtraeme /*
732 1.47 xtraeme * Add the array into the global dictionary for the driver.
733 1.47 xtraeme *
734 1.47 xtraeme * <dict>
735 1.47 xtraeme * <key>foo0</key>
736 1.47 xtraeme * <array>
737 1.47 xtraeme * ...
738 1.47 xtraeme */
739 1.82 xtraeme mutex_enter(&sme_global_mtx);
740 1.47 xtraeme if (!prop_dictionary_set(sme_propd, sme->sme_name, array)) {
741 1.53 xtraeme error = EINVAL;
742 1.47 xtraeme DPRINTF(("%s: prop_dictionary_set for '%s'\n", __func__,
743 1.47 xtraeme sme->sme_name));
744 1.47 xtraeme goto out;
745 1.47 xtraeme }
746 1.82 xtraeme
747 1.47 xtraeme /*
748 1.48 xtraeme * Add the device into the list.
749 1.47 xtraeme */
750 1.47 xtraeme LIST_INSERT_HEAD(&sysmon_envsys_list, sme, sme_list);
751 1.58 xtraeme sme->sme_fsensor = sysmon_envsys_next_sensor_index;
752 1.58 xtraeme sysmon_envsys_next_sensor_index += sme->sme_nsensors;
753 1.82 xtraeme mutex_exit(&sme_global_mtx);
754 1.82 xtraeme
755 1.18 xtraeme out:
756 1.72 xtraeme /*
757 1.81 xtraeme * No errors? register the events that were set in the driver
758 1.81 xtraeme * and make an initial data refresh if was requested.
759 1.72 xtraeme */
760 1.56 xtraeme if (error == 0) {
761 1.81 xtraeme sysmon_task_queue_init();
762 1.82 xtraeme SLIST_FOREACH(evdv, &sme_evdrv_list, evdrv_head) {
763 1.58 xtraeme sysmon_task_queue_sched(0,
764 1.82 xtraeme sme_event_drvadd, evdv->evdrv);
765 1.58 xtraeme }
766 1.56 xtraeme DPRINTF(("%s: driver '%s' registered (nsens=%d)\n",
767 1.56 xtraeme __func__, sme->sme_name, sme->sme_nsensors));
768 1.81 xtraeme
769 1.81 xtraeme if (sme->sme_flags & SME_INIT_REFRESH)
770 1.81 xtraeme sysmon_task_queue_sched(0, sme_initial_refresh, sme);
771 1.56 xtraeme }
772 1.62 xtraeme
773 1.47 xtraeme out2:
774 1.58 xtraeme while (!SLIST_EMPTY(&sme_evdrv_list)) {
775 1.82 xtraeme evdv = SLIST_FIRST(&sme_evdrv_list);
776 1.58 xtraeme SLIST_REMOVE_HEAD(&sme_evdrv_list, evdrv_head);
777 1.82 xtraeme kmem_free(evdv, sizeof(*evdv));
778 1.58 xtraeme }
779 1.69 xtraeme if (!error)
780 1.62 xtraeme return 0;
781 1.62 xtraeme
782 1.72 xtraeme /*
783 1.72 xtraeme * Ugh... something wasn't right; unregister all events and sensors
784 1.72 xtraeme * previously assigned and destroy the array with all its objects.
785 1.72 xtraeme */
786 1.62 xtraeme DPRINTF(("%s: failed to register '%s' (%d)\n", __func__,
787 1.62 xtraeme sme->sme_name, error));
788 1.82 xtraeme
789 1.82 xtraeme sme_event_unregister_all(sme);
790 1.82 xtraeme while (!TAILQ_EMPTY(&sme->sme_sensors_list)) {
791 1.82 xtraeme edata = TAILQ_FIRST(&sme->sme_sensors_list);
792 1.82 xtraeme TAILQ_REMOVE(&sme->sme_sensors_list, edata, sensors_head);
793 1.59 xtraeme }
794 1.53 xtraeme sysmon_envsys_destroy_plist(array);
795 1.18 xtraeme return error;
796 1.1 thorpej }
797 1.1 thorpej
798 1.1 thorpej /*
799 1.53 xtraeme * sysmon_envsys_destroy_plist:
800 1.53 xtraeme *
801 1.53 xtraeme * + Remove all objects from the array of dictionaries that is
802 1.53 xtraeme * created in a sysmon envsys device.
803 1.53 xtraeme */
804 1.53 xtraeme static void
805 1.53 xtraeme sysmon_envsys_destroy_plist(prop_array_t array)
806 1.53 xtraeme {
807 1.63 xtraeme prop_object_iterator_t iter, iter2;
808 1.53 xtraeme prop_dictionary_t dict;
809 1.53 xtraeme prop_object_t obj;
810 1.53 xtraeme
811 1.53 xtraeme KASSERT(array != NULL);
812 1.82 xtraeme KASSERT(prop_object_type(array) == PROP_TYPE_ARRAY);
813 1.53 xtraeme
814 1.67 xtraeme DPRINTFOBJ(("%s: objects in array=%d\n", __func__,
815 1.63 xtraeme prop_array_count(array)));
816 1.63 xtraeme
817 1.53 xtraeme iter = prop_array_iterator(array);
818 1.69 xtraeme if (!iter)
819 1.53 xtraeme return;
820 1.53 xtraeme
821 1.69 xtraeme while ((dict = prop_object_iterator_next(iter))) {
822 1.63 xtraeme KASSERT(prop_object_type(dict) == PROP_TYPE_DICTIONARY);
823 1.53 xtraeme iter2 = prop_dictionary_iterator(dict);
824 1.69 xtraeme if (!iter2)
825 1.63 xtraeme goto out;
826 1.67 xtraeme DPRINTFOBJ(("%s: iterating over dictionary\n", __func__));
827 1.63 xtraeme while ((obj = prop_object_iterator_next(iter2)) != NULL) {
828 1.67 xtraeme DPRINTFOBJ(("%s: obj=%s\n", __func__,
829 1.65 xtraeme prop_dictionary_keysym_cstring_nocopy(obj)));
830 1.63 xtraeme prop_dictionary_remove(dict,
831 1.63 xtraeme prop_dictionary_keysym_cstring_nocopy(obj));
832 1.63 xtraeme prop_object_iterator_reset(iter2);
833 1.63 xtraeme }
834 1.63 xtraeme prop_object_iterator_release(iter2);
835 1.67 xtraeme DPRINTFOBJ(("%s: objects in dictionary:%d\n",
836 1.63 xtraeme __func__, prop_dictionary_count(dict)));
837 1.53 xtraeme prop_object_release(dict);
838 1.53 xtraeme }
839 1.53 xtraeme
840 1.63 xtraeme out:
841 1.53 xtraeme prop_object_iterator_release(iter);
842 1.63 xtraeme prop_object_release(array);
843 1.53 xtraeme }
844 1.53 xtraeme
845 1.53 xtraeme /*
846 1.1 thorpej * sysmon_envsys_unregister:
847 1.1 thorpej *
848 1.52 xtraeme * + Unregister a sysmon envsys device.
849 1.1 thorpej */
850 1.1 thorpej void
851 1.1 thorpej sysmon_envsys_unregister(struct sysmon_envsys *sme)
852 1.1 thorpej {
853 1.53 xtraeme prop_array_t array;
854 1.35 xtraeme
855 1.35 xtraeme KASSERT(sme != NULL);
856 1.1 thorpej
857 1.72 xtraeme /*
858 1.83 xtraeme * Unregister all events associated with device.
859 1.72 xtraeme */
860 1.82 xtraeme sme_event_unregister_all(sme);
861 1.72 xtraeme /*
862 1.82 xtraeme * Decrement global sensors counter (only used for compatibility
863 1.82 xtraeme * with previous API) and remove the device from the list.
864 1.27 xtraeme */
865 1.82 xtraeme mutex_enter(&sme_global_mtx);
866 1.72 xtraeme sysmon_envsys_next_sensor_index -= sme->sme_nsensors;
867 1.58 xtraeme LIST_REMOVE(sme, sme_list);
868 1.82 xtraeme mutex_exit(&sme_global_mtx);
869 1.82 xtraeme
870 1.47 xtraeme /*
871 1.53 xtraeme * Remove the device (and all its objects) from the global dictionary.
872 1.47 xtraeme */
873 1.53 xtraeme array = prop_dictionary_get(sme_propd, sme->sme_name);
874 1.63 xtraeme if (array && prop_object_type(array) == PROP_TYPE_ARRAY) {
875 1.82 xtraeme mutex_enter(&sme_global_mtx);
876 1.63 xtraeme prop_dictionary_remove(sme_propd, sme->sme_name);
877 1.82 xtraeme mutex_exit(&sme_global_mtx);
878 1.53 xtraeme sysmon_envsys_destroy_plist(array);
879 1.53 xtraeme }
880 1.72 xtraeme /*
881 1.72 xtraeme * And finally destroy the sysmon_envsys object.
882 1.72 xtraeme */
883 1.72 xtraeme sysmon_envsys_destroy(sme);
884 1.1 thorpej }
885 1.1 thorpej
886 1.1 thorpej /*
887 1.1 thorpej * sysmon_envsys_find:
888 1.1 thorpej *
889 1.82 xtraeme * + Find a sysmon envsys device and mark it as busy
890 1.82 xtraeme * once it's available.
891 1.1 thorpej */
892 1.1 thorpej struct sysmon_envsys *
893 1.18 xtraeme sysmon_envsys_find(const char *name)
894 1.1 thorpej {
895 1.1 thorpej struct sysmon_envsys *sme;
896 1.1 thorpej
897 1.82 xtraeme mutex_enter(&sme_global_mtx);
898 1.77 dyoung LIST_FOREACH(sme, &sysmon_envsys_list, sme_list) {
899 1.79 xtraeme if (strcmp(sme->sme_name, name) == 0) {
900 1.82 xtraeme sysmon_envsys_acquire(sme, false);
901 1.79 xtraeme break;
902 1.79 xtraeme }
903 1.18 xtraeme }
904 1.82 xtraeme mutex_exit(&sme_global_mtx);
905 1.82 xtraeme
906 1.18 xtraeme return sme;
907 1.18 xtraeme }
908 1.18 xtraeme
909 1.18 xtraeme /*
910 1.82 xtraeme * Compatibility function with the old API.
911 1.72 xtraeme */
912 1.82 xtraeme struct sysmon_envsys *
913 1.82 xtraeme sysmon_envsys_find_40(u_int idx)
914 1.72 xtraeme {
915 1.82 xtraeme struct sysmon_envsys *sme;
916 1.72 xtraeme
917 1.82 xtraeme mutex_enter(&sme_global_mtx);
918 1.82 xtraeme LIST_FOREACH(sme, &sysmon_envsys_list, sme_list) {
919 1.82 xtraeme if (idx >= sme->sme_fsensor &&
920 1.82 xtraeme idx < (sme->sme_fsensor + sme->sme_nsensors)) {
921 1.82 xtraeme sysmon_envsys_acquire(sme, false);
922 1.82 xtraeme break;
923 1.82 xtraeme }
924 1.82 xtraeme }
925 1.82 xtraeme mutex_exit(&sme_global_mtx);
926 1.72 xtraeme
927 1.82 xtraeme return sme;
928 1.72 xtraeme }
929 1.72 xtraeme
930 1.72 xtraeme /*
931 1.82 xtraeme * sysmon_envsys_acquire:
932 1.18 xtraeme *
933 1.82 xtraeme * + Wait until a sysmon envsys device is available and mark
934 1.82 xtraeme * it as busy.
935 1.18 xtraeme */
936 1.18 xtraeme void
937 1.82 xtraeme sysmon_envsys_acquire(struct sysmon_envsys *sme, bool locked)
938 1.18 xtraeme {
939 1.82 xtraeme KASSERT(sme != NULL);
940 1.72 xtraeme
941 1.82 xtraeme if (locked) {
942 1.82 xtraeme while (sme->sme_flags & SME_FLAG_BUSY)
943 1.82 xtraeme cv_wait(&sme->sme_condvar, &sme->sme_mtx);
944 1.82 xtraeme sme->sme_flags |= SME_FLAG_BUSY;
945 1.82 xtraeme } else {
946 1.82 xtraeme mutex_enter(&sme->sme_mtx);
947 1.82 xtraeme while (sme->sme_flags & SME_FLAG_BUSY)
948 1.82 xtraeme cv_wait(&sme->sme_condvar, &sme->sme_mtx);
949 1.82 xtraeme sme->sme_flags |= SME_FLAG_BUSY;
950 1.82 xtraeme mutex_exit(&sme->sme_mtx);
951 1.82 xtraeme }
952 1.18 xtraeme }
953 1.18 xtraeme
954 1.82 xtraeme /*
955 1.82 xtraeme * sysmon_envsys_release:
956 1.82 xtraeme *
957 1.82 xtraeme * + Unmark a sysmon envsys device as busy, and notify
958 1.82 xtraeme * waiters.
959 1.82 xtraeme */
960 1.82 xtraeme void
961 1.82 xtraeme sysmon_envsys_release(struct sysmon_envsys *sme, bool locked)
962 1.18 xtraeme {
963 1.82 xtraeme KASSERT(sme != NULL);
964 1.18 xtraeme
965 1.82 xtraeme if (locked) {
966 1.82 xtraeme sme->sme_flags &= ~SME_FLAG_BUSY;
967 1.82 xtraeme cv_broadcast(&sme->sme_condvar);
968 1.82 xtraeme } else {
969 1.82 xtraeme mutex_enter(&sme->sme_mtx);
970 1.82 xtraeme sme->sme_flags &= ~SME_FLAG_BUSY;
971 1.82 xtraeme cv_broadcast(&sme->sme_condvar);
972 1.82 xtraeme mutex_exit(&sme->sme_mtx);
973 1.18 xtraeme }
974 1.18 xtraeme }
975 1.18 xtraeme
976 1.18 xtraeme /*
977 1.81 xtraeme * sme_initial_refresh:
978 1.81 xtraeme *
979 1.81 xtraeme * + Do an initial refresh of the sensors in a device just after
980 1.81 xtraeme * interrupts are enabled in the autoconf(9) process.
981 1.81 xtraeme *
982 1.81 xtraeme */
983 1.81 xtraeme static void
984 1.81 xtraeme sme_initial_refresh(void *arg)
985 1.81 xtraeme {
986 1.81 xtraeme struct sysmon_envsys *sme = arg;
987 1.81 xtraeme envsys_data_t *edata;
988 1.81 xtraeme
989 1.82 xtraeme mutex_enter(&sme->sme_mtx);
990 1.82 xtraeme sysmon_envsys_acquire(sme, true);
991 1.81 xtraeme TAILQ_FOREACH(edata, &sme->sme_sensors_list, sensors_head)
992 1.81 xtraeme (*sme->sme_refresh)(sme, edata);
993 1.82 xtraeme sysmon_envsys_release(sme, true);
994 1.82 xtraeme mutex_exit(&sme->sme_mtx);
995 1.81 xtraeme }
996 1.81 xtraeme
997 1.81 xtraeme /*
998 1.69 xtraeme * sme_sensor_dictionary_get:
999 1.69 xtraeme *
1000 1.72 xtraeme * + Returns a dictionary of a device specified by its index
1001 1.72 xtraeme * position.
1002 1.69 xtraeme */
1003 1.69 xtraeme prop_dictionary_t
1004 1.69 xtraeme sme_sensor_dictionary_get(prop_array_t array, const char *index)
1005 1.69 xtraeme {
1006 1.69 xtraeme prop_object_iterator_t iter;
1007 1.69 xtraeme prop_dictionary_t dict;
1008 1.69 xtraeme prop_object_t obj;
1009 1.69 xtraeme
1010 1.69 xtraeme KASSERT(array != NULL || index != NULL);
1011 1.69 xtraeme
1012 1.69 xtraeme iter = prop_array_iterator(array);
1013 1.69 xtraeme if (!iter)
1014 1.69 xtraeme return NULL;
1015 1.69 xtraeme
1016 1.69 xtraeme while ((dict = prop_object_iterator_next(iter))) {
1017 1.69 xtraeme obj = prop_dictionary_get(dict, "index");
1018 1.69 xtraeme if (prop_string_equals_cstring(obj, index))
1019 1.69 xtraeme break;
1020 1.69 xtraeme }
1021 1.69 xtraeme
1022 1.69 xtraeme prop_object_iterator_release(iter);
1023 1.69 xtraeme return dict;
1024 1.69 xtraeme }
1025 1.69 xtraeme
1026 1.69 xtraeme /*
1027 1.69 xtraeme * sme_remove_userprops:
1028 1.69 xtraeme *
1029 1.69 xtraeme * + Remove all properties from all devices that were set by
1030 1.72 xtraeme * the ENVSYS_SETDICTIONARY ioctl.
1031 1.69 xtraeme */
1032 1.69 xtraeme static void
1033 1.69 xtraeme sme_remove_userprops(void)
1034 1.69 xtraeme {
1035 1.69 xtraeme struct sysmon_envsys *sme;
1036 1.69 xtraeme prop_array_t array;
1037 1.69 xtraeme prop_dictionary_t sdict;
1038 1.69 xtraeme envsys_data_t *edata = NULL;
1039 1.69 xtraeme char tmp[ENVSYS_DESCLEN];
1040 1.72 xtraeme int ptype;
1041 1.69 xtraeme
1042 1.82 xtraeme mutex_enter(&sme_global_mtx);
1043 1.69 xtraeme LIST_FOREACH(sme, &sysmon_envsys_list, sme_list) {
1044 1.82 xtraeme sysmon_envsys_acquire(sme, false);
1045 1.69 xtraeme array = prop_dictionary_get(sme_propd, sme->sme_name);
1046 1.69 xtraeme
1047 1.72 xtraeme TAILQ_FOREACH(edata, &sme->sme_sensors_list, sensors_head) {
1048 1.69 xtraeme (void)snprintf(tmp, sizeof(tmp), "sensor%d",
1049 1.69 xtraeme edata->sensor);
1050 1.69 xtraeme sdict = sme_sensor_dictionary_get(array, tmp);
1051 1.72 xtraeme KASSERT(sdict != NULL);
1052 1.69 xtraeme
1053 1.69 xtraeme if (edata->upropset & USERPROP_BATTCAP) {
1054 1.69 xtraeme prop_dictionary_remove(sdict,
1055 1.69 xtraeme "critical-capacity");
1056 1.69 xtraeme ptype = PENVSYS_EVENT_BATT_USERCAP;
1057 1.72 xtraeme sme_event_unregister(sme, edata->desc, ptype);
1058 1.69 xtraeme }
1059 1.69 xtraeme
1060 1.69 xtraeme if (edata->upropset & USERPROP_CRITMAX) {
1061 1.69 xtraeme prop_dictionary_remove(sdict,
1062 1.69 xtraeme "critical-max");
1063 1.69 xtraeme ptype = PENVSYS_EVENT_USER_CRITMAX;
1064 1.72 xtraeme sme_event_unregister(sme, edata->desc, ptype);
1065 1.69 xtraeme }
1066 1.69 xtraeme
1067 1.69 xtraeme if (edata->upropset & USERPROP_CRITMIN) {
1068 1.69 xtraeme prop_dictionary_remove(sdict,
1069 1.69 xtraeme "critical-min");
1070 1.69 xtraeme ptype = PENVSYS_EVENT_USER_CRITMIN;
1071 1.72 xtraeme sme_event_unregister(sme, edata->desc, ptype);
1072 1.69 xtraeme }
1073 1.69 xtraeme
1074 1.69 xtraeme if (edata->upropset & USERPROP_RFACT) {
1075 1.69 xtraeme (void)sme_sensor_upint32(sdict, "rfact", 0);
1076 1.69 xtraeme edata->rfact = 0;
1077 1.69 xtraeme }
1078 1.69 xtraeme
1079 1.69 xtraeme if (edata->upropset & USERPROP_DESC)
1080 1.69 xtraeme (void)sme_sensor_upstring(sdict,
1081 1.69 xtraeme "description", edata->desc);
1082 1.72 xtraeme
1083 1.72 xtraeme if (edata->upropset)
1084 1.72 xtraeme edata->upropset = 0;
1085 1.69 xtraeme }
1086 1.69 xtraeme
1087 1.72 xtraeme /*
1088 1.72 xtraeme * Restore default timeout value.
1089 1.72 xtraeme */
1090 1.72 xtraeme sme->sme_events_timeout = SME_EVENTS_DEFTIMEOUT;
1091 1.82 xtraeme sysmon_envsys_release(sme, false);
1092 1.69 xtraeme }
1093 1.82 xtraeme mutex_exit(&sme_global_mtx);
1094 1.69 xtraeme }
1095 1.72 xtraeme
1096 1.69 xtraeme /*
1097 1.72 xtraeme * sme_add_property_dictionary:
1098 1.72 xtraeme *
1099 1.72 xtraeme * + Add global properties into a device.
1100 1.27 xtraeme */
1101 1.27 xtraeme static int
1102 1.72 xtraeme sme_add_property_dictionary(struct sysmon_envsys *sme, prop_array_t array,
1103 1.72 xtraeme prop_dictionary_t dict)
1104 1.27 xtraeme {
1105 1.72 xtraeme prop_dictionary_t pdict;
1106 1.72 xtraeme int error = 0;
1107 1.72 xtraeme
1108 1.72 xtraeme pdict = prop_dictionary_create();
1109 1.72 xtraeme if (!pdict)
1110 1.72 xtraeme return EINVAL;
1111 1.27 xtraeme
1112 1.72 xtraeme /*
1113 1.72 xtraeme * Add the 'refresh-timeout' object into the 'device-properties'
1114 1.72 xtraeme * dictionary. We use by default 30 seconds.
1115 1.72 xtraeme *
1116 1.72 xtraeme * ...
1117 1.72 xtraeme * <dict>
1118 1.72 xtraeme * <key>device-properties</key>
1119 1.72 xtraeme * <dict>
1120 1.72 xtraeme * <key>refresh-timeout</key>
1121 1.72 xtraeme * <integer>120</integer<
1122 1.72 xtraeme * </dict<
1123 1.72 xtraeme * </dict>
1124 1.72 xtraeme * ...
1125 1.72 xtraeme *
1126 1.72 xtraeme */
1127 1.72 xtraeme if (!sme->sme_events_timeout)
1128 1.72 xtraeme sme->sme_events_timeout = SME_EVENTS_DEFTIMEOUT;
1129 1.35 xtraeme
1130 1.72 xtraeme if (!prop_dictionary_set_uint64(pdict, "refresh-timeout",
1131 1.72 xtraeme sme->sme_events_timeout)) {
1132 1.72 xtraeme error = EINVAL;
1133 1.72 xtraeme goto out;
1134 1.27 xtraeme }
1135 1.27 xtraeme
1136 1.72 xtraeme if (!prop_dictionary_set(dict, "device-properties", pdict)) {
1137 1.72 xtraeme error = EINVAL;
1138 1.72 xtraeme goto out;
1139 1.72 xtraeme }
1140 1.47 xtraeme
1141 1.72 xtraeme /*
1142 1.72 xtraeme * Add the device dictionary into the sysmon envsys array.
1143 1.72 xtraeme */
1144 1.72 xtraeme if (!prop_array_add(array, dict))
1145 1.72 xtraeme error = EINVAL;
1146 1.27 xtraeme
1147 1.72 xtraeme out:
1148 1.72 xtraeme prop_object_release(pdict);
1149 1.72 xtraeme return error;
1150 1.27 xtraeme }
1151 1.27 xtraeme
1152 1.27 xtraeme /*
1153 1.52 xtraeme * sme_add_sensor_dictionary:
1154 1.18 xtraeme *
1155 1.72 xtraeme * + Adds the sensor objects into the dictionary and returns a pointer
1156 1.72 xtraeme * to a sme_event_drv_t object if a monitoring flag was set
1157 1.72 xtraeme * (or NULL otherwise).
1158 1.18 xtraeme */
1159 1.58 xtraeme sme_event_drv_t *
1160 1.47 xtraeme sme_add_sensor_dictionary(struct sysmon_envsys *sme, prop_array_t array,
1161 1.47 xtraeme prop_dictionary_t dict, envsys_data_t *edata)
1162 1.18 xtraeme {
1163 1.55 xtraeme const struct sme_description_table *sdt, *sdt_units;
1164 1.18 xtraeme sme_event_drv_t *sme_evdrv_t = NULL;
1165 1.41 xtraeme int i, j;
1166 1.69 xtraeme char indexstr[ENVSYS_DESCLEN];
1167 1.18 xtraeme
1168 1.72 xtraeme /*
1169 1.72 xtraeme * Find the correct units for this sensor.
1170 1.72 xtraeme */
1171 1.55 xtraeme sdt_units = sme_get_description_table(SME_DESC_UNITS);
1172 1.55 xtraeme for (i = 0; sdt_units[i].type != -1; i++)
1173 1.55 xtraeme if (sdt_units[i].type == edata->units)
1174 1.18 xtraeme break;
1175 1.18 xtraeme
1176 1.18 xtraeme /*
1177 1.69 xtraeme * Add the index sensor string.
1178 1.69 xtraeme *
1179 1.69 xtraeme * ...
1180 1.72 xtraeme * <key>index</eyr
1181 1.69 xtraeme * <string>sensor0</string>
1182 1.69 xtraeme * ...
1183 1.69 xtraeme */
1184 1.69 xtraeme (void)snprintf(indexstr, sizeof(indexstr), "sensor%d", edata->sensor);
1185 1.69 xtraeme if (sme_sensor_upstring(dict, "index", indexstr))
1186 1.72 xtraeme goto bad;
1187 1.69 xtraeme
1188 1.69 xtraeme /*
1189 1.18 xtraeme * ...
1190 1.18 xtraeme * <key>type</key>
1191 1.18 xtraeme * <string>foo</string>
1192 1.18 xtraeme * <key>description</key>
1193 1.18 xtraeme * <string>blah blah</string>
1194 1.18 xtraeme * ...
1195 1.18 xtraeme */
1196 1.55 xtraeme if (sme_sensor_upstring(dict, "type", sdt_units[i].desc))
1197 1.72 xtraeme goto bad;
1198 1.30 xtraeme
1199 1.41 xtraeme if (sme_sensor_upstring(dict, "description", edata->desc))
1200 1.72 xtraeme goto bad;
1201 1.18 xtraeme
1202 1.18 xtraeme /*
1203 1.18 xtraeme * Add sensor's state description.
1204 1.18 xtraeme *
1205 1.18 xtraeme * ...
1206 1.18 xtraeme * <key>state</key>
1207 1.18 xtraeme * <string>valid</string>
1208 1.18 xtraeme * ...
1209 1.18 xtraeme */
1210 1.55 xtraeme sdt = sme_get_description_table(SME_DESC_STATES);
1211 1.55 xtraeme for (j = 0; sdt[j].type != -1; j++)
1212 1.55 xtraeme if (sdt[j].type == edata->state)
1213 1.7 yamt break;
1214 1.18 xtraeme
1215 1.41 xtraeme DPRINTF(("%s: sensor desc=%s type=%d state=%d\n",
1216 1.41 xtraeme __func__, edata->desc, edata->units, edata->state));
1217 1.41 xtraeme
1218 1.55 xtraeme if (sme_sensor_upstring(dict, "state", sdt[j].desc))
1219 1.72 xtraeme goto bad;
1220 1.18 xtraeme
1221 1.18 xtraeme /*
1222 1.18 xtraeme * Add the monitoring boolean object:
1223 1.18 xtraeme *
1224 1.18 xtraeme * ...
1225 1.18 xtraeme * <key>monitoring-supported</key>
1226 1.18 xtraeme * <true/>
1227 1.18 xtraeme * ...
1228 1.18 xtraeme *
1229 1.71 xtraeme * always false on Battery {capacity,charge}, Drive and Indicator types.
1230 1.54 xtraeme * They cannot be monitored.
1231 1.18 xtraeme *
1232 1.18 xtraeme */
1233 1.18 xtraeme if ((edata->flags & ENVSYS_FMONNOTSUPP) ||
1234 1.18 xtraeme (edata->units == ENVSYS_INDICATOR) ||
1235 1.54 xtraeme (edata->units == ENVSYS_DRIVE) ||
1236 1.71 xtraeme (edata->units == ENVSYS_BATTERY_CAPACITY) ||
1237 1.71 xtraeme (edata->units == ENVSYS_BATTERY_CHARGE)) {
1238 1.41 xtraeme if (sme_sensor_upbool(dict, "monitoring-supported", false))
1239 1.58 xtraeme goto out;
1240 1.18 xtraeme } else {
1241 1.41 xtraeme if (sme_sensor_upbool(dict, "monitoring-supported", true))
1242 1.58 xtraeme goto out;
1243 1.18 xtraeme }
1244 1.18 xtraeme
1245 1.18 xtraeme /*
1246 1.69 xtraeme * Add the percentage boolean object, true if ENVSYS_FPERCENT
1247 1.69 xtraeme * is set or false otherwise.
1248 1.54 xtraeme *
1249 1.54 xtraeme * ...
1250 1.55 xtraeme * <key>want-percentage</key>
1251 1.55 xtraeme * <true/>
1252 1.54 xtraeme * ...
1253 1.54 xtraeme */
1254 1.55 xtraeme if (edata->flags & ENVSYS_FPERCENT)
1255 1.55 xtraeme if (sme_sensor_upbool(dict, "want-percentage", true))
1256 1.58 xtraeme goto out;
1257 1.54 xtraeme
1258 1.54 xtraeme /*
1259 1.69 xtraeme * Add the allow-rfact boolean object, true if
1260 1.69 xtraeme * ENVSYS_FCHANGERFACT if set or false otherwise.
1261 1.69 xtraeme *
1262 1.69 xtraeme * ...
1263 1.69 xtraeme * <key>allow-rfact</key>
1264 1.69 xtraeme * <true/>
1265 1.69 xtraeme * ...
1266 1.69 xtraeme */
1267 1.69 xtraeme if (edata->units == ENVSYS_SVOLTS_DC ||
1268 1.69 xtraeme edata->units == ENVSYS_SVOLTS_AC) {
1269 1.69 xtraeme if (edata->flags & ENVSYS_FCHANGERFACT) {
1270 1.69 xtraeme if (sme_sensor_upbool(dict, "allow-rfact", true))
1271 1.69 xtraeme goto out;
1272 1.69 xtraeme } else {
1273 1.69 xtraeme if (sme_sensor_upbool(dict, "allow-rfact", false))
1274 1.69 xtraeme goto out;
1275 1.69 xtraeme }
1276 1.69 xtraeme }
1277 1.69 xtraeme
1278 1.69 xtraeme /*
1279 1.71 xtraeme * Add the object for battery capacity sensors:
1280 1.54 xtraeme *
1281 1.54 xtraeme * ...
1282 1.71 xtraeme * <key>battery-capacity</key>
1283 1.55 xtraeme * <string>NORMAL</string>
1284 1.54 xtraeme * ...
1285 1.54 xtraeme */
1286 1.71 xtraeme if (edata->units == ENVSYS_BATTERY_CAPACITY) {
1287 1.71 xtraeme sdt = sme_get_description_table(SME_DESC_BATTERY_CAPACITY);
1288 1.55 xtraeme for (j = 0; sdt[j].type != -1; j++)
1289 1.55 xtraeme if (sdt[j].type == edata->value_cur)
1290 1.55 xtraeme break;
1291 1.55 xtraeme
1292 1.71 xtraeme if (sme_sensor_upstring(dict, "battery-capacity", sdt[j].desc))
1293 1.58 xtraeme goto out;
1294 1.55 xtraeme }
1295 1.54 xtraeme
1296 1.54 xtraeme /*
1297 1.18 xtraeme * Add the drive-state object for drive sensors:
1298 1.18 xtraeme *
1299 1.18 xtraeme * ...
1300 1.18 xtraeme * <key>drive-state</key>
1301 1.18 xtraeme * <string>drive is online</string>
1302 1.18 xtraeme * ...
1303 1.18 xtraeme */
1304 1.18 xtraeme if (edata->units == ENVSYS_DRIVE) {
1305 1.55 xtraeme sdt = sme_get_description_table(SME_DESC_DRIVE_STATES);
1306 1.55 xtraeme for (j = 0; sdt[j].type != -1; j++)
1307 1.55 xtraeme if (sdt[j].type == edata->value_cur)
1308 1.18 xtraeme break;
1309 1.30 xtraeme
1310 1.55 xtraeme if (sme_sensor_upstring(dict, "drive-state", sdt[j].desc))
1311 1.58 xtraeme goto out;
1312 1.18 xtraeme }
1313 1.18 xtraeme
1314 1.72 xtraeme /*
1315 1.72 xtraeme * Add the following objects if sensor is enabled...
1316 1.54 xtraeme */
1317 1.18 xtraeme if (edata->state == ENVSYS_SVALID) {
1318 1.18 xtraeme /*
1319 1.72 xtraeme * Add the following objects:
1320 1.72 xtraeme *
1321 1.18 xtraeme * ...
1322 1.18 xtraeme * <key>rpms</key>
1323 1.18 xtraeme * <integer>2500</integer>
1324 1.18 xtraeme * <key>rfact</key>
1325 1.18 xtraeme * <integer>10000</integer>
1326 1.18 xtraeme * <key>cur-value</key>
1327 1.72 xtraeme * <integer>1250</integer>
1328 1.72 xtraeme * <key>min-value</key>
1329 1.72 xtraeme * <integer>800</integer>
1330 1.72 xtraeme * <key>max-value</integer>
1331 1.72 xtraeme * <integer>3000</integer>
1332 1.72 xtraeme * <key>avg-value</integer>
1333 1.72 xtraeme * <integer>1400</integer>
1334 1.72 xtraeme * ...
1335 1.72 xtraeme */
1336 1.41 xtraeme if (edata->units == ENVSYS_SFANRPM)
1337 1.41 xtraeme if (sme_sensor_upuint32(dict, "rpms", edata->rpms))
1338 1.58 xtraeme goto out;
1339 1.18 xtraeme
1340 1.41 xtraeme if (edata->units == ENVSYS_SVOLTS_AC ||
1341 1.72 xtraeme edata->units == ENVSYS_SVOLTS_DC)
1342 1.41 xtraeme if (sme_sensor_upint32(dict, "rfact", edata->rfact))
1343 1.58 xtraeme goto out;
1344 1.18 xtraeme
1345 1.41 xtraeme if (sme_sensor_upint32(dict, "cur-value", edata->value_cur))
1346 1.58 xtraeme goto out;
1347 1.30 xtraeme
1348 1.41 xtraeme if (edata->flags & ENVSYS_FVALID_MIN) {
1349 1.41 xtraeme if (sme_sensor_upint32(dict,
1350 1.41 xtraeme "min-value",
1351 1.41 xtraeme edata->value_min))
1352 1.72 xtraeme goto out;
1353 1.30 xtraeme }
1354 1.30 xtraeme
1355 1.41 xtraeme if (edata->flags & ENVSYS_FVALID_MAX) {
1356 1.41 xtraeme if (sme_sensor_upint32(dict,
1357 1.41 xtraeme "max-value",
1358 1.41 xtraeme edata->value_max))
1359 1.72 xtraeme goto out;
1360 1.30 xtraeme }
1361 1.30 xtraeme
1362 1.41 xtraeme if (edata->flags & ENVSYS_FVALID_AVG) {
1363 1.41 xtraeme if (sme_sensor_upint32(dict,
1364 1.41 xtraeme "avg-value",
1365 1.72 xtraeme edata->value_avg))
1366 1.72 xtraeme goto out;
1367 1.30 xtraeme }
1368 1.18 xtraeme }
1369 1.18 xtraeme
1370 1.18 xtraeme /*
1371 1.18 xtraeme * ...
1372 1.72 xtraeme * </dict>
1373 1.47 xtraeme *
1374 1.47 xtraeme * Add the dictionary into the array.
1375 1.47 xtraeme *
1376 1.18 xtraeme */
1377 1.72 xtraeme if (!prop_array_add(array, dict)) {
1378 1.41 xtraeme DPRINTF(("%s: prop_array_add\n", __func__));
1379 1.72 xtraeme goto bad;
1380 1.41 xtraeme }
1381 1.41 xtraeme
1382 1.41 xtraeme /*
1383 1.72 xtraeme * Register a new event if a monitoring flag was set.
1384 1.41 xtraeme */
1385 1.41 xtraeme if (edata->monitor) {
1386 1.58 xtraeme sme_evdrv_t = kmem_zalloc(sizeof(*sme_evdrv_t), KM_SLEEP);
1387 1.72 xtraeme sme_evdrv_t->sed_sdict = dict;
1388 1.72 xtraeme sme_evdrv_t->sed_edata = edata;
1389 1.72 xtraeme sme_evdrv_t->sed_sme = sme;
1390 1.72 xtraeme sme_evdrv_t->sed_powertype = sdt_units[i].crittype;
1391 1.41 xtraeme }
1392 1.41 xtraeme
1393 1.58 xtraeme out:
1394 1.58 xtraeme return sme_evdrv_t;
1395 1.41 xtraeme
1396 1.72 xtraeme bad:
1397 1.68 xtraeme prop_object_release(dict);
1398 1.72 xtraeme return NULL;
1399 1.18 xtraeme }
1400 1.18 xtraeme
1401 1.18 xtraeme /*
1402 1.18 xtraeme * sme_update_dictionary:
1403 1.18 xtraeme *
1404 1.18 xtraeme * + Update per-sensor dictionaries with new values if there were
1405 1.18 xtraeme * changes, otherwise the object in dictionary is untouched.
1406 1.18 xtraeme */
1407 1.18 xtraeme int
1408 1.18 xtraeme sme_update_dictionary(struct sysmon_envsys *sme)
1409 1.18 xtraeme {
1410 1.55 xtraeme const struct sme_description_table *sdt;
1411 1.55 xtraeme envsys_data_t *edata;
1412 1.72 xtraeme prop_object_t array, dict, obj, obj2;
1413 1.72 xtraeme int j, error = 0;
1414 1.18 xtraeme
1415 1.72 xtraeme /*
1416 1.72 xtraeme * Retrieve the array of dictionaries in device.
1417 1.72 xtraeme */
1418 1.18 xtraeme array = prop_dictionary_get(sme_propd, sme->sme_name);
1419 1.24 xtraeme if (prop_object_type(array) != PROP_TYPE_ARRAY) {
1420 1.24 xtraeme DPRINTF(("%s: not an array (%s)\n", __func__, sme->sme_name));
1421 1.18 xtraeme return EINVAL;
1422 1.24 xtraeme }
1423 1.18 xtraeme
1424 1.72 xtraeme /*
1425 1.72 xtraeme * Get the last dictionary on the array, this contains the
1426 1.72 xtraeme * 'device-properties' sub-dictionary.
1427 1.72 xtraeme */
1428 1.72 xtraeme obj = prop_array_get(array, prop_array_count(array) - 1);
1429 1.72 xtraeme if (!obj || prop_object_type(obj) != PROP_TYPE_DICTIONARY) {
1430 1.72 xtraeme DPRINTF(("%s: not a device-properties dictionary\n", __func__));
1431 1.72 xtraeme return EINVAL;
1432 1.72 xtraeme }
1433 1.72 xtraeme
1434 1.72 xtraeme obj2 = prop_dictionary_get(obj, "device-properties");
1435 1.72 xtraeme if (!obj2)
1436 1.72 xtraeme return EINVAL;
1437 1.72 xtraeme
1438 1.72 xtraeme /*
1439 1.72 xtraeme * Update the 'refresh-timeout' property.
1440 1.72 xtraeme */
1441 1.72 xtraeme if (!prop_dictionary_set_uint64(obj2, "refresh-timeout",
1442 1.72 xtraeme sme->sme_events_timeout))
1443 1.72 xtraeme return EINVAL;
1444 1.72 xtraeme
1445 1.18 xtraeme /*
1446 1.18 xtraeme * - iterate over all sensors.
1447 1.18 xtraeme * - fetch new data.
1448 1.18 xtraeme * - check if data in dictionary is different than new data.
1449 1.18 xtraeme * - update dictionary if there were changes.
1450 1.18 xtraeme */
1451 1.56 xtraeme DPRINTF(("%s: updating '%s' with nsensors=%d\n", __func__,
1452 1.56 xtraeme sme->sme_name, sme->sme_nsensors));
1453 1.56 xtraeme
1454 1.82 xtraeme /*
1455 1.82 xtraeme * Don't bother with locking when traversing the queue,
1456 1.82 xtraeme * the device is already marked as busy; if a sensor
1457 1.82 xtraeme * is going to be removed or added it will have to wait.
1458 1.82 xtraeme */
1459 1.72 xtraeme TAILQ_FOREACH(edata, &sme->sme_sensors_list, sensors_head) {
1460 1.18 xtraeme /*
1461 1.72 xtraeme * refresh sensor data via sme_refresh only if the
1462 1.18 xtraeme * flag is not set.
1463 1.18 xtraeme */
1464 1.82 xtraeme if ((sme->sme_flags & SME_DISABLE_REFRESH) == 0) {
1465 1.82 xtraeme mutex_enter(&sme->sme_mtx);
1466 1.72 xtraeme (*sme->sme_refresh)(sme, edata);
1467 1.82 xtraeme mutex_exit(&sme->sme_mtx);
1468 1.82 xtraeme }
1469 1.18 xtraeme
1470 1.72 xtraeme /*
1471 1.72 xtraeme * retrieve sensor's dictionary.
1472 1.72 xtraeme */
1473 1.72 xtraeme dict = prop_array_get(array, edata->sensor);
1474 1.24 xtraeme if (prop_object_type(dict) != PROP_TYPE_DICTIONARY) {
1475 1.24 xtraeme DPRINTF(("%s: not a dictionary (%d:%s)\n",
1476 1.24 xtraeme __func__, edata->sensor, sme->sme_name));
1477 1.18 xtraeme return EINVAL;
1478 1.24 xtraeme }
1479 1.18 xtraeme
1480 1.72 xtraeme /*
1481 1.72 xtraeme * update sensor's state.
1482 1.72 xtraeme */
1483 1.55 xtraeme sdt = sme_get_description_table(SME_DESC_STATES);
1484 1.55 xtraeme for (j = 0; sdt[j].type != -1; j++)
1485 1.55 xtraeme if (sdt[j].type == edata->state)
1486 1.18 xtraeme break;
1487 1.18 xtraeme
1488 1.18 xtraeme DPRINTFOBJ(("%s: state=%s type=%d flags=%d "
1489 1.55 xtraeme "units=%d sensor=%d\n", __func__, sdt[j].desc,
1490 1.55 xtraeme sdt[j].type, edata->flags, edata->units, edata->sensor));
1491 1.18 xtraeme
1492 1.55 xtraeme error = sme_sensor_upstring(dict, "state", sdt[j].desc);
1493 1.30 xtraeme if (error)
1494 1.30 xtraeme break;
1495 1.18 xtraeme
1496 1.72 xtraeme /*
1497 1.72 xtraeme * update sensor's type.
1498 1.72 xtraeme */
1499 1.55 xtraeme sdt = sme_get_description_table(SME_DESC_UNITS);
1500 1.55 xtraeme for (j = 0; sdt[j].type != -1; j++)
1501 1.55 xtraeme if (sdt[j].type == edata->units)
1502 1.45 xtraeme break;
1503 1.45 xtraeme
1504 1.55 xtraeme error = sme_sensor_upstring(dict, "type", sdt[j].desc);
1505 1.45 xtraeme if (error)
1506 1.45 xtraeme break;
1507 1.45 xtraeme
1508 1.72 xtraeme /*
1509 1.72 xtraeme * update sensor's current value.
1510 1.72 xtraeme */
1511 1.34 xtraeme error = sme_sensor_upint32(dict,
1512 1.30 xtraeme "cur-value",
1513 1.30 xtraeme edata->value_cur);
1514 1.30 xtraeme if (error)
1515 1.30 xtraeme break;
1516 1.18 xtraeme
1517 1.18 xtraeme /*
1518 1.71 xtraeme * Battery charge, Integer and Indicator types do not
1519 1.71 xtraeme * need the following objects, so skip them.
1520 1.18 xtraeme */
1521 1.18 xtraeme if (edata->units == ENVSYS_INTEGER ||
1522 1.71 xtraeme edata->units == ENVSYS_INDICATOR ||
1523 1.71 xtraeme edata->units == ENVSYS_BATTERY_CHARGE)
1524 1.18 xtraeme continue;
1525 1.18 xtraeme
1526 1.72 xtraeme /*
1527 1.72 xtraeme * update sensor flags.
1528 1.72 xtraeme */
1529 1.30 xtraeme if (edata->flags & ENVSYS_FPERCENT) {
1530 1.34 xtraeme error = sme_sensor_upbool(dict,
1531 1.30 xtraeme "want-percentage",
1532 1.30 xtraeme true);
1533 1.30 xtraeme if (error)
1534 1.30 xtraeme break;
1535 1.18 xtraeme }
1536 1.18 xtraeme
1537 1.72 xtraeme /*
1538 1.72 xtraeme * update sensor's {avg,max,min}-value.
1539 1.72 xtraeme */
1540 1.30 xtraeme if (edata->flags & ENVSYS_FVALID_MAX) {
1541 1.34 xtraeme error = sme_sensor_upint32(dict,
1542 1.30 xtraeme "max-value",
1543 1.30 xtraeme edata->value_max);
1544 1.30 xtraeme if (error)
1545 1.30 xtraeme break;
1546 1.30 xtraeme }
1547 1.30 xtraeme
1548 1.30 xtraeme if (edata->flags & ENVSYS_FVALID_MIN) {
1549 1.34 xtraeme error = sme_sensor_upint32(dict,
1550 1.30 xtraeme "min-value",
1551 1.30 xtraeme edata->value_min);
1552 1.30 xtraeme if (error)
1553 1.30 xtraeme break;
1554 1.30 xtraeme }
1555 1.18 xtraeme
1556 1.30 xtraeme if (edata->flags & ENVSYS_FVALID_AVG) {
1557 1.34 xtraeme error = sme_sensor_upint32(dict,
1558 1.30 xtraeme "avg-value",
1559 1.30 xtraeme edata->value_avg);
1560 1.30 xtraeme if (error)
1561 1.30 xtraeme break;
1562 1.30 xtraeme }
1563 1.18 xtraeme
1564 1.72 xtraeme /*
1565 1.72 xtraeme * update 'rpms' only for ENVSYS_SFANRPM sensors.
1566 1.72 xtraeme */
1567 1.30 xtraeme if (edata->units == ENVSYS_SFANRPM) {
1568 1.34 xtraeme error = sme_sensor_upuint32(dict,
1569 1.30 xtraeme "rpms",
1570 1.30 xtraeme edata->rpms);
1571 1.30 xtraeme if (error)
1572 1.30 xtraeme break;
1573 1.30 xtraeme }
1574 1.18 xtraeme
1575 1.72 xtraeme /*
1576 1.72 xtraeme * update 'rfact' only for ENVSYS_SVOLTS_[AD]C sensors.
1577 1.72 xtraeme */
1578 1.18 xtraeme if (edata->units == ENVSYS_SVOLTS_AC ||
1579 1.18 xtraeme edata->units == ENVSYS_SVOLTS_DC) {
1580 1.34 xtraeme error = sme_sensor_upint32(dict,
1581 1.30 xtraeme "rfact",
1582 1.30 xtraeme edata->rfact);
1583 1.30 xtraeme if (error)
1584 1.30 xtraeme break;
1585 1.18 xtraeme }
1586 1.18 xtraeme
1587 1.72 xtraeme /*
1588 1.72 xtraeme * update 'drive-state' only for ENVSYS_DRIVE sensors.
1589 1.72 xtraeme */
1590 1.18 xtraeme if (edata->units == ENVSYS_DRIVE) {
1591 1.55 xtraeme sdt = sme_get_description_table(SME_DESC_DRIVE_STATES);
1592 1.55 xtraeme for (j = 0; sdt[j].type != -1; j++)
1593 1.55 xtraeme if (sdt[j].type == edata->value_cur)
1594 1.18 xtraeme break;
1595 1.18 xtraeme
1596 1.34 xtraeme error = sme_sensor_upstring(dict,
1597 1.30 xtraeme "drive-state",
1598 1.55 xtraeme sdt[j].desc);
1599 1.55 xtraeme if (error)
1600 1.55 xtraeme break;
1601 1.55 xtraeme }
1602 1.55 xtraeme
1603 1.72 xtraeme /*
1604 1.72 xtraeme * update 'battery-capacity' only for ENVSYS_BATTERY_CAPACITY
1605 1.72 xtraeme * sensors.
1606 1.72 xtraeme */
1607 1.71 xtraeme if (edata->units == ENVSYS_BATTERY_CAPACITY) {
1608 1.55 xtraeme sdt =
1609 1.72 xtraeme sme_get_description_table(SME_DESC_BATTERY_CAPACITY);
1610 1.55 xtraeme for (j = 0; sdt[j].type != -1; j++)
1611 1.55 xtraeme if (sdt[j].type == edata->value_cur)
1612 1.55 xtraeme break;
1613 1.55 xtraeme
1614 1.55 xtraeme error = sme_sensor_upstring(dict,
1615 1.71 xtraeme "battery-capacity",
1616 1.55 xtraeme sdt[j].desc);
1617 1.32 xtraeme if (error)
1618 1.32 xtraeme break;
1619 1.7 yamt }
1620 1.1 thorpej }
1621 1.1 thorpej
1622 1.18 xtraeme return error;
1623 1.1 thorpej }
1624 1.1 thorpej
1625 1.1 thorpej /*
1626 1.18 xtraeme * sme_userset_dictionary:
1627 1.1 thorpej *
1628 1.72 xtraeme * + Parse the userland dictionary and run the appropiate tasks
1629 1.72 xtraeme * that were specified.
1630 1.1 thorpej */
1631 1.18 xtraeme int
1632 1.18 xtraeme sme_userset_dictionary(struct sysmon_envsys *sme, prop_dictionary_t udict,
1633 1.18 xtraeme prop_array_t array)
1634 1.1 thorpej {
1635 1.55 xtraeme const struct sme_description_table *sdt;
1636 1.72 xtraeme envsys_data_t *edata;
1637 1.72 xtraeme prop_dictionary_t dict, tdict = NULL;
1638 1.72 xtraeme prop_object_t obj, obj1, obj2, tobj = NULL;
1639 1.72 xtraeme uint64_t refresh_timo = 0;
1640 1.18 xtraeme int32_t critval;
1641 1.72 xtraeme int i, error = 0;
1642 1.72 xtraeme const char *blah;
1643 1.18 xtraeme bool targetfound = false;
1644 1.18 xtraeme
1645 1.72 xtraeme /*
1646 1.72 xtraeme * The user wanted to change the refresh timeout value for this
1647 1.72 xtraeme * device.
1648 1.72 xtraeme *
1649 1.72 xtraeme * Get the 'device-properties' object from the userland dictionary.
1650 1.72 xtraeme */
1651 1.72 xtraeme obj = prop_dictionary_get(udict, "device-properties");
1652 1.72 xtraeme if (obj && prop_object_type(obj) == PROP_TYPE_DICTIONARY) {
1653 1.72 xtraeme /*
1654 1.72 xtraeme * Get the 'refresh-timeout' property for this device.
1655 1.72 xtraeme */
1656 1.72 xtraeme obj1 = prop_dictionary_get(obj, "refresh-timeout");
1657 1.72 xtraeme if (obj1 && prop_object_type(obj1) == PROP_TYPE_NUMBER) {
1658 1.72 xtraeme targetfound = true;
1659 1.72 xtraeme refresh_timo =
1660 1.72 xtraeme prop_number_unsigned_integer_value(obj1);
1661 1.72 xtraeme if (refresh_timo < 1)
1662 1.72 xtraeme error = EINVAL;
1663 1.82 xtraeme else {
1664 1.82 xtraeme mutex_enter(&sme->sme_mtx);
1665 1.72 xtraeme sme->sme_events_timeout = refresh_timo;
1666 1.82 xtraeme mutex_exit(&sme->sme_mtx);
1667 1.82 xtraeme }
1668 1.72 xtraeme }
1669 1.82 xtraeme return error;
1670 1.1 thorpej
1671 1.72 xtraeme } else if (!obj) {
1672 1.69 xtraeme /*
1673 1.72 xtraeme * Get sensor's index from userland dictionary.
1674 1.69 xtraeme */
1675 1.72 xtraeme obj = prop_dictionary_get(udict, "index");
1676 1.72 xtraeme if (!obj)
1677 1.82 xtraeme return EINVAL;
1678 1.72 xtraeme if (prop_object_type(obj) != PROP_TYPE_STRING) {
1679 1.72 xtraeme DPRINTF(("%s: 'index' not a string\n", __func__));
1680 1.72 xtraeme return EINVAL;
1681 1.40 xtraeme }
1682 1.72 xtraeme } else
1683 1.72 xtraeme return EINVAL;
1684 1.27 xtraeme
1685 1.82 xtraeme /*
1686 1.82 xtraeme * Don't bother with locking when traversing the queue,
1687 1.82 xtraeme * the device is already marked as busy; if a sensor
1688 1.82 xtraeme * is going to be removed or added it will have to wait.
1689 1.72 xtraeme */
1690 1.72 xtraeme TAILQ_FOREACH(edata, &sme->sme_sensors_list, sensors_head) {
1691 1.72 xtraeme /*
1692 1.72 xtraeme * Get a dictionary and check if it's our sensor by checking
1693 1.72 xtraeme * at its index position.
1694 1.72 xtraeme */
1695 1.72 xtraeme dict = prop_array_get(array, edata->sensor);
1696 1.69 xtraeme obj1 = prop_dictionary_get(dict, "index");
1697 1.18 xtraeme
1698 1.72 xtraeme /*
1699 1.72 xtraeme * is it our sensor?
1700 1.72 xtraeme */
1701 1.18 xtraeme if (!prop_string_equals(obj1, obj))
1702 1.18 xtraeme continue;
1703 1.18 xtraeme
1704 1.18 xtraeme /*
1705 1.18 xtraeme * Check if a new description operation was
1706 1.18 xtraeme * requested by the user and set new description.
1707 1.18 xtraeme */
1708 1.72 xtraeme obj2 = prop_dictionary_get(udict, "description");
1709 1.72 xtraeme if (obj2 && prop_object_type(obj2) == PROP_TYPE_STRING) {
1710 1.18 xtraeme targetfound = true;
1711 1.18 xtraeme blah = prop_string_cstring_nocopy(obj2);
1712 1.72 xtraeme
1713 1.72 xtraeme /*
1714 1.72 xtraeme * Check for duplicate description.
1715 1.72 xtraeme */
1716 1.23 xtraeme for (i = 0; i < sme->sme_nsensors; i++) {
1717 1.23 xtraeme if (i == edata->sensor)
1718 1.23 xtraeme continue;
1719 1.72 xtraeme tdict = prop_array_get(array, i);
1720 1.72 xtraeme tobj =
1721 1.72 xtraeme prop_dictionary_get(tdict, "description");
1722 1.82 xtraeme if (prop_string_equals(obj2, tobj)) {
1723 1.82 xtraeme error = EEXIST;
1724 1.82 xtraeme goto out;
1725 1.82 xtraeme }
1726 1.23 xtraeme }
1727 1.23 xtraeme
1728 1.72 xtraeme /*
1729 1.72 xtraeme * Update the object in dictionary.
1730 1.72 xtraeme */
1731 1.82 xtraeme mutex_enter(&sme->sme_mtx);
1732 1.34 xtraeme error = sme_sensor_upstring(dict,
1733 1.30 xtraeme "description",
1734 1.30 xtraeme blah);
1735 1.82 xtraeme if (error) {
1736 1.82 xtraeme mutex_exit(&sme->sme_mtx);
1737 1.82 xtraeme goto out;
1738 1.82 xtraeme }
1739 1.18 xtraeme
1740 1.72 xtraeme DPRINTF(("%s: sensor%d changed desc to: %s\n",
1741 1.72 xtraeme __func__, edata->sensor, blah));
1742 1.69 xtraeme edata->upropset |= USERPROP_DESC;
1743 1.82 xtraeme mutex_exit(&sme->sme_mtx);
1744 1.18 xtraeme }
1745 1.18 xtraeme
1746 1.69 xtraeme /*
1747 1.69 xtraeme * did the user want to change the rfact?
1748 1.69 xtraeme */
1749 1.69 xtraeme obj2 = prop_dictionary_get(udict, "rfact");
1750 1.72 xtraeme if (obj2 && prop_object_type(obj2) == PROP_TYPE_NUMBER) {
1751 1.18 xtraeme targetfound = true;
1752 1.69 xtraeme if (edata->flags & ENVSYS_FCHANGERFACT) {
1753 1.82 xtraeme mutex_enter(&sme->sme_mtx);
1754 1.18 xtraeme edata->rfact = prop_number_integer_value(obj2);
1755 1.69 xtraeme edata->upropset |= USERPROP_RFACT;
1756 1.82 xtraeme mutex_exit(&sme->sme_mtx);
1757 1.72 xtraeme DPRINTF(("%s: sensor%d changed rfact to %d\n",
1758 1.72 xtraeme __func__, edata->sensor, edata->rfact));
1759 1.82 xtraeme } else {
1760 1.82 xtraeme error = ENOTSUP;
1761 1.82 xtraeme goto out;
1762 1.82 xtraeme }
1763 1.18 xtraeme }
1764 1.18 xtraeme
1765 1.55 xtraeme sdt = sme_get_description_table(SME_DESC_UNITS);
1766 1.55 xtraeme for (i = 0; sdt[i].type != -1; i++)
1767 1.55 xtraeme if (sdt[i].type == edata->units)
1768 1.18 xtraeme break;
1769 1.18 xtraeme
1770 1.69 xtraeme /*
1771 1.69 xtraeme * did the user want to set a critical capacity event?
1772 1.69 xtraeme *
1773 1.69 xtraeme * NOTE: if sme_event_register returns EEXIST that means
1774 1.69 xtraeme * the object is already there, but this is not a real
1775 1.69 xtraeme * error, because the object might be updated.
1776 1.69 xtraeme */
1777 1.18 xtraeme obj2 = prop_dictionary_get(udict, "critical-capacity");
1778 1.72 xtraeme if (obj2 && prop_object_type(obj2) == PROP_TYPE_NUMBER) {
1779 1.18 xtraeme targetfound = true;
1780 1.18 xtraeme if ((edata->flags & ENVSYS_FMONNOTSUPP) ||
1781 1.82 xtraeme (edata->flags & ENVSYS_FPERCENT) == 0) {
1782 1.82 xtraeme error = ENOTSUP;
1783 1.82 xtraeme goto out;
1784 1.82 xtraeme }
1785 1.18 xtraeme
1786 1.18 xtraeme critval = prop_number_integer_value(obj2);
1787 1.51 xtraeme error = sme_event_register(dict,
1788 1.18 xtraeme edata,
1789 1.72 xtraeme sme,
1790 1.18 xtraeme "critical-capacity",
1791 1.18 xtraeme critval,
1792 1.18 xtraeme PENVSYS_EVENT_BATT_USERCAP,
1793 1.55 xtraeme sdt[i].crittype);
1794 1.69 xtraeme if (error == EEXIST)
1795 1.69 xtraeme error = 0;
1796 1.72 xtraeme if (error)
1797 1.72 xtraeme goto out;
1798 1.82 xtraeme
1799 1.82 xtraeme mutex_enter(&sme->sme_mtx);
1800 1.82 xtraeme edata->upropset |= USERPROP_BATTCAP;
1801 1.82 xtraeme mutex_exit(&sme->sme_mtx);
1802 1.18 xtraeme }
1803 1.18 xtraeme
1804 1.69 xtraeme /*
1805 1.69 xtraeme * did the user want to set a critical max event?
1806 1.69 xtraeme */
1807 1.69 xtraeme obj2 = prop_dictionary_get(udict, "critical-max");
1808 1.72 xtraeme if (obj2 && prop_object_type(obj2) == PROP_TYPE_NUMBER) {
1809 1.18 xtraeme targetfound = true;
1810 1.18 xtraeme if (edata->units == ENVSYS_INDICATOR ||
1811 1.82 xtraeme edata->flags & ENVSYS_FMONNOTSUPP) {
1812 1.82 xtraeme error = ENOTSUP;
1813 1.82 xtraeme goto out;
1814 1.82 xtraeme }
1815 1.18 xtraeme
1816 1.18 xtraeme critval = prop_number_integer_value(obj2);
1817 1.51 xtraeme error = sme_event_register(dict,
1818 1.18 xtraeme edata,
1819 1.72 xtraeme sme,
1820 1.69 xtraeme "critical-max",
1821 1.18 xtraeme critval,
1822 1.18 xtraeme PENVSYS_EVENT_USER_CRITMAX,
1823 1.55 xtraeme sdt[i].crittype);
1824 1.69 xtraeme if (error == EEXIST)
1825 1.69 xtraeme error = 0;
1826 1.72 xtraeme if (error)
1827 1.72 xtraeme goto out;
1828 1.82 xtraeme
1829 1.82 xtraeme mutex_enter(&sme->sme_mtx);
1830 1.82 xtraeme edata->upropset |= USERPROP_CRITMAX;
1831 1.82 xtraeme mutex_exit(&sme->sme_mtx);
1832 1.18 xtraeme }
1833 1.18 xtraeme
1834 1.69 xtraeme /*
1835 1.69 xtraeme * did the user want to set a critical min event?
1836 1.69 xtraeme */
1837 1.69 xtraeme obj2 = prop_dictionary_get(udict, "critical-min");
1838 1.72 xtraeme if (obj2 && prop_object_type(obj2) == PROP_TYPE_NUMBER) {
1839 1.18 xtraeme targetfound = true;
1840 1.18 xtraeme if (edata->units == ENVSYS_INDICATOR ||
1841 1.82 xtraeme edata->flags & ENVSYS_FMONNOTSUPP) {
1842 1.82 xtraeme error = ENOTSUP;
1843 1.82 xtraeme goto out;
1844 1.82 xtraeme }
1845 1.18 xtraeme
1846 1.18 xtraeme critval = prop_number_integer_value(obj2);
1847 1.51 xtraeme error = sme_event_register(dict,
1848 1.18 xtraeme edata,
1849 1.72 xtraeme sme,
1850 1.69 xtraeme "critical-min",
1851 1.18 xtraeme critval,
1852 1.18 xtraeme PENVSYS_EVENT_USER_CRITMIN,
1853 1.55 xtraeme sdt[i].crittype);
1854 1.69 xtraeme if (error == EEXIST)
1855 1.69 xtraeme error = 0;
1856 1.72 xtraeme if (error)
1857 1.72 xtraeme goto out;
1858 1.82 xtraeme
1859 1.82 xtraeme mutex_enter(&sme->sme_mtx);
1860 1.82 xtraeme edata->upropset |= USERPROP_CRITMIN;
1861 1.82 xtraeme mutex_exit(&sme->sme_mtx);
1862 1.18 xtraeme }
1863 1.69 xtraeme
1864 1.69 xtraeme /*
1865 1.69 xtraeme * All objects in dictionary were processed.
1866 1.69 xtraeme */
1867 1.69 xtraeme break;
1868 1.18 xtraeme }
1869 1.18 xtraeme
1870 1.72 xtraeme out:
1871 1.72 xtraeme /*
1872 1.72 xtraeme * invalid target? return the error.
1873 1.72 xtraeme */
1874 1.18 xtraeme if (!targetfound)
1875 1.18 xtraeme error = EINVAL;
1876 1.18 xtraeme
1877 1.18 xtraeme return error;
1878 1.1 thorpej }
1879