Home | History | Annotate | Line # | Download | only in sysmon
sysmon_envsys_events.c revision 1.36
      1  1.36  xtraeme /* $NetBSD: sysmon_envsys_events.c,v 1.36 2007/10/07 04:11:15 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.36  xtraeme __KERNEL_RCSID(0, "$NetBSD: sysmon_envsys_events.c,v 1.36 2007/10/07 04:11:15 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.31  xtraeme kmutex_t sme_mtx, sme_event_init_mtx;
     70  1.33  xtraeme kcondvar_t sme_cv;
     71   1.1  xtraeme 
     72   1.3  xtraeme /* 10 seconds of timeout for the callout */
     73   1.3  xtraeme static int sme_events_timeout = 10;
     74   1.3  xtraeme static int sme_events_timeout_sysctl(SYSCTLFN_PROTO);
     75   1.3  xtraeme #define SME_EVTIMO 	(sme_events_timeout * hz)
     76   1.3  xtraeme 
     77   1.3  xtraeme /*
     78   1.3  xtraeme  * sysctl(9) stuff to handle the refresh value in the callout
     79   1.3  xtraeme  * function.
     80   1.3  xtraeme  */
     81   1.3  xtraeme static int
     82   1.3  xtraeme sme_events_timeout_sysctl(SYSCTLFN_ARGS)
     83   1.3  xtraeme {
     84   1.3  xtraeme 	struct sysctlnode node;
     85   1.3  xtraeme 	int timo, error;
     86   1.3  xtraeme 
     87   1.3  xtraeme 	node = *rnode;
     88   1.3  xtraeme 	timo = sme_events_timeout;
     89   1.3  xtraeme 	node.sysctl_data = &timo;
     90   1.3  xtraeme 
     91   1.3  xtraeme 	error = sysctl_lookup(SYSCTLFN_CALL(&node));
     92  1.36  xtraeme 	if (error || !newp)
     93   1.3  xtraeme 		return error;
     94   1.3  xtraeme 
     95   1.5  xtraeme 	/* min 1s */
     96   1.5  xtraeme 	if (timo < 1)
     97   1.3  xtraeme 		return EINVAL;
     98   1.3  xtraeme 
     99   1.3  xtraeme 	sme_events_timeout = timo;
    100   1.3  xtraeme 	return 0;
    101   1.3  xtraeme }
    102   1.3  xtraeme 
    103   1.3  xtraeme SYSCTL_SETUP(sysctl_kern_envsys_timeout_setup, "sysctl kern.envsys subtree")
    104   1.3  xtraeme {
    105   1.3  xtraeme 	const struct sysctlnode *node, *envsys_node;
    106   1.3  xtraeme 
    107   1.3  xtraeme 	sysctl_createv(clog, 0, NULL, &node,
    108   1.3  xtraeme 			CTLFLAG_PERMANENT,
    109   1.3  xtraeme 			CTLTYPE_NODE, "kern", NULL,
    110   1.3  xtraeme 			NULL, 0, NULL, 0,
    111   1.3  xtraeme 			CTL_KERN, CTL_EOL);
    112   1.3  xtraeme 
    113   1.3  xtraeme 	sysctl_createv(clog, 0, &node, &envsys_node,
    114   1.3  xtraeme 			0,
    115   1.3  xtraeme 			CTLTYPE_NODE, "envsys", NULL,
    116   1.3  xtraeme 			NULL, 0, NULL, 0,
    117   1.3  xtraeme 			CTL_CREATE, CTL_EOL);
    118   1.3  xtraeme 
    119   1.3  xtraeme 	sysctl_createv(clog, 0, &envsys_node, &node,
    120   1.3  xtraeme 			CTLFLAG_READWRITE,
    121   1.3  xtraeme 			CTLTYPE_INT, "refresh_value",
    122   1.3  xtraeme 			SYSCTL_DESCR("wait time in seconds to refresh "
    123   1.3  xtraeme 			    "sensors being monitored"),
    124   1.3  xtraeme 			sme_events_timeout_sysctl, 0, &sme_events_timeout, 0,
    125   1.3  xtraeme 			CTL_CREATE, CTL_EOL);
    126   1.3  xtraeme }
    127   1.3  xtraeme 
    128   1.1  xtraeme /*
    129   1.1  xtraeme  * sme_event_register:
    130   1.1  xtraeme  *
    131  1.24  xtraeme  * 	+ Registers a new sysmon envsys event or updates any event
    132  1.24  xtraeme  * 	  already in the queue.
    133   1.1  xtraeme  */
    134   1.1  xtraeme int
    135  1.24  xtraeme sme_event_register(prop_dictionary_t sdict, envsys_data_t *edata,
    136  1.24  xtraeme 		   const char *drvn, const char *objkey,
    137  1.24  xtraeme 		   int32_t critval, int crittype, int powertype)
    138   1.1  xtraeme {
    139  1.24  xtraeme 	sme_event_t *see = NULL;
    140  1.24  xtraeme 	prop_object_t obj;
    141  1.24  xtraeme 	bool critvalup = false;
    142   1.1  xtraeme 	int error = 0;
    143   1.1  xtraeme 
    144  1.24  xtraeme 	KASSERT(sdict != NULL || edata != NULL);
    145   1.1  xtraeme 
    146  1.31  xtraeme 	mutex_enter(&sme_mtx);
    147   1.1  xtraeme 	/*
    148  1.24  xtraeme 	 * check if the event is already on the list and return
    149  1.24  xtraeme 	 * EEXIST if value provided hasn't been changed.
    150   1.1  xtraeme 	 */
    151  1.24  xtraeme 	LIST_FOREACH(see, &sme_events_list, see_list) {
    152  1.24  xtraeme 		if (strcmp(edata->desc, see->pes.pes_sensname) == 0)
    153  1.24  xtraeme 			if (crittype == see->type) {
    154  1.24  xtraeme 				if (see->critval == critval) {
    155  1.24  xtraeme 					DPRINTF(("%s: dev=%s sensor=%s type=%d "
    156  1.24  xtraeme 				    	    "(already exists)\n", __func__,
    157  1.24  xtraeme 				    	    see->pes.pes_dvname,
    158  1.24  xtraeme 				    	    see->pes.pes_sensname, see->type));
    159  1.31  xtraeme 					mutex_exit(&sme_mtx);
    160  1.24  xtraeme 					return EEXIST;
    161  1.24  xtraeme 				}
    162  1.24  xtraeme 				critvalup = true;
    163  1.24  xtraeme 				break;
    164   1.1  xtraeme 			}
    165  1.24  xtraeme 	}
    166  1.24  xtraeme 
    167  1.24  xtraeme 	/*
    168  1.24  xtraeme 	 * Critical condition operation requested by userland.
    169  1.24  xtraeme 	 */
    170  1.24  xtraeme 	if (objkey && critval && critvalup) {
    171  1.24  xtraeme 		obj = prop_dictionary_get(sdict, objkey);
    172  1.36  xtraeme 		if (obj) {
    173  1.24  xtraeme 			/*
    174  1.24  xtraeme 			 * object is already in dictionary and value
    175  1.24  xtraeme 			 * provided is not the same than we have
    176  1.24  xtraeme 			 * currently,  update the critical value.
    177  1.24  xtraeme 			 */
    178  1.24  xtraeme 			see->critval = critval;
    179  1.24  xtraeme 			DPRINTF(("%s: sensor=%s type=%d (critval updated)\n",
    180  1.24  xtraeme 				 __func__, edata->desc, see->type));
    181  1.24  xtraeme 			error = sme_sensor_upint32(sdict, objkey, critval);
    182  1.31  xtraeme 			mutex_exit(&sme_mtx);
    183  1.24  xtraeme 			return error;
    184   1.1  xtraeme 		}
    185   1.1  xtraeme 	}
    186   1.1  xtraeme 
    187  1.24  xtraeme 	/*
    188  1.24  xtraeme 	 * The event is not in on the list or in a dictionary, create a new
    189  1.24  xtraeme 	 * sme event, assign required members and update the object in
    190  1.24  xtraeme 	 * the dictionary.
    191  1.24  xtraeme 	 */
    192  1.24  xtraeme 	see = NULL;
    193  1.24  xtraeme 	see = kmem_zalloc(sizeof(*see), KM_NOSLEEP);
    194  1.24  xtraeme 	if (see == NULL) {
    195  1.31  xtraeme 		mutex_exit(&sme_mtx);
    196  1.24  xtraeme 		return ENOMEM;
    197  1.24  xtraeme 	}
    198  1.24  xtraeme 
    199  1.24  xtraeme 	see->critval = critval;
    200  1.24  xtraeme 	see->type = crittype;
    201  1.24  xtraeme 	(void)strlcpy(see->pes.pes_dvname, drvn,
    202  1.24  xtraeme 	    sizeof(see->pes.pes_dvname));
    203  1.24  xtraeme 	see->pes.pes_type = powertype;
    204  1.24  xtraeme 	(void)strlcpy(see->pes.pes_sensname, edata->desc,
    205  1.24  xtraeme 	    sizeof(see->pes.pes_sensname));
    206  1.24  xtraeme 	see->snum = edata->sensor;
    207  1.24  xtraeme 
    208  1.27  xtraeme 	LIST_INSERT_HEAD(&sme_events_list, see, see_list);
    209  1.27  xtraeme 	if (objkey && critval) {
    210  1.27  xtraeme 		error = sme_sensor_upint32(sdict, objkey, critval);
    211  1.27  xtraeme 		if (error) {
    212  1.31  xtraeme 			mutex_exit(&sme_mtx);
    213  1.27  xtraeme 			goto out;
    214  1.27  xtraeme 		}
    215  1.27  xtraeme 	}
    216  1.24  xtraeme 	DPRINTF(("%s: registering dev=%s sensor=%s snum=%d type=%d "
    217   1.1  xtraeme 	    "critval=%" PRIu32 "\n", __func__,
    218   1.1  xtraeme 	    see->pes.pes_dvname, see->pes.pes_sensname,
    219   1.1  xtraeme 	    see->snum, see->type, see->critval));
    220   1.1  xtraeme 	/*
    221   1.1  xtraeme 	 * Initialize the events framework if it wasn't initialized
    222   1.1  xtraeme 	 * before.
    223   1.1  xtraeme 	 */
    224   1.1  xtraeme 	mutex_enter(&sme_event_init_mtx);
    225  1.31  xtraeme 	mutex_exit(&sme_mtx);
    226   1.1  xtraeme 	if (sme_events_initialized == false)
    227   1.1  xtraeme 		error = sme_events_init();
    228   1.1  xtraeme 	mutex_exit(&sme_event_init_mtx);
    229  1.27  xtraeme out:
    230  1.24  xtraeme 	if (error)
    231  1.24  xtraeme 		kmem_free(see, sizeof(*see));
    232   1.1  xtraeme 	return error;
    233   1.1  xtraeme }
    234   1.1  xtraeme 
    235   1.1  xtraeme /*
    236  1.18  xtraeme  * sme_event_unregister_all:
    237  1.18  xtraeme  *
    238  1.18  xtraeme  * 	+ Unregisters all sysmon envsys events associated with a
    239  1.18  xtraeme  * 	  sysmon envsys device.
    240  1.18  xtraeme  */
    241  1.18  xtraeme void
    242  1.25  xtraeme sme_event_unregister_all(const char *sme_name)
    243  1.18  xtraeme {
    244  1.18  xtraeme 	sme_event_t *see;
    245  1.18  xtraeme 	int evcounter = 0;
    246  1.18  xtraeme 
    247  1.31  xtraeme 	KASSERT(mutex_owned(&sme_mtx));
    248  1.25  xtraeme 	KASSERT(sme_name != NULL);
    249  1.18  xtraeme 
    250  1.18  xtraeme 	LIST_FOREACH(see, &sme_events_list, see_list) {
    251  1.25  xtraeme 		if (strcmp(see->pes.pes_dvname, sme_name) == 0)
    252  1.18  xtraeme 			evcounter++;
    253  1.18  xtraeme 	}
    254  1.18  xtraeme 
    255  1.18  xtraeme 	DPRINTF(("%s: total events %d (%s)\n", __func__,
    256  1.25  xtraeme 	    evcounter, sme_name));
    257  1.18  xtraeme 
    258  1.36  xtraeme 	while ((see = LIST_FIRST(&sme_events_list))) {
    259  1.18  xtraeme 		if (evcounter == 0)
    260  1.18  xtraeme 			break;
    261  1.18  xtraeme 
    262  1.25  xtraeme 		if (strcmp(see->pes.pes_dvname, sme_name) == 0) {
    263  1.18  xtraeme 			DPRINTF(("%s: event %s %d removed (%s)\n", __func__,
    264  1.25  xtraeme 			    see->pes.pes_sensname, see->type, sme_name));
    265  1.18  xtraeme 
    266  1.18  xtraeme 			while (see->see_flags & SME_EVENT_WORKING)
    267  1.33  xtraeme 				cv_wait(&sme_cv, &sme_mtx);
    268  1.18  xtraeme 
    269  1.18  xtraeme 			LIST_REMOVE(see, see_list);
    270  1.18  xtraeme 			kmem_free(see, sizeof(*see));
    271  1.18  xtraeme 			evcounter--;
    272  1.18  xtraeme 		}
    273  1.18  xtraeme 	}
    274  1.18  xtraeme 
    275  1.20  xtraeme 	if (LIST_EMPTY(&sme_events_list)) {
    276  1.21  xtraeme 		mutex_enter(&sme_event_init_mtx);
    277  1.29  xtraeme 		if (sme_events_initialized)
    278  1.29  xtraeme 			sme_events_destroy();
    279  1.21  xtraeme 		mutex_exit(&sme_event_init_mtx);
    280  1.20  xtraeme 	}
    281  1.18  xtraeme }
    282  1.18  xtraeme 
    283  1.18  xtraeme /*
    284   1.1  xtraeme  * sme_event_unregister:
    285   1.1  xtraeme  *
    286   1.1  xtraeme  * 	+ Unregisters a sysmon envsys event.
    287   1.1  xtraeme  */
    288   1.1  xtraeme int
    289   1.1  xtraeme sme_event_unregister(const char *sensor, int type)
    290   1.1  xtraeme {
    291   1.1  xtraeme 	sme_event_t *see;
    292   1.1  xtraeme 	bool found = false;
    293   1.1  xtraeme 
    294  1.36  xtraeme 	KASSERT(mutex_owned(&sme_mtx));
    295   1.1  xtraeme 	KASSERT(sensor != NULL);
    296   1.1  xtraeme 
    297   1.1  xtraeme 	LIST_FOREACH(see, &sme_events_list, see_list) {
    298   1.1  xtraeme 		if (strcmp(see->pes.pes_sensname, sensor) == 0) {
    299   1.1  xtraeme 			if (see->type == type) {
    300   1.1  xtraeme 				found = true;
    301   1.1  xtraeme 				break;
    302   1.1  xtraeme 			}
    303   1.1  xtraeme 		}
    304   1.1  xtraeme 	}
    305   1.1  xtraeme 
    306  1.36  xtraeme 	if (!found)
    307   1.1  xtraeme 		return EINVAL;
    308   1.1  xtraeme 
    309  1.15  xtraeme 	while (see->see_flags & SME_EVENT_WORKING)
    310  1.33  xtraeme 		cv_wait(&sme_cv, &sme_mtx);
    311  1.15  xtraeme 
    312   1.1  xtraeme 	DPRINTF(("%s: removing dev=%s sensor=%s type=%d\n",
    313   1.1  xtraeme 	    __func__, see->pes.pes_dvname, sensor, type));
    314   1.1  xtraeme 	LIST_REMOVE(see, see_list);
    315   1.1  xtraeme 	/*
    316   1.1  xtraeme 	 * So the events list is empty, we'll do the following:
    317   1.1  xtraeme 	 *
    318   1.9  xtraeme 	 * 	- stop and destroy the callout.
    319   1.1  xtraeme 	 * 	- destroy the workqueue.
    320   1.1  xtraeme 	 */
    321  1.20  xtraeme 	if (LIST_EMPTY(&sme_events_list)) {
    322  1.21  xtraeme 		mutex_enter(&sme_event_init_mtx);
    323  1.18  xtraeme 		sme_events_destroy();
    324  1.21  xtraeme 		mutex_exit(&sme_event_init_mtx);
    325  1.20  xtraeme 		goto out;
    326  1.20  xtraeme 	}
    327   1.1  xtraeme 
    328  1.20  xtraeme out:
    329  1.20  xtraeme 	kmem_free(see, sizeof(*see));
    330   1.1  xtraeme 	return 0;
    331   1.1  xtraeme }
    332   1.1  xtraeme 
    333   1.1  xtraeme /*
    334   1.1  xtraeme  * sme_event_drvadd:
    335   1.1  xtraeme  *
    336   1.1  xtraeme  * 	+ Adds a new sysmon envsys event for a driver if a sensor
    337   1.1  xtraeme  * 	  has set any accepted monitoring flag.
    338   1.1  xtraeme  */
    339   1.1  xtraeme void
    340   1.1  xtraeme sme_event_drvadd(void *arg)
    341   1.1  xtraeme {
    342   1.1  xtraeme 	sme_event_drv_t *sed_t = arg;
    343   1.2  xtraeme 	int error = 0;
    344   1.1  xtraeme 
    345   1.1  xtraeme 	KASSERT(sed_t != NULL);
    346   1.1  xtraeme 
    347   1.1  xtraeme #define SEE_REGEVENT(a, b, c)						\
    348   1.1  xtraeme do {									\
    349   1.1  xtraeme 	if (sed_t->edata->flags & (a)) {				\
    350  1.36  xtraeme 		char str[ENVSYS_DESCLEN] = "monitoring-state-";		\
    351   1.1  xtraeme 									\
    352  1.24  xtraeme 		error = sme_event_register(sed_t->sdict,		\
    353   1.2  xtraeme 				      sed_t->edata,			\
    354   1.2  xtraeme 				      sed_t->sme->sme_name,		\
    355   1.2  xtraeme 				      NULL,				\
    356   1.2  xtraeme 				      0,				\
    357   1.2  xtraeme 				      (b),				\
    358   1.2  xtraeme 				      sed_t->powertype);		\
    359   1.2  xtraeme 		if (error && error != EEXIST)				\
    360   1.2  xtraeme 			printf("%s: failed to add event! "		\
    361   1.2  xtraeme 			    "error=%d sensor=%s event=%s\n",		\
    362   1.2  xtraeme 			    __func__, error, sed_t->edata->desc, (c));	\
    363   1.2  xtraeme 		else {							\
    364   1.2  xtraeme 			(void)strlcat(str, (c), sizeof(str));		\
    365  1.31  xtraeme 			mutex_enter(&sme_mtx);			\
    366   1.2  xtraeme 			prop_dictionary_set_bool(sed_t->sdict,		\
    367   1.2  xtraeme 						 str,			\
    368   1.2  xtraeme 						 true);			\
    369  1.31  xtraeme 			mutex_exit(&sme_mtx);			\
    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.20  xtraeme 	    sme_events_worker, NULL, 0, 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.1  xtraeme 	callout_schedule(&seeco, SME_EVTIMO);
    468   1.1  xtraeme }
    469   1.1  xtraeme 
    470   1.1  xtraeme /*
    471   1.1  xtraeme  * sme_events_worker:
    472   1.1  xtraeme  *
    473   1.1  xtraeme  * 	+ workqueue thread that checks if there's a critical condition
    474   1.1  xtraeme  * 	  and sends an event if the condition was triggered.
    475   1.1  xtraeme  */
    476   1.1  xtraeme void
    477   1.1  xtraeme sme_events_worker(struct work *wk, void *arg)
    478   1.1  xtraeme {
    479  1.28  xtraeme 	const struct sme_description_table *sdt = NULL;
    480  1.10  xtraeme 	const struct sme_sensor_event *sse = sme_sensor_event;
    481   1.1  xtraeme 	sme_event_t *see = (void *)wk;
    482   1.1  xtraeme 	struct sysmon_envsys *sme;
    483   1.1  xtraeme 	envsys_data_t *edata;
    484  1.28  xtraeme 	int i, state, error;
    485   1.1  xtraeme 
    486   1.1  xtraeme 	KASSERT(wk == &see->see_wk);
    487   1.1  xtraeme 
    488  1.28  xtraeme 	state = error = 0;
    489  1.28  xtraeme 
    490  1.31  xtraeme 	mutex_enter(&sme_mtx);
    491  1.15  xtraeme 	see->see_flags |= SME_EVENT_WORKING;
    492  1.15  xtraeme 
    493   1.1  xtraeme 	/*
    494   1.1  xtraeme 	 * We have to find the sme device by looking
    495   1.1  xtraeme 	 * at the power envsys device name.
    496   1.1  xtraeme 	 */
    497   1.1  xtraeme 	LIST_FOREACH(sme, &sysmon_envsys_list, sme_list)
    498   1.1  xtraeme 		if (strcmp(sme->sme_name, see->pes.pes_dvname) == 0)
    499   1.1  xtraeme 			break;
    500  1.36  xtraeme 	if (!sme)
    501  1.30  xtraeme 		goto out;
    502   1.1  xtraeme 
    503  1.13  xtraeme 	/* get the sensor with the index specified in see->snum */
    504  1.13  xtraeme 	edata = &sme->sme_sensor_data[see->snum];
    505   1.1  xtraeme 
    506   1.1  xtraeme 	/*
    507   1.1  xtraeme 	 * refresh the sensor that was marked with a critical
    508   1.1  xtraeme 	 * event.
    509   1.1  xtraeme 	 */
    510   1.1  xtraeme 	if ((sme->sme_flags & SME_DISABLE_GTREDATA) == 0) {
    511   1.1  xtraeme 		error = (*sme->sme_gtredata)(sme, edata);
    512  1.20  xtraeme 		if (error)
    513  1.30  xtraeme 			goto out;
    514   1.1  xtraeme 	}
    515   1.1  xtraeme 
    516  1.18  xtraeme 	DPRINTFOBJ(("%s: desc=%s sensor=%d units=%d value_cur=%d\n",
    517   1.1  xtraeme 	    __func__, edata->desc, edata->sensor,
    518   1.1  xtraeme 	    edata->units, edata->value_cur));
    519   1.1  xtraeme 
    520  1.10  xtraeme #define SME_SEND_NORMALEVENT()						\
    521  1.10  xtraeme do {									\
    522  1.10  xtraeme 	see->evsent = false;						\
    523  1.10  xtraeme 	sysmon_penvsys_event(&see->pes, PENVSYS_EVENT_NORMAL);		\
    524  1.10  xtraeme } while (/* CONSTCOND */ 0)
    525  1.10  xtraeme 
    526  1.10  xtraeme #define SME_SEND_EVENT(type)						\
    527   1.1  xtraeme do {									\
    528  1.10  xtraeme 	see->evsent = true;						\
    529  1.10  xtraeme 	sysmon_penvsys_event(&see->pes, (type));			\
    530   1.1  xtraeme } while (/* CONSTCOND */ 0)
    531   1.1  xtraeme 
    532   1.1  xtraeme 	switch (see->type) {
    533  1.10  xtraeme 	/*
    534  1.10  xtraeme 	 * if state is the same than the one that matches sse[i].state,
    535  1.10  xtraeme 	 * send the event...
    536  1.10  xtraeme 	 */
    537   1.1  xtraeme 	case PENVSYS_EVENT_CRITICAL:
    538   1.1  xtraeme 	case PENVSYS_EVENT_CRITUNDER:
    539   1.1  xtraeme 	case PENVSYS_EVENT_CRITOVER:
    540  1.10  xtraeme 	case PENVSYS_EVENT_WARNUNDER:
    541  1.10  xtraeme 	case PENVSYS_EVENT_WARNOVER:
    542  1.10  xtraeme 		for (i = 0; sse[i].state != -1; i++)
    543  1.10  xtraeme 			if (sse[i].event == see->type)
    544  1.10  xtraeme 				break;
    545   1.1  xtraeme 
    546  1.10  xtraeme 		if (see->evsent && edata->state == ENVSYS_SVALID)
    547  1.10  xtraeme 			SME_SEND_NORMALEVENT();
    548   1.1  xtraeme 
    549  1.10  xtraeme 		if (!see->evsent && edata->state == sse[i].state)
    550  1.10  xtraeme 			SME_SEND_EVENT(see->type);
    551   1.1  xtraeme 
    552   1.1  xtraeme 		break;
    553  1.10  xtraeme 	/*
    554  1.10  xtraeme 	 * if value_cur is lower than the limit, send the event...
    555  1.10  xtraeme 	 */
    556   1.1  xtraeme 	case PENVSYS_EVENT_BATT_USERCAP:
    557  1.10  xtraeme 	case PENVSYS_EVENT_USER_CRITMIN:
    558  1.10  xtraeme 		if (see->evsent && edata->value_cur > see->critval)
    559  1.10  xtraeme 			SME_SEND_NORMALEVENT();
    560   1.1  xtraeme 
    561  1.10  xtraeme 		if (!see->evsent && edata->value_cur < see->critval)
    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 higher than the limit, send the event...
    567  1.10  xtraeme 	 */
    568   1.1  xtraeme 	case PENVSYS_EVENT_USER_CRITMAX:
    569  1.10  xtraeme 		if (see->evsent && edata->value_cur < see->critval)
    570  1.10  xtraeme 			SME_SEND_NORMALEVENT();
    571   1.1  xtraeme 
    572  1.10  xtraeme 		if (!see->evsent && edata->value_cur > see->critval)
    573  1.10  xtraeme 			SME_SEND_EVENT(see->type);
    574   1.1  xtraeme 
    575   1.1  xtraeme 		break;
    576  1.10  xtraeme 	/*
    577  1.28  xtraeme 	 * if value_cur is not normal (battery) or online (drive),
    578  1.28  xtraeme 	 * send the event...
    579  1.10  xtraeme 	 */
    580  1.28  xtraeme 	case PENVSYS_EVENT_STATE_CHANGED:
    581   1.1  xtraeme 		/* the state has not been changed, just ignore the event */
    582   1.1  xtraeme 		if (edata->value_cur == see->evsent)
    583   1.1  xtraeme 			break;
    584   1.1  xtraeme 
    585  1.28  xtraeme 		switch (edata->units) {
    586  1.28  xtraeme 		case ENVSYS_DRIVE:
    587  1.28  xtraeme 			sdt = sme_get_description_table(SME_DESC_DRIVE_STATES);
    588  1.28  xtraeme 			state = ENVSYS_DRIVE_ONLINE;
    589  1.28  xtraeme 			break;
    590  1.28  xtraeme 		case ENVSYS_BATTERY_STATE:
    591  1.28  xtraeme 			sdt =
    592  1.28  xtraeme 			    sme_get_description_table(SME_DESC_BATTERY_STATES);
    593  1.28  xtraeme 			state = ENVSYS_BATTERY_STATE_NORMAL;
    594  1.28  xtraeme 			break;
    595  1.34  xtraeme 		default:
    596  1.35  xtraeme 			panic("%s: invalid units for ENVSYS_FMONSTCHANGED",
    597  1.35  xtraeme 			    __func__);
    598  1.28  xtraeme 		}
    599  1.28  xtraeme 
    600  1.28  xtraeme 		for (i = 0; sdt[i].type != -1; i++)
    601  1.28  xtraeme 			if (sdt[i].type == edata->value_cur)
    602   1.1  xtraeme 				break;
    603   1.1  xtraeme 
    604   1.1  xtraeme 		/* copy current state description  */
    605  1.28  xtraeme 		(void)strlcpy(see->pes.pes_statedesc, sdt[i].desc,
    606   1.1  xtraeme 		    sizeof(see->pes.pes_statedesc));
    607   1.1  xtraeme 
    608   1.1  xtraeme 		/* state is ok again... send a normal event */
    609  1.28  xtraeme 		if (see->evsent && edata->value_cur == state)
    610  1.10  xtraeme 			SME_SEND_NORMALEVENT();
    611   1.1  xtraeme 
    612  1.28  xtraeme 		/* state has been changed... send event */
    613  1.28  xtraeme 		if (see->evsent || edata->value_cur != state) {
    614   1.1  xtraeme 			/* save current drive state */
    615   1.1  xtraeme 			see->evsent = edata->value_cur;
    616  1.10  xtraeme 			sysmon_penvsys_event(&see->pes, see->type);
    617   1.1  xtraeme 		}
    618   1.1  xtraeme 
    619   1.1  xtraeme 		break;
    620   1.1  xtraeme 	}
    621  1.30  xtraeme out:
    622  1.15  xtraeme 	see->see_flags &= ~SME_EVENT_WORKING;
    623  1.33  xtraeme 	cv_broadcast(&sme_cv);
    624  1.31  xtraeme 	mutex_exit(&sme_mtx);
    625   1.1  xtraeme }
    626