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