Home | History | Annotate | Line # | Download | only in sysmon
sysmon_envsys_events.c revision 1.44
      1  1.44  xtraeme /* $NetBSD: sysmon_envsys_events.c,v 1.44 2007/11/03 23:05:21 xtraeme Exp $ */
      2   1.1  xtraeme 
      3   1.1  xtraeme /*-
      4  1.36  xtraeme  * Copyright (c) 2007 Juan Romero Pardines.
      5   1.1  xtraeme  * All rights reserved.
      6   1.1  xtraeme  *
      7   1.1  xtraeme  * Redistribution and use in source and binary forms, with or without
      8   1.1  xtraeme  * modification, are permitted provided that the following conditions
      9   1.1  xtraeme  * are met:
     10   1.1  xtraeme  * 1. Redistributions of source code must retain the above copyright
     11   1.1  xtraeme  *    notice, this list of conditions and the following disclaimer.
     12   1.1  xtraeme  * 2. Redistributions in binary form must reproduce the above copyright
     13   1.1  xtraeme  *    notice, this list of conditions and the following disclaimer in the
     14   1.1  xtraeme  *    documentation and/or other materials provided with the distribution.
     15   1.1  xtraeme  *
     16  1.36  xtraeme  * THIS SOFTWARE IS PROVIDED BY THE AUTHOR ``AS IS'' AND ANY EXPRESS OR
     17  1.36  xtraeme  * IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE IMPLIED WARRANTIES
     18  1.36  xtraeme  * OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE ARE DISCLAIMED.
     19  1.36  xtraeme  * IN NO EVENT SHALL THE AUTHOR BE LIABLE FOR ANY DIRECT, INDIRECT,
     20  1.36  xtraeme  * INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT
     21  1.36  xtraeme  * NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE,
     22  1.36  xtraeme  * DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY
     23  1.36  xtraeme  * THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT
     24  1.36  xtraeme  * (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE OF
     25  1.36  xtraeme  * THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.
     26   1.1  xtraeme  */
     27   1.1  xtraeme 
     28   1.1  xtraeme /*
     29   1.1  xtraeme  * sysmon_envsys(9) events framework.
     30   1.1  xtraeme  */
     31   1.1  xtraeme 
     32   1.1  xtraeme #include <sys/cdefs.h>
     33  1.44  xtraeme __KERNEL_RCSID(0, "$NetBSD: sysmon_envsys_events.c,v 1.44 2007/11/03 23:05:21 xtraeme Exp $");
     34   1.1  xtraeme 
     35   1.1  xtraeme #include <sys/param.h>
     36   1.1  xtraeme #include <sys/types.h>
     37   1.1  xtraeme #include <sys/conf.h>
     38   1.1  xtraeme #include <sys/errno.h>
     39   1.1  xtraeme #include <sys/kernel.h>
     40   1.3  xtraeme #include <sys/sysctl.h>
     41   1.1  xtraeme #include <sys/systm.h>
     42   1.1  xtraeme #include <sys/proc.h>
     43   1.1  xtraeme #include <sys/mutex.h>
     44   1.1  xtraeme #include <sys/kmem.h>
     45   1.1  xtraeme #include <sys/callout.h>
     46   1.1  xtraeme 
     47  1.32  xtraeme /* #define ENVSYS_DEBUG */
     48   1.1  xtraeme #include <dev/sysmon/sysmonvar.h>
     49   1.1  xtraeme #include <dev/sysmon/sysmon_envsysvar.h>
     50   1.1  xtraeme 
     51  1.10  xtraeme struct sme_sensor_event {
     52  1.10  xtraeme 	int		state;
     53  1.10  xtraeme 	int		event;
     54  1.10  xtraeme };
     55  1.10  xtraeme 
     56  1.10  xtraeme static const struct sme_sensor_event sme_sensor_event[] = {
     57  1.10  xtraeme 	{ ENVSYS_SVALID, 	PENVSYS_EVENT_NORMAL },
     58  1.10  xtraeme 	{ ENVSYS_SCRITICAL, 	PENVSYS_EVENT_CRITICAL },
     59  1.10  xtraeme 	{ ENVSYS_SCRITOVER, 	PENVSYS_EVENT_CRITOVER },
     60  1.10  xtraeme 	{ ENVSYS_SCRITUNDER, 	PENVSYS_EVENT_CRITUNDER },
     61  1.10  xtraeme 	{ ENVSYS_SWARNOVER, 	PENVSYS_EVENT_WARNOVER },
     62  1.10  xtraeme 	{ ENVSYS_SWARNUNDER,	PENVSYS_EVENT_WARNUNDER },
     63  1.10  xtraeme 	{ -1, 			-1 }
     64  1.10  xtraeme };
     65  1.10  xtraeme 
     66   1.1  xtraeme static struct workqueue *seewq;
     67   1.1  xtraeme static struct callout seeco;
     68   1.1  xtraeme static bool sme_events_initialized = false;
     69  1.38  xtraeme static bool sysmon_low_power = false;
     70  1.31  xtraeme kmutex_t sme_mtx, sme_event_init_mtx;
     71  1.33  xtraeme kcondvar_t sme_cv;
     72   1.1  xtraeme 
     73   1.3  xtraeme /* 10 seconds of timeout for the callout */
     74   1.3  xtraeme static int sme_events_timeout = 10;
     75   1.3  xtraeme static int sme_events_timeout_sysctl(SYSCTLFN_PROTO);
     76   1.3  xtraeme #define SME_EVTIMO 	(sme_events_timeout * hz)
     77   1.3  xtraeme 
     78  1.44  xtraeme static bool sme_event_check_low_power(void);
     79  1.44  xtraeme static bool sme_battery_critical(envsys_data_t *);
     80  1.38  xtraeme 
     81   1.3  xtraeme /*
     82   1.3  xtraeme  * sysctl(9) stuff to handle the refresh value in the callout
     83   1.3  xtraeme  * function.
     84   1.3  xtraeme  */
     85   1.3  xtraeme static int
     86   1.3  xtraeme sme_events_timeout_sysctl(SYSCTLFN_ARGS)
     87   1.3  xtraeme {
     88   1.3  xtraeme 	struct sysctlnode node;
     89   1.3  xtraeme 	int timo, error;
     90   1.3  xtraeme 
     91   1.3  xtraeme 	node = *rnode;
     92   1.3  xtraeme 	timo = sme_events_timeout;
     93   1.3  xtraeme 	node.sysctl_data = &timo;
     94   1.3  xtraeme 
     95   1.3  xtraeme 	error = sysctl_lookup(SYSCTLFN_CALL(&node));
     96  1.36  xtraeme 	if (error || !newp)
     97   1.3  xtraeme 		return error;
     98   1.3  xtraeme 
     99   1.5  xtraeme 	/* min 1s */
    100   1.5  xtraeme 	if (timo < 1)
    101   1.3  xtraeme 		return EINVAL;
    102   1.3  xtraeme 
    103   1.3  xtraeme 	sme_events_timeout = timo;
    104   1.3  xtraeme 	return 0;
    105   1.3  xtraeme }
    106   1.3  xtraeme 
    107   1.3  xtraeme SYSCTL_SETUP(sysctl_kern_envsys_timeout_setup, "sysctl kern.envsys subtree")
    108   1.3  xtraeme {
    109   1.3  xtraeme 	const struct sysctlnode *node, *envsys_node;
    110   1.3  xtraeme 
    111   1.3  xtraeme 	sysctl_createv(clog, 0, NULL, &node,
    112   1.3  xtraeme 			CTLFLAG_PERMANENT,
    113   1.3  xtraeme 			CTLTYPE_NODE, "kern", NULL,
    114   1.3  xtraeme 			NULL, 0, NULL, 0,
    115   1.3  xtraeme 			CTL_KERN, CTL_EOL);
    116   1.3  xtraeme 
    117   1.3  xtraeme 	sysctl_createv(clog, 0, &node, &envsys_node,
    118   1.3  xtraeme 			0,
    119   1.3  xtraeme 			CTLTYPE_NODE, "envsys", NULL,
    120   1.3  xtraeme 			NULL, 0, NULL, 0,
    121   1.3  xtraeme 			CTL_CREATE, CTL_EOL);
    122   1.3  xtraeme 
    123   1.3  xtraeme 	sysctl_createv(clog, 0, &envsys_node, &node,
    124   1.3  xtraeme 			CTLFLAG_READWRITE,
    125   1.3  xtraeme 			CTLTYPE_INT, "refresh_value",
    126   1.3  xtraeme 			SYSCTL_DESCR("wait time in seconds to refresh "
    127   1.3  xtraeme 			    "sensors being monitored"),
    128   1.3  xtraeme 			sme_events_timeout_sysctl, 0, &sme_events_timeout, 0,
    129   1.3  xtraeme 			CTL_CREATE, CTL_EOL);
    130   1.3  xtraeme }
    131   1.3  xtraeme 
    132   1.1  xtraeme /*
    133   1.1  xtraeme  * sme_event_register:
    134   1.1  xtraeme  *
    135  1.24  xtraeme  * 	+ Registers a new sysmon envsys event or updates any event
    136  1.24  xtraeme  * 	  already in the queue.
    137   1.1  xtraeme  */
    138   1.1  xtraeme int
    139  1.24  xtraeme sme_event_register(prop_dictionary_t sdict, envsys_data_t *edata,
    140  1.24  xtraeme 		   const char *drvn, const char *objkey,
    141  1.24  xtraeme 		   int32_t critval, int crittype, int powertype)
    142   1.1  xtraeme {
    143  1.24  xtraeme 	sme_event_t *see = NULL;
    144  1.24  xtraeme 	prop_object_t obj;
    145  1.24  xtraeme 	bool critvalup = false;
    146   1.1  xtraeme 	int error = 0;
    147   1.1  xtraeme 
    148  1.24  xtraeme 	KASSERT(sdict != NULL || edata != NULL);
    149   1.1  xtraeme 
    150  1.31  xtraeme 	mutex_enter(&sme_mtx);
    151   1.1  xtraeme 	/*
    152  1.24  xtraeme 	 * check if the event is already on the list and return
    153  1.24  xtraeme 	 * EEXIST if value provided hasn't been changed.
    154   1.1  xtraeme 	 */
    155  1.24  xtraeme 	LIST_FOREACH(see, &sme_events_list, see_list) {
    156  1.24  xtraeme 		if (strcmp(edata->desc, see->pes.pes_sensname) == 0)
    157  1.24  xtraeme 			if (crittype == see->type) {
    158  1.24  xtraeme 				if (see->critval == critval) {
    159  1.24  xtraeme 					DPRINTF(("%s: dev=%s sensor=%s type=%d "
    160  1.24  xtraeme 				    	    "(already exists)\n", __func__,
    161  1.24  xtraeme 				    	    see->pes.pes_dvname,
    162  1.24  xtraeme 				    	    see->pes.pes_sensname, see->type));
    163  1.31  xtraeme 					mutex_exit(&sme_mtx);
    164  1.24  xtraeme 					return EEXIST;
    165  1.24  xtraeme 				}
    166  1.24  xtraeme 				critvalup = true;
    167  1.24  xtraeme 				break;
    168   1.1  xtraeme 			}
    169  1.24  xtraeme 	}
    170  1.24  xtraeme 
    171  1.24  xtraeme 	/*
    172  1.24  xtraeme 	 * Critical condition operation requested by userland.
    173  1.24  xtraeme 	 */
    174  1.24  xtraeme 	if (objkey && critval && critvalup) {
    175  1.24  xtraeme 		obj = prop_dictionary_get(sdict, objkey);
    176  1.36  xtraeme 		if (obj) {
    177  1.24  xtraeme 			/*
    178  1.24  xtraeme 			 * object is already in dictionary and value
    179  1.24  xtraeme 			 * provided is not the same than we have
    180  1.24  xtraeme 			 * currently,  update the critical value.
    181  1.24  xtraeme 			 */
    182  1.24  xtraeme 			see->critval = critval;
    183  1.24  xtraeme 			DPRINTF(("%s: sensor=%s type=%d (critval updated)\n",
    184  1.24  xtraeme 				 __func__, edata->desc, see->type));
    185  1.24  xtraeme 			error = sme_sensor_upint32(sdict, objkey, critval);
    186  1.31  xtraeme 			mutex_exit(&sme_mtx);
    187  1.24  xtraeme 			return error;
    188   1.1  xtraeme 		}
    189   1.1  xtraeme 	}
    190   1.1  xtraeme 
    191  1.24  xtraeme 	/*
    192  1.24  xtraeme 	 * The event is not in on the list or in a dictionary, create a new
    193  1.24  xtraeme 	 * sme event, assign required members and update the object in
    194  1.24  xtraeme 	 * the dictionary.
    195  1.24  xtraeme 	 */
    196  1.24  xtraeme 	see = NULL;
    197  1.24  xtraeme 	see = kmem_zalloc(sizeof(*see), KM_NOSLEEP);
    198  1.24  xtraeme 	if (see == NULL) {
    199  1.31  xtraeme 		mutex_exit(&sme_mtx);
    200  1.24  xtraeme 		return ENOMEM;
    201  1.24  xtraeme 	}
    202  1.24  xtraeme 
    203  1.24  xtraeme 	see->critval = critval;
    204  1.24  xtraeme 	see->type = crittype;
    205  1.24  xtraeme 	(void)strlcpy(see->pes.pes_dvname, drvn,
    206  1.24  xtraeme 	    sizeof(see->pes.pes_dvname));
    207  1.24  xtraeme 	see->pes.pes_type = powertype;
    208  1.24  xtraeme 	(void)strlcpy(see->pes.pes_sensname, edata->desc,
    209  1.24  xtraeme 	    sizeof(see->pes.pes_sensname));
    210  1.24  xtraeme 	see->snum = edata->sensor;
    211  1.24  xtraeme 
    212  1.27  xtraeme 	LIST_INSERT_HEAD(&sme_events_list, see, see_list);
    213  1.27  xtraeme 	if (objkey && critval) {
    214  1.27  xtraeme 		error = sme_sensor_upint32(sdict, objkey, critval);
    215  1.27  xtraeme 		if (error) {
    216  1.31  xtraeme 			mutex_exit(&sme_mtx);
    217  1.27  xtraeme 			goto out;
    218  1.27  xtraeme 		}
    219  1.27  xtraeme 	}
    220  1.24  xtraeme 	DPRINTF(("%s: registering dev=%s sensor=%s snum=%d type=%d "
    221   1.1  xtraeme 	    "critval=%" PRIu32 "\n", __func__,
    222   1.1  xtraeme 	    see->pes.pes_dvname, see->pes.pes_sensname,
    223   1.1  xtraeme 	    see->snum, see->type, see->critval));
    224   1.1  xtraeme 	/*
    225   1.1  xtraeme 	 * Initialize the events framework if it wasn't initialized
    226   1.1  xtraeme 	 * before.
    227   1.1  xtraeme 	 */
    228   1.1  xtraeme 	mutex_enter(&sme_event_init_mtx);
    229  1.31  xtraeme 	mutex_exit(&sme_mtx);
    230   1.1  xtraeme 	if (sme_events_initialized == false)
    231   1.1  xtraeme 		error = sme_events_init();
    232   1.1  xtraeme 	mutex_exit(&sme_event_init_mtx);
    233  1.27  xtraeme out:
    234  1.24  xtraeme 	if (error)
    235  1.24  xtraeme 		kmem_free(see, sizeof(*see));
    236   1.1  xtraeme 	return error;
    237   1.1  xtraeme }
    238   1.1  xtraeme 
    239   1.1  xtraeme /*
    240  1.18  xtraeme  * sme_event_unregister_all:
    241  1.18  xtraeme  *
    242  1.18  xtraeme  * 	+ Unregisters all sysmon envsys events associated with a
    243  1.18  xtraeme  * 	  sysmon envsys device.
    244  1.18  xtraeme  */
    245  1.18  xtraeme void
    246  1.25  xtraeme sme_event_unregister_all(const char *sme_name)
    247  1.18  xtraeme {
    248  1.18  xtraeme 	sme_event_t *see;
    249  1.18  xtraeme 	int evcounter = 0;
    250  1.18  xtraeme 
    251  1.31  xtraeme 	KASSERT(mutex_owned(&sme_mtx));
    252  1.25  xtraeme 	KASSERT(sme_name != NULL);
    253  1.18  xtraeme 
    254  1.18  xtraeme 	LIST_FOREACH(see, &sme_events_list, see_list) {
    255  1.25  xtraeme 		if (strcmp(see->pes.pes_dvname, sme_name) == 0)
    256  1.18  xtraeme 			evcounter++;
    257  1.18  xtraeme 	}
    258  1.18  xtraeme 
    259  1.18  xtraeme 	DPRINTF(("%s: total events %d (%s)\n", __func__,
    260  1.25  xtraeme 	    evcounter, sme_name));
    261  1.18  xtraeme 
    262  1.36  xtraeme 	while ((see = LIST_FIRST(&sme_events_list))) {
    263  1.18  xtraeme 		if (evcounter == 0)
    264  1.18  xtraeme 			break;
    265  1.18  xtraeme 
    266  1.25  xtraeme 		if (strcmp(see->pes.pes_dvname, sme_name) == 0) {
    267  1.18  xtraeme 			DPRINTF(("%s: event %s %d removed (%s)\n", __func__,
    268  1.25  xtraeme 			    see->pes.pes_sensname, see->type, sme_name));
    269  1.18  xtraeme 
    270  1.18  xtraeme 			while (see->see_flags & SME_EVENT_WORKING)
    271  1.33  xtraeme 				cv_wait(&sme_cv, &sme_mtx);
    272  1.18  xtraeme 
    273  1.18  xtraeme 			LIST_REMOVE(see, see_list);
    274  1.18  xtraeme 			kmem_free(see, sizeof(*see));
    275  1.18  xtraeme 			evcounter--;
    276  1.18  xtraeme 		}
    277  1.18  xtraeme 	}
    278  1.18  xtraeme 
    279  1.20  xtraeme 	if (LIST_EMPTY(&sme_events_list)) {
    280  1.21  xtraeme 		mutex_enter(&sme_event_init_mtx);
    281  1.29  xtraeme 		if (sme_events_initialized)
    282  1.29  xtraeme 			sme_events_destroy();
    283  1.21  xtraeme 		mutex_exit(&sme_event_init_mtx);
    284  1.20  xtraeme 	}
    285  1.18  xtraeme }
    286  1.18  xtraeme 
    287  1.18  xtraeme /*
    288   1.1  xtraeme  * sme_event_unregister:
    289   1.1  xtraeme  *
    290   1.1  xtraeme  * 	+ Unregisters a sysmon envsys event.
    291   1.1  xtraeme  */
    292   1.1  xtraeme int
    293   1.1  xtraeme sme_event_unregister(const char *sensor, int type)
    294   1.1  xtraeme {
    295   1.1  xtraeme 	sme_event_t *see;
    296   1.1  xtraeme 	bool found = false;
    297   1.1  xtraeme 
    298  1.36  xtraeme 	KASSERT(mutex_owned(&sme_mtx));
    299   1.1  xtraeme 	KASSERT(sensor != NULL);
    300   1.1  xtraeme 
    301   1.1  xtraeme 	LIST_FOREACH(see, &sme_events_list, see_list) {
    302   1.1  xtraeme 		if (strcmp(see->pes.pes_sensname, sensor) == 0) {
    303   1.1  xtraeme 			if (see->type == type) {
    304   1.1  xtraeme 				found = true;
    305   1.1  xtraeme 				break;
    306   1.1  xtraeme 			}
    307   1.1  xtraeme 		}
    308   1.1  xtraeme 	}
    309   1.1  xtraeme 
    310  1.36  xtraeme 	if (!found)
    311   1.1  xtraeme 		return EINVAL;
    312   1.1  xtraeme 
    313  1.15  xtraeme 	while (see->see_flags & SME_EVENT_WORKING)
    314  1.33  xtraeme 		cv_wait(&sme_cv, &sme_mtx);
    315  1.15  xtraeme 
    316   1.1  xtraeme 	DPRINTF(("%s: removing dev=%s sensor=%s type=%d\n",
    317   1.1  xtraeme 	    __func__, see->pes.pes_dvname, sensor, type));
    318   1.1  xtraeme 	LIST_REMOVE(see, see_list);
    319   1.1  xtraeme 	/*
    320   1.1  xtraeme 	 * So the events list is empty, we'll do the following:
    321   1.1  xtraeme 	 *
    322   1.9  xtraeme 	 * 	- stop and destroy the callout.
    323   1.1  xtraeme 	 * 	- destroy the workqueue.
    324   1.1  xtraeme 	 */
    325  1.20  xtraeme 	if (LIST_EMPTY(&sme_events_list)) {
    326  1.21  xtraeme 		mutex_enter(&sme_event_init_mtx);
    327  1.18  xtraeme 		sme_events_destroy();
    328  1.21  xtraeme 		mutex_exit(&sme_event_init_mtx);
    329  1.20  xtraeme 	}
    330   1.1  xtraeme 
    331  1.20  xtraeme 	kmem_free(see, sizeof(*see));
    332   1.1  xtraeme 	return 0;
    333   1.1  xtraeme }
    334   1.1  xtraeme 
    335   1.1  xtraeme /*
    336   1.1  xtraeme  * sme_event_drvadd:
    337   1.1  xtraeme  *
    338   1.1  xtraeme  * 	+ Adds a new sysmon envsys event for a driver if a sensor
    339   1.1  xtraeme  * 	  has set any accepted monitoring flag.
    340   1.1  xtraeme  */
    341   1.1  xtraeme void
    342   1.1  xtraeme sme_event_drvadd(void *arg)
    343   1.1  xtraeme {
    344   1.1  xtraeme 	sme_event_drv_t *sed_t = arg;
    345   1.2  xtraeme 	int error = 0;
    346   1.1  xtraeme 
    347   1.1  xtraeme 	KASSERT(sed_t != NULL);
    348   1.1  xtraeme 
    349   1.1  xtraeme #define SEE_REGEVENT(a, b, c)						\
    350   1.1  xtraeme do {									\
    351   1.1  xtraeme 	if (sed_t->edata->flags & (a)) {				\
    352  1.36  xtraeme 		char str[ENVSYS_DESCLEN] = "monitoring-state-";		\
    353   1.1  xtraeme 									\
    354  1.24  xtraeme 		error = sme_event_register(sed_t->sdict,		\
    355   1.2  xtraeme 				      sed_t->edata,			\
    356   1.2  xtraeme 				      sed_t->sme->sme_name,		\
    357   1.2  xtraeme 				      NULL,				\
    358   1.2  xtraeme 				      0,				\
    359   1.2  xtraeme 				      (b),				\
    360   1.2  xtraeme 				      sed_t->powertype);		\
    361   1.2  xtraeme 		if (error && error != EEXIST)				\
    362   1.2  xtraeme 			printf("%s: failed to add event! "		\
    363   1.2  xtraeme 			    "error=%d sensor=%s event=%s\n",		\
    364   1.2  xtraeme 			    __func__, error, sed_t->edata->desc, (c));	\
    365   1.2  xtraeme 		else {							\
    366   1.2  xtraeme 			(void)strlcat(str, (c), sizeof(str));		\
    367   1.2  xtraeme 			prop_dictionary_set_bool(sed_t->sdict,		\
    368   1.2  xtraeme 						 str,			\
    369   1.2  xtraeme 						 true);			\
    370   1.2  xtraeme 		}							\
    371   1.1  xtraeme 	}								\
    372   1.1  xtraeme } while (/* CONSTCOND */ 0)
    373   1.1  xtraeme 
    374   1.1  xtraeme 	SEE_REGEVENT(ENVSYS_FMONCRITICAL,
    375   1.1  xtraeme 		     PENVSYS_EVENT_CRITICAL,
    376   1.1  xtraeme 		     "critical");
    377   1.1  xtraeme 
    378   1.1  xtraeme 	SEE_REGEVENT(ENVSYS_FMONCRITUNDER,
    379   1.1  xtraeme 		     PENVSYS_EVENT_CRITUNDER,
    380   1.1  xtraeme 		     "critunder");
    381   1.1  xtraeme 
    382   1.1  xtraeme 	SEE_REGEVENT(ENVSYS_FMONCRITOVER,
    383   1.1  xtraeme 		     PENVSYS_EVENT_CRITOVER,
    384   1.1  xtraeme 		     "critover");
    385   1.1  xtraeme 
    386   1.1  xtraeme 	SEE_REGEVENT(ENVSYS_FMONWARNUNDER,
    387   1.1  xtraeme 		     PENVSYS_EVENT_WARNUNDER,
    388   1.1  xtraeme 		     "warnunder");
    389   1.1  xtraeme 
    390   1.1  xtraeme 	SEE_REGEVENT(ENVSYS_FMONWARNOVER,
    391   1.1  xtraeme 		     PENVSYS_EVENT_WARNOVER,
    392   1.1  xtraeme 		     "warnover");
    393   1.1  xtraeme 
    394  1.28  xtraeme 	SEE_REGEVENT(ENVSYS_FMONSTCHANGED,
    395  1.28  xtraeme 		     PENVSYS_EVENT_STATE_CHANGED,
    396  1.28  xtraeme 		     "state-changed");
    397   1.1  xtraeme 
    398   1.1  xtraeme 	/* we are done, free memory now */
    399   1.1  xtraeme 	kmem_free(sed_t, sizeof(*sed_t));
    400   1.1  xtraeme }
    401   1.1  xtraeme 
    402   1.1  xtraeme /*
    403   1.1  xtraeme  * sme_events_init:
    404   1.1  xtraeme  *
    405  1.18  xtraeme  * 	+ Initializes the events framework.
    406   1.1  xtraeme  */
    407   1.1  xtraeme int
    408   1.1  xtraeme sme_events_init(void)
    409   1.1  xtraeme {
    410   1.1  xtraeme 	int error;
    411   1.1  xtraeme 
    412  1.22  xtraeme 	KASSERT(mutex_owned(&sme_event_init_mtx));
    413  1.22  xtraeme 
    414   1.1  xtraeme 	error = workqueue_create(&seewq, "envsysev",
    415  1.40  xtraeme 	    sme_events_worker, NULL, PRI_NONE, IPL_SOFTCLOCK, WQ_MPSAFE);
    416   1.1  xtraeme 	if (error)
    417   1.1  xtraeme 		goto out;
    418   1.1  xtraeme 
    419   1.6       ad 	callout_init(&seeco, 0);
    420   1.1  xtraeme 	callout_setfunc(&seeco, sme_events_check, NULL);
    421   1.1  xtraeme 	callout_schedule(&seeco, SME_EVTIMO);
    422   1.1  xtraeme 	sme_events_initialized = true;
    423   1.1  xtraeme 	DPRINTF(("%s: events framework initialized\n", __func__));
    424   1.1  xtraeme 
    425   1.1  xtraeme out:
    426   1.1  xtraeme 	return error;
    427   1.1  xtraeme }
    428   1.1  xtraeme 
    429   1.1  xtraeme /*
    430  1.18  xtraeme  * sme_events_destroy:
    431  1.18  xtraeme  *
    432  1.18  xtraeme  * 	+ Destroys the events framework: the workqueue and the
    433  1.18  xtraeme  * 	  callout are stopped and destroyed because there are not
    434  1.18  xtraeme  * 	  events in the queue.
    435  1.18  xtraeme  */
    436  1.18  xtraeme void
    437  1.18  xtraeme sme_events_destroy(void)
    438  1.18  xtraeme {
    439  1.22  xtraeme 	KASSERT(mutex_owned(&sme_event_init_mtx));
    440  1.22  xtraeme 
    441  1.18  xtraeme 	callout_stop(&seeco);
    442  1.18  xtraeme 	sme_events_initialized = false;
    443  1.18  xtraeme 	DPRINTF(("%s: events framework destroyed\n", __func__));
    444  1.20  xtraeme 	callout_destroy(&seeco);
    445  1.20  xtraeme 	workqueue_destroy(seewq);
    446  1.18  xtraeme }
    447  1.18  xtraeme 
    448  1.18  xtraeme /*
    449   1.1  xtraeme  * sme_events_check:
    450   1.1  xtraeme  *
    451   1.1  xtraeme  * 	+ Runs the work on each sysmon envsys event in our
    452   1.1  xtraeme  * 	  workqueue periodically with callout.
    453   1.1  xtraeme  */
    454   1.1  xtraeme void
    455   1.1  xtraeme sme_events_check(void *arg)
    456   1.1  xtraeme {
    457   1.1  xtraeme 	sme_event_t *see;
    458   1.1  xtraeme 
    459   1.1  xtraeme 	LIST_FOREACH(see, &sme_events_list, see_list) {
    460  1.14  xtraeme 		DPRINTFOBJ(("%s: dev=%s sensor=%s type=%d\n",
    461   1.1  xtraeme 		    __func__,
    462   1.1  xtraeme 		    see->pes.pes_dvname,
    463   1.1  xtraeme 		    see->pes.pes_sensname,
    464   1.1  xtraeme 		    see->type));
    465   1.8    rmind 		workqueue_enqueue(seewq, &see->see_wk, NULL);
    466   1.1  xtraeme 	}
    467  1.42  xtraeme 	/*
    468  1.42  xtraeme 	 * Now that the events list was checked, reset the refresh value.
    469  1.42  xtraeme 	 */
    470  1.42  xtraeme 	LIST_FOREACH(see, &sme_events_list, see_list)
    471  1.43  xtraeme 		see->see_flags &= ~SME_EVENT_REFRESHED;
    472  1.42  xtraeme 
    473  1.38  xtraeme 	if (!sysmon_low_power)
    474  1.38  xtraeme 		callout_schedule(&seeco, SME_EVTIMO);
    475   1.1  xtraeme }
    476   1.1  xtraeme 
    477   1.1  xtraeme /*
    478   1.1  xtraeme  * sme_events_worker:
    479   1.1  xtraeme  *
    480   1.1  xtraeme  * 	+ workqueue thread that checks if there's a critical condition
    481   1.1  xtraeme  * 	  and sends an event if the condition was triggered.
    482   1.1  xtraeme  */
    483   1.1  xtraeme void
    484   1.1  xtraeme sme_events_worker(struct work *wk, void *arg)
    485   1.1  xtraeme {
    486  1.28  xtraeme 	const struct sme_description_table *sdt = NULL;
    487  1.10  xtraeme 	const struct sme_sensor_event *sse = sme_sensor_event;
    488   1.1  xtraeme 	sme_event_t *see = (void *)wk;
    489   1.1  xtraeme 	struct sysmon_envsys *sme;
    490   1.1  xtraeme 	envsys_data_t *edata;
    491  1.28  xtraeme 	int i, state, error;
    492   1.1  xtraeme 
    493   1.1  xtraeme 	KASSERT(wk == &see->see_wk);
    494   1.1  xtraeme 
    495  1.28  xtraeme 	state = error = 0;
    496  1.28  xtraeme 
    497  1.31  xtraeme 	mutex_enter(&sme_mtx);
    498  1.15  xtraeme 	see->see_flags |= SME_EVENT_WORKING;
    499  1.15  xtraeme 
    500   1.1  xtraeme 	/*
    501   1.1  xtraeme 	 * We have to find the sme device by looking
    502   1.1  xtraeme 	 * at the power envsys device name.
    503   1.1  xtraeme 	 */
    504   1.1  xtraeme 	LIST_FOREACH(sme, &sysmon_envsys_list, sme_list)
    505   1.1  xtraeme 		if (strcmp(sme->sme_name, see->pes.pes_dvname) == 0)
    506   1.1  xtraeme 			break;
    507  1.36  xtraeme 	if (!sme)
    508  1.30  xtraeme 		goto out;
    509   1.1  xtraeme 
    510  1.13  xtraeme 	/* get the sensor with the index specified in see->snum */
    511  1.13  xtraeme 	edata = &sme->sme_sensor_data[see->snum];
    512   1.1  xtraeme 
    513   1.1  xtraeme 	/*
    514  1.42  xtraeme 	 * refresh the sensor that was marked with a critical event
    515  1.42  xtraeme 	 * only if it wasn't refreshed before or if the driver doesn't
    516  1.42  xtraeme 	 * use its own method for refreshing.
    517   1.1  xtraeme 	 */
    518   1.1  xtraeme 	if ((sme->sme_flags & SME_DISABLE_GTREDATA) == 0) {
    519  1.43  xtraeme 		if ((see->see_flags & SME_EVENT_REFRESHED) == 0) {
    520  1.42  xtraeme 			error = (*sme->sme_gtredata)(sme, edata);
    521  1.42  xtraeme 			if (error)
    522  1.42  xtraeme 				goto out;
    523  1.43  xtraeme 			see->see_flags |= SME_EVENT_REFRESHED;
    524  1.42  xtraeme 		}
    525   1.1  xtraeme 	}
    526   1.1  xtraeme 
    527  1.18  xtraeme 	DPRINTFOBJ(("%s: desc=%s sensor=%d units=%d value_cur=%d\n",
    528   1.1  xtraeme 	    __func__, edata->desc, edata->sensor,
    529   1.1  xtraeme 	    edata->units, edata->value_cur));
    530   1.1  xtraeme 
    531  1.10  xtraeme #define SME_SEND_NORMALEVENT()						\
    532  1.10  xtraeme do {									\
    533  1.10  xtraeme 	see->evsent = false;						\
    534  1.10  xtraeme 	sysmon_penvsys_event(&see->pes, PENVSYS_EVENT_NORMAL);		\
    535  1.10  xtraeme } while (/* CONSTCOND */ 0)
    536  1.10  xtraeme 
    537  1.10  xtraeme #define SME_SEND_EVENT(type)						\
    538   1.1  xtraeme do {									\
    539  1.10  xtraeme 	see->evsent = true;						\
    540  1.10  xtraeme 	sysmon_penvsys_event(&see->pes, (type));			\
    541   1.1  xtraeme } while (/* CONSTCOND */ 0)
    542   1.1  xtraeme 
    543  1.38  xtraeme 
    544   1.1  xtraeme 	switch (see->type) {
    545  1.10  xtraeme 	/*
    546  1.10  xtraeme 	 * if state is the same than the one that matches sse[i].state,
    547  1.10  xtraeme 	 * send the event...
    548  1.10  xtraeme 	 */
    549   1.1  xtraeme 	case PENVSYS_EVENT_CRITICAL:
    550   1.1  xtraeme 	case PENVSYS_EVENT_CRITUNDER:
    551   1.1  xtraeme 	case PENVSYS_EVENT_CRITOVER:
    552  1.10  xtraeme 	case PENVSYS_EVENT_WARNUNDER:
    553  1.10  xtraeme 	case PENVSYS_EVENT_WARNOVER:
    554  1.10  xtraeme 		for (i = 0; sse[i].state != -1; i++)
    555  1.10  xtraeme 			if (sse[i].event == see->type)
    556  1.10  xtraeme 				break;
    557   1.1  xtraeme 
    558  1.10  xtraeme 		if (see->evsent && edata->state == ENVSYS_SVALID)
    559  1.10  xtraeme 			SME_SEND_NORMALEVENT();
    560   1.1  xtraeme 
    561  1.10  xtraeme 		if (!see->evsent && edata->state == sse[i].state)
    562  1.10  xtraeme 			SME_SEND_EVENT(see->type);
    563   1.1  xtraeme 
    564   1.1  xtraeme 		break;
    565  1.10  xtraeme 	/*
    566  1.10  xtraeme 	 * if value_cur is lower than the limit, send the event...
    567  1.10  xtraeme 	 */
    568   1.1  xtraeme 	case PENVSYS_EVENT_BATT_USERCAP:
    569  1.10  xtraeme 	case PENVSYS_EVENT_USER_CRITMIN:
    570  1.10  xtraeme 		if (see->evsent && edata->value_cur > see->critval)
    571  1.10  xtraeme 			SME_SEND_NORMALEVENT();
    572   1.1  xtraeme 
    573  1.10  xtraeme 		if (!see->evsent && edata->value_cur < see->critval)
    574  1.10  xtraeme 			SME_SEND_EVENT(see->type);
    575   1.1  xtraeme 
    576   1.1  xtraeme 		break;
    577  1.10  xtraeme 	/*
    578  1.10  xtraeme 	 * if value_cur is higher than the limit, send the event...
    579  1.10  xtraeme 	 */
    580   1.1  xtraeme 	case PENVSYS_EVENT_USER_CRITMAX:
    581  1.10  xtraeme 		if (see->evsent && edata->value_cur < see->critval)
    582  1.10  xtraeme 			SME_SEND_NORMALEVENT();
    583   1.1  xtraeme 
    584  1.10  xtraeme 		if (!see->evsent && edata->value_cur > see->critval)
    585  1.10  xtraeme 			SME_SEND_EVENT(see->type);
    586   1.1  xtraeme 
    587   1.1  xtraeme 		break;
    588  1.10  xtraeme 	/*
    589  1.28  xtraeme 	 * if value_cur is not normal (battery) or online (drive),
    590  1.28  xtraeme 	 * send the event...
    591  1.10  xtraeme 	 */
    592  1.28  xtraeme 	case PENVSYS_EVENT_STATE_CHANGED:
    593   1.1  xtraeme 		/* the state has not been changed, just ignore the event */
    594   1.1  xtraeme 		if (edata->value_cur == see->evsent)
    595   1.1  xtraeme 			break;
    596   1.1  xtraeme 
    597  1.28  xtraeme 		switch (edata->units) {
    598  1.28  xtraeme 		case ENVSYS_DRIVE:
    599  1.28  xtraeme 			sdt = sme_get_description_table(SME_DESC_DRIVE_STATES);
    600  1.28  xtraeme 			state = ENVSYS_DRIVE_ONLINE;
    601  1.28  xtraeme 			break;
    602  1.44  xtraeme 		case ENVSYS_BATTERY_CAPACITY:
    603  1.28  xtraeme 			sdt =
    604  1.44  xtraeme 			    sme_get_description_table(SME_DESC_BATTERY_CAPACITY);
    605  1.44  xtraeme 			state = ENVSYS_BATTERY_CAPACITY_NORMAL;
    606  1.28  xtraeme 			break;
    607  1.34  xtraeme 		default:
    608  1.35  xtraeme 			panic("%s: invalid units for ENVSYS_FMONSTCHANGED",
    609  1.35  xtraeme 			    __func__);
    610  1.28  xtraeme 		}
    611  1.28  xtraeme 
    612  1.28  xtraeme 		for (i = 0; sdt[i].type != -1; i++)
    613  1.28  xtraeme 			if (sdt[i].type == edata->value_cur)
    614   1.1  xtraeme 				break;
    615   1.1  xtraeme 
    616   1.1  xtraeme 		/* copy current state description  */
    617  1.28  xtraeme 		(void)strlcpy(see->pes.pes_statedesc, sdt[i].desc,
    618   1.1  xtraeme 		    sizeof(see->pes.pes_statedesc));
    619   1.1  xtraeme 
    620   1.1  xtraeme 		/* state is ok again... send a normal event */
    621  1.28  xtraeme 		if (see->evsent && edata->value_cur == state)
    622  1.10  xtraeme 			SME_SEND_NORMALEVENT();
    623   1.1  xtraeme 
    624  1.28  xtraeme 		/* state has been changed... send event */
    625  1.28  xtraeme 		if (see->evsent || edata->value_cur != state) {
    626   1.1  xtraeme 			/* save current drive state */
    627   1.1  xtraeme 			see->evsent = edata->value_cur;
    628  1.10  xtraeme 			sysmon_penvsys_event(&see->pes, see->type);
    629   1.1  xtraeme 		}
    630   1.1  xtraeme 
    631  1.39  xtraeme 		/*
    632  1.39  xtraeme 		 * Check if the system is running in low power and send the
    633  1.39  xtraeme 		 * event to powerd (if running) or shutdown the system
    634  1.39  xtraeme 		 * otherwise.
    635  1.39  xtraeme 		 */
    636  1.39  xtraeme 		if (!sysmon_low_power && sme_event_check_low_power()) {
    637  1.39  xtraeme 			struct penvsys_state pes;
    638  1.39  xtraeme 
    639  1.39  xtraeme 			pes.pes_type = PENVSYS_TYPE_BATTERY;
    640  1.39  xtraeme 			sysmon_penvsys_event(&pes, PENVSYS_EVENT_LOW_POWER);
    641  1.39  xtraeme 			sysmon_low_power = true;
    642  1.39  xtraeme 			callout_stop(&seeco);
    643  1.39  xtraeme 		}
    644  1.39  xtraeme 
    645   1.1  xtraeme 		break;
    646   1.1  xtraeme 	}
    647  1.30  xtraeme out:
    648  1.15  xtraeme 	see->see_flags &= ~SME_EVENT_WORKING;
    649  1.33  xtraeme 	cv_broadcast(&sme_cv);
    650  1.31  xtraeme 	mutex_exit(&sme_mtx);
    651   1.1  xtraeme }
    652  1.38  xtraeme 
    653  1.44  xtraeme static bool
    654  1.38  xtraeme sme_event_check_low_power(void)
    655  1.38  xtraeme {
    656  1.38  xtraeme 	struct sysmon_envsys *sme;
    657  1.38  xtraeme 	envsys_data_t *edata;
    658  1.44  xtraeme 	int i;
    659  1.44  xtraeme 	bool battery, batterycap, batterycharge;
    660  1.38  xtraeme 
    661  1.44  xtraeme 	KASSERT(mutex_owned(&sme_mtx));
    662  1.38  xtraeme 
    663  1.44  xtraeme 	battery = batterycap = batterycharge = false;
    664  1.38  xtraeme 
    665  1.38  xtraeme 	LIST_FOREACH(sme, &sysmon_envsys_list, sme_list)
    666  1.38  xtraeme 		if (sme->sme_class == SME_CLASS_ACADAPTER)
    667  1.38  xtraeme 			break;
    668  1.38  xtraeme 
    669  1.38  xtraeme 	/*
    670  1.38  xtraeme 	 * No AC Adapter devices were found, do nothing.
    671  1.38  xtraeme 	 */
    672  1.38  xtraeme 	if (!sme)
    673  1.44  xtraeme 		return false;
    674  1.38  xtraeme 
    675  1.44  xtraeme 	/*
    676  1.44  xtraeme 	 * If there's an AC Adapter connected, there's no need
    677  1.44  xtraeme 	 * to continue...
    678  1.44  xtraeme 	 */
    679  1.38  xtraeme 	for (i = 0; i < sme->sme_nsensors; i++) {
    680  1.38  xtraeme 		edata = &sme->sme_sensor_data[i];
    681  1.38  xtraeme 		if (edata->units == ENVSYS_INDICATOR) {
    682  1.44  xtraeme 			if (edata->value_cur)
    683  1.44  xtraeme 				return false;
    684  1.38  xtraeme 		}
    685  1.38  xtraeme 	}
    686  1.44  xtraeme 
    687  1.38  xtraeme 	/*
    688  1.44  xtraeme 	 * Check for battery devices and its state.
    689  1.38  xtraeme 	 */
    690  1.44  xtraeme 	LIST_FOREACH(sme, &sysmon_envsys_list, sme_list) {
    691  1.44  xtraeme 		if (sme->sme_class != SME_CLASS_BATTERY)
    692  1.44  xtraeme 			continue;
    693  1.38  xtraeme 
    694  1.44  xtraeme 		/*
    695  1.44  xtraeme 		 * We've found a battery device...
    696  1.44  xtraeme 		 */
    697  1.44  xtraeme 		battery = true;
    698  1.44  xtraeme 		for (i = 0; i < sme->sme_nsensors; i++) {
    699  1.44  xtraeme 			edata = &sme->sme_sensor_data[i];
    700  1.44  xtraeme 			if (edata->units == ENVSYS_BATTERY_CAPACITY) {
    701  1.44  xtraeme 				batterycap = true;
    702  1.44  xtraeme 				if (!sme_battery_critical(edata))
    703  1.44  xtraeme 					return false;
    704  1.44  xtraeme 			} else if (edata->units == ENVSYS_BATTERY_CHARGE) {
    705  1.44  xtraeme 				batterycharge = true;
    706  1.44  xtraeme 				if (edata->value_cur)
    707  1.44  xtraeme 					return false;
    708  1.38  xtraeme 			}
    709  1.38  xtraeme 		}
    710  1.38  xtraeme 	}
    711  1.44  xtraeme 	if (!battery || !batterycap || !batterycharge)
    712  1.44  xtraeme 		return false;
    713  1.38  xtraeme 
    714  1.38  xtraeme 	/*
    715  1.44  xtraeme 	 * All batteries in low/critical capacity and discharging.
    716  1.38  xtraeme 	 */
    717  1.44  xtraeme 	return true;
    718  1.44  xtraeme }
    719  1.38  xtraeme 
    720  1.44  xtraeme static bool
    721  1.44  xtraeme sme_battery_critical(envsys_data_t *edata)
    722  1.44  xtraeme {
    723  1.44  xtraeme 	if (edata->value_cur == ENVSYS_BATTERY_CAPACITY_CRITICAL ||
    724  1.44  xtraeme 	    edata->value_cur == ENVSYS_BATTERY_CAPACITY_LOW)
    725  1.44  xtraeme 		return true;
    726  1.44  xtraeme 
    727  1.44  xtraeme 	return false;
    728  1.38  xtraeme }
    729