Home | History | Annotate | Line # | Download | only in sysmon
sysmon_envsys.c revision 1.80.6.2
      1  1.80.6.1       mjf /*	$NetBSD: sysmon_envsys.c,v 1.80.6.2 2008/06/05 19:14:35 mjf Exp $	*/
      2      1.18   xtraeme 
      3      1.18   xtraeme /*-
      4  1.80.6.1       mjf  * 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.80.6.1       mjf __KERNEL_RCSID(0, "$NetBSD: sysmon_envsys.c,v 1.80.6.2 2008/06/05 19:14:35 mjf 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.80.6.1       mjf 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.80.6.1       mjf 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.80.6.1       mjf 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.80.6.1       mjf  * 	+ 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.80.6.1       mjf 	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.80.6.1       mjf 		mutex_enter(&sme_global_mtx);
    168      1.18   xtraeme 		LIST_FOREACH(sme, &sysmon_envsys_list, sme_list) {
    169  1.80.6.1       mjf 			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.80.6.1       mjf 				sysmon_envsys_release(sme, false);
    175  1.80.6.1       mjf 				mutex_exit(&sme_global_mtx);
    176      1.18   xtraeme 				return error;
    177      1.18   xtraeme 			}
    178  1.80.6.1       mjf 			sysmon_envsys_release(sme, false);
    179      1.18   xtraeme 		}
    180  1.80.6.1       mjf 		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.80.6.1       mjf 				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.80.6.1       mjf 				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.80.6.1       mjf 					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.80.6.1       mjf 			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.80.6.1       mjf 		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.80.6.1       mjf 			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.80.6.2       mjf 			if ((sme->sme_flags & SME_DISABLE_REFRESH) == 0 &&
    365  1.80.6.2       mjf 			    (sme->sme_flags & SME_POLL_ONLY) == 0) {
    366  1.80.6.1       mjf 				mutex_enter(&sme->sme_mtx);
    367      1.72   xtraeme 				(*sme->sme_refresh)(sme, edata);
    368  1.80.6.1       mjf 				mutex_exit(&sme->sme_mtx);
    369  1.80.6.1       mjf 			}
    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.80.6.1       mjf 		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.80.6.1       mjf 		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.80.6.1       mjf 			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.80.6.1       mjf 		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.80.6.1       mjf 	mutex_init(&sme->sme_mtx, MUTEX_DEFAULT, IPL_NONE);
    493  1.80.6.1       mjf 	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.80.6.1       mjf 	mutex_destroy(&sme->sme_mtx);
    516  1.80.6.1       mjf 	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.80.6.1       mjf 	mutex_enter(&sme->sme_mtx);
    553  1.80.6.1       mjf 	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.80.6.1       mjf 			sysmon_envsys_release(sme, true);
    557  1.80.6.1       mjf 			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.80.6.1       mjf 	sysmon_envsys_release(sme, true);
    572  1.80.6.1       mjf 	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.80.6.1       mjf 	mutex_enter(&sme->sme_mtx);
    595  1.80.6.1       mjf 	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.80.6.1       mjf 		sysmon_envsys_release(sme, true);
    605  1.80.6.1       mjf 		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.80.6.1       mjf 	sysmon_envsys_release(sme, true);
    615  1.80.6.1       mjf 	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.80.6.1       mjf 	struct sme_evdrv *evdv = NULL;
    636      1.18   xtraeme 	struct sysmon_envsys *lsme;
    637  1.80.6.1       mjf 	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.80.6.1       mjf 	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.80.6.1       mjf 	 * Check if requested sysmon_envsys device is valid
    647  1.80.6.1       mjf 	 * and does not exist already in the list.
    648  1.80.6.1       mjf 	 */
    649  1.80.6.1       mjf 	mutex_enter(&sme_global_mtx);
    650  1.80.6.1       mjf 	LIST_FOREACH(lsme, &sysmon_envsys_list, sme_list) {
    651  1.80.6.1       mjf 	       if (strcmp(lsme->sme_name, sme->sme_name) == 0) {
    652  1.80.6.1       mjf 		       mutex_exit(&sme_global_mtx);
    653  1.80.6.1       mjf 		       return EEXIST;
    654  1.80.6.1       mjf 	       }
    655  1.80.6.1       mjf 	}
    656  1.80.6.1       mjf 	mutex_exit(&sme_global_mtx);
    657  1.80.6.1       mjf 
    658  1.80.6.1       mjf 	/*
    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.80.6.1       mjf 	 * Initialize the singly linked list for driver events.
    677      1.72   xtraeme 	 */
    678  1.80.6.1       mjf 	SLIST_INIT(&sme_evdrv_list);
    679  1.80.6.1       mjf 
    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.80.6.1       mjf 		evdv = kmem_zalloc(sizeof(*evdv), KM_SLEEP);
    699  1.80.6.1       mjf 		evdv->evdrv = sme_add_sensor_dictionary(sme, array,
    700  1.80.6.1       mjf 				    	      		dict, edata);
    701  1.80.6.1       mjf 		if (evdv->evdrv)
    702  1.80.6.1       mjf 			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.80.6.1       mjf 	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.80.6.1       mjf 
    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.80.6.1       mjf 	mutex_exit(&sme_global_mtx);
    754      1.56   xtraeme 
    755  1.80.6.1       mjf out:
    756      1.72   xtraeme 	/*
    757  1.80.6.1       mjf 	 * No errors? register the events that were set in the driver
    758  1.80.6.1       mjf 	 * and make an initial data refresh if was requested.
    759      1.72   xtraeme 	 */
    760      1.56   xtraeme 	if (error == 0) {
    761  1.80.6.1       mjf 		sysmon_task_queue_init();
    762  1.80.6.1       mjf 		SLIST_FOREACH(evdv, &sme_evdrv_list, evdrv_head) {
    763      1.58   xtraeme 			sysmon_task_queue_sched(0,
    764  1.80.6.1       mjf 			    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.80.6.1       mjf 
    769  1.80.6.1       mjf 		if (sme->sme_flags & SME_INIT_REFRESH)
    770  1.80.6.1       mjf 			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.80.6.1       mjf 		evdv = SLIST_FIRST(&sme_evdrv_list);
    776      1.58   xtraeme 		SLIST_REMOVE_HEAD(&sme_evdrv_list, evdrv_head);
    777  1.80.6.1       mjf 		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.80.6.1       mjf 
    789  1.80.6.1       mjf 	sme_event_unregister_all(sme);
    790  1.80.6.1       mjf 	while (!TAILQ_EMPTY(&sme->sme_sensors_list)) {
    791  1.80.6.1       mjf 		edata = TAILQ_FIRST(&sme->sme_sensors_list);
    792  1.80.6.1       mjf 		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.80.6.1       mjf 	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.80.6.1       mjf 	 * Unregister all events associated with device.
    859      1.72   xtraeme 	 */
    860  1.80.6.1       mjf 	sme_event_unregister_all(sme);
    861      1.72   xtraeme 	/*
    862  1.80.6.1       mjf 	 * Decrement global sensors counter (only used for compatibility
    863  1.80.6.1       mjf 	 * with previous API) and remove the device from the list.
    864      1.27   xtraeme 	 */
    865  1.80.6.1       mjf 	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.80.6.1       mjf 	mutex_exit(&sme_global_mtx);
    869  1.80.6.1       mjf 
    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.80.6.1       mjf 		mutex_enter(&sme_global_mtx);
    876      1.63   xtraeme 		prop_dictionary_remove(sme_propd, sme->sme_name);
    877  1.80.6.1       mjf 		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.80.6.1       mjf  *	+ Find a sysmon envsys device and mark it as busy
    890  1.80.6.1       mjf  *	  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.80.6.1       mjf 	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.80.6.1       mjf 			sysmon_envsys_acquire(sme, false);
    901  1.80.6.1       mjf 			break;
    902  1.80.6.1       mjf 		}
    903  1.80.6.1       mjf 	}
    904  1.80.6.1       mjf 	mutex_exit(&sme_global_mtx);
    905  1.80.6.1       mjf 
    906  1.80.6.1       mjf 	return sme;
    907  1.80.6.1       mjf }
    908  1.80.6.1       mjf 
    909  1.80.6.1       mjf /*
    910  1.80.6.1       mjf  * Compatibility function with the old API.
    911  1.80.6.1       mjf  */
    912  1.80.6.1       mjf struct sysmon_envsys *
    913  1.80.6.1       mjf sysmon_envsys_find_40(u_int idx)
    914  1.80.6.1       mjf {
    915  1.80.6.1       mjf 	struct sysmon_envsys *sme;
    916  1.80.6.1       mjf 
    917  1.80.6.1       mjf 	mutex_enter(&sme_global_mtx);
    918  1.80.6.1       mjf 	LIST_FOREACH(sme, &sysmon_envsys_list, sme_list) {
    919  1.80.6.1       mjf 		if (idx >= sme->sme_fsensor &&
    920  1.80.6.1       mjf 	    	    idx < (sme->sme_fsensor + sme->sme_nsensors)) {
    921  1.80.6.1       mjf 			sysmon_envsys_acquire(sme, false);
    922      1.79   xtraeme 			break;
    923      1.79   xtraeme 		}
    924      1.18   xtraeme 	}
    925  1.80.6.1       mjf 	mutex_exit(&sme_global_mtx);
    926  1.80.6.1       mjf 
    927      1.18   xtraeme 	return sme;
    928      1.18   xtraeme }
    929      1.18   xtraeme 
    930      1.18   xtraeme /*
    931      1.72   xtraeme  * sysmon_envsys_acquire:
    932      1.72   xtraeme  *
    933  1.80.6.1       mjf  * 	+ Wait until a sysmon envsys device is available and mark
    934  1.80.6.1       mjf  * 	  it as busy.
    935      1.72   xtraeme  */
    936      1.72   xtraeme void
    937  1.80.6.1       mjf sysmon_envsys_acquire(struct sysmon_envsys *sme, bool locked)
    938      1.72   xtraeme {
    939  1.80.6.1       mjf 	KASSERT(sme != NULL);
    940      1.72   xtraeme 
    941  1.80.6.1       mjf 	if (locked) {
    942  1.80.6.1       mjf 		while (sme->sme_flags & SME_FLAG_BUSY)
    943  1.80.6.1       mjf 			cv_wait(&sme->sme_condvar, &sme->sme_mtx);
    944  1.80.6.1       mjf 		sme->sme_flags |= SME_FLAG_BUSY;
    945  1.80.6.1       mjf 	} else {
    946  1.80.6.1       mjf 		mutex_enter(&sme->sme_mtx);
    947  1.80.6.1       mjf 		while (sme->sme_flags & SME_FLAG_BUSY)
    948  1.80.6.1       mjf 			cv_wait(&sme->sme_condvar, &sme->sme_mtx);
    949  1.80.6.1       mjf 		sme->sme_flags |= SME_FLAG_BUSY;
    950  1.80.6.1       mjf 		mutex_exit(&sme->sme_mtx);
    951  1.80.6.1       mjf 	}
    952      1.72   xtraeme }
    953      1.72   xtraeme 
    954      1.72   xtraeme /*
    955      1.18   xtraeme  * sysmon_envsys_release:
    956      1.18   xtraeme  *
    957  1.80.6.1       mjf  * 	+ Unmark a sysmon envsys device as busy, and notify
    958  1.80.6.1       mjf  * 	  waiters.
    959      1.18   xtraeme  */
    960      1.18   xtraeme void
    961  1.80.6.1       mjf sysmon_envsys_release(struct sysmon_envsys *sme, bool locked)
    962      1.18   xtraeme {
    963  1.80.6.1       mjf 	KASSERT(sme != NULL);
    964      1.72   xtraeme 
    965  1.80.6.1       mjf 	if (locked) {
    966  1.80.6.1       mjf 		sme->sme_flags &= ~SME_FLAG_BUSY;
    967  1.80.6.1       mjf 		cv_broadcast(&sme->sme_condvar);
    968  1.80.6.1       mjf 	} else {
    969  1.80.6.1       mjf 		mutex_enter(&sme->sme_mtx);
    970  1.80.6.1       mjf 		sme->sme_flags &= ~SME_FLAG_BUSY;
    971  1.80.6.1       mjf 		cv_broadcast(&sme->sme_condvar);
    972  1.80.6.1       mjf 		mutex_exit(&sme->sme_mtx);
    973  1.80.6.1       mjf 	}
    974      1.18   xtraeme }
    975      1.18   xtraeme 
    976  1.80.6.1       mjf /*
    977  1.80.6.1       mjf  * sme_initial_refresh:
    978  1.80.6.1       mjf  *
    979  1.80.6.1       mjf  * 	+ Do an initial refresh of the sensors in a device just after
    980  1.80.6.1       mjf  * 	  interrupts are enabled in the autoconf(9) process.
    981  1.80.6.1       mjf  *
    982  1.80.6.1       mjf  */
    983  1.80.6.1       mjf static void
    984  1.80.6.1       mjf sme_initial_refresh(void *arg)
    985      1.18   xtraeme {
    986  1.80.6.1       mjf 	struct sysmon_envsys *sme = arg;
    987  1.80.6.1       mjf 	envsys_data_t *edata;
    988      1.72   xtraeme 
    989  1.80.6.1       mjf 	mutex_enter(&sme->sme_mtx);
    990  1.80.6.1       mjf 	sysmon_envsys_acquire(sme, true);
    991  1.80.6.1       mjf 	TAILQ_FOREACH(edata, &sme->sme_sensors_list, sensors_head)
    992  1.80.6.1       mjf 		(*sme->sme_refresh)(sme, edata);
    993  1.80.6.1       mjf 	sysmon_envsys_release(sme, true);
    994  1.80.6.1       mjf 	mutex_exit(&sme->sme_mtx);
    995      1.18   xtraeme }
    996      1.18   xtraeme 
    997      1.18   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.80.6.1       mjf 	mutex_enter(&sme_global_mtx);
   1043      1.69   xtraeme 	LIST_FOREACH(sme, &sysmon_envsys_list, sme_list) {
   1044  1.80.6.1       mjf 		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.80.6.1       mjf 		sysmon_envsys_release(sme, false);
   1092      1.69   xtraeme 	}
   1093  1.80.6.1       mjf 	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.80.6.1       mjf 	/*
   1455  1.80.6.1       mjf 	 * Don't bother with locking when traversing the queue,
   1456  1.80.6.1       mjf 	 * the device is already marked as busy; if a sensor
   1457  1.80.6.1       mjf 	 * is going to be removed or added it will have to wait.
   1458  1.80.6.1       mjf 	 */
   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.80.6.1       mjf 		if ((sme->sme_flags & SME_DISABLE_REFRESH) == 0) {
   1465  1.80.6.1       mjf 			mutex_enter(&sme->sme_mtx);
   1466      1.72   xtraeme 			(*sme->sme_refresh)(sme, edata);
   1467  1.80.6.1       mjf 			mutex_exit(&sme->sme_mtx);
   1468  1.80.6.1       mjf 		}
   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.80.6.1       mjf 			else {
   1664  1.80.6.1       mjf 				mutex_enter(&sme->sme_mtx);
   1665      1.72   xtraeme 				sme->sme_events_timeout = refresh_timo;
   1666  1.80.6.1       mjf 				mutex_exit(&sme->sme_mtx);
   1667      1.72   xtraeme 		}
   1668  1.80.6.1       mjf 		}
   1669  1.80.6.1       mjf 		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.80.6.1       mjf 			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.80.6.1       mjf 	/*
   1686  1.80.6.1       mjf 	 * Don't bother with locking when traversing the queue,
   1687  1.80.6.1       mjf 	 * the device is already marked as busy; if a sensor
   1688  1.80.6.1       mjf 	 * 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.80.6.1       mjf 				if (prop_string_equals(obj2, tobj)) {
   1723  1.80.6.1       mjf 					error = EEXIST;
   1724  1.80.6.1       mjf 					goto out;
   1725  1.80.6.1       mjf 				}
   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.80.6.1       mjf 			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.80.6.1       mjf 			if (error) {
   1736  1.80.6.1       mjf 				mutex_exit(&sme->sme_mtx);
   1737  1.80.6.1       mjf 				goto out;
   1738  1.80.6.1       mjf 			}
   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.80.6.1       mjf 			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.80.6.1       mjf 				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.80.6.1       mjf 				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.80.6.1       mjf 			} else {
   1760  1.80.6.1       mjf 				error = ENOTSUP;
   1761  1.80.6.1       mjf 				goto out;
   1762  1.80.6.1       mjf 			}
   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.80.6.1       mjf 			    (edata->flags & ENVSYS_FPERCENT) == 0) {
   1782  1.80.6.1       mjf 				error = ENOTSUP;
   1783  1.80.6.1       mjf 				goto out;
   1784  1.80.6.1       mjf 			}
   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.80.6.1       mjf 
   1799  1.80.6.1       mjf 			mutex_enter(&sme->sme_mtx);
   1800  1.80.6.1       mjf 			edata->upropset |= USERPROP_BATTCAP;
   1801  1.80.6.1       mjf 			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.80.6.1       mjf 			    edata->flags & ENVSYS_FMONNOTSUPP) {
   1812  1.80.6.1       mjf 				error = ENOTSUP;
   1813  1.80.6.1       mjf 				goto out;
   1814  1.80.6.1       mjf 			}
   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.80.6.1       mjf 
   1829  1.80.6.1       mjf 			mutex_enter(&sme->sme_mtx);
   1830  1.80.6.1       mjf 			edata->upropset |= USERPROP_CRITMAX;
   1831  1.80.6.1       mjf 			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.80.6.1       mjf 			    edata->flags & ENVSYS_FMONNOTSUPP) {
   1842  1.80.6.1       mjf 				error = ENOTSUP;
   1843  1.80.6.1       mjf 				goto out;
   1844  1.80.6.1       mjf 			}
   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.80.6.1       mjf 
   1859  1.80.6.1       mjf 			mutex_enter(&sme->sme_mtx);
   1860  1.80.6.1       mjf 			edata->upropset |= USERPROP_CRITMIN;
   1861  1.80.6.1       mjf 			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