Home | History | Annotate | Line # | Download | only in sysmon
sysmon_envsys_events.c revision 1.95
      1  1.95  pgoyette /* $NetBSD: sysmon_envsys_events.c,v 1.95 2010/12/08 00:09:14 pgoyette Exp $ */
      2   1.1   xtraeme 
      3   1.1   xtraeme /*-
      4  1.51   xtraeme  * Copyright (c) 2007, 2008 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.95  pgoyette __KERNEL_RCSID(0, "$NetBSD: sysmon_envsys_events.c,v 1.95 2010/12/08 00:09:14 pgoyette 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.1   xtraeme #include <sys/systm.h>
     41   1.1   xtraeme #include <sys/proc.h>
     42   1.1   xtraeme #include <sys/mutex.h>
     43   1.1   xtraeme #include <sys/kmem.h>
     44   1.1   xtraeme #include <sys/callout.h>
     45   1.1   xtraeme 
     46  1.32   xtraeme /* #define ENVSYS_DEBUG */
     47  1.82  pgoyette /* #define ENVSYS_OBJECTS_DEBUG */
     48  1.56  pgoyette 
     49   1.1   xtraeme #include <dev/sysmon/sysmonvar.h>
     50   1.1   xtraeme #include <dev/sysmon/sysmon_envsysvar.h>
     51   1.1   xtraeme 
     52  1.10   xtraeme struct sme_sensor_event {
     53  1.10   xtraeme 	int		state;
     54  1.10   xtraeme 	int		event;
     55  1.10   xtraeme };
     56  1.10   xtraeme 
     57  1.10   xtraeme static const struct sme_sensor_event sme_sensor_event[] = {
     58  1.65  pgoyette 	{ ENVSYS_SVALID,			PENVSYS_EVENT_NORMAL },
     59  1.65  pgoyette 	{ ENVSYS_SCRITOVER, 			PENVSYS_EVENT_CRITOVER },
     60  1.65  pgoyette 	{ ENVSYS_SCRITUNDER, 			PENVSYS_EVENT_CRITUNDER },
     61  1.65  pgoyette 	{ ENVSYS_SWARNOVER, 			PENVSYS_EVENT_WARNOVER },
     62  1.65  pgoyette 	{ ENVSYS_SWARNUNDER,			PENVSYS_EVENT_WARNUNDER },
     63  1.65  pgoyette 	{ ENVSYS_BATTERY_CAPACITY_NORMAL,	PENVSYS_EVENT_NORMAL },
     64  1.65  pgoyette 	{ ENVSYS_BATTERY_CAPACITY_WARNING,	PENVSYS_EVENT_BATT_WARN },
     65  1.65  pgoyette 	{ ENVSYS_BATTERY_CAPACITY_CRITICAL,	PENVSYS_EVENT_BATT_CRIT },
     66  1.84  pgoyette 	{ ENVSYS_BATTERY_CAPACITY_HIGH,		PENVSYS_EVENT_BATT_HIGH },
     67  1.84  pgoyette 	{ ENVSYS_BATTERY_CAPACITY_MAX,		PENVSYS_EVENT_BATT_MAX },
     68  1.65  pgoyette 	{ -1, 					-1 }
     69  1.10   xtraeme };
     70  1.10   xtraeme 
     71  1.51   xtraeme static bool sysmon_low_power;
     72   1.1   xtraeme 
     73  1.45   xtraeme #define SME_EVTIMO	(SME_EVENTS_DEFTIMEOUT * hz)
     74   1.3   xtraeme 
     75  1.44   xtraeme static bool sme_event_check_low_power(void);
     76  1.47   xtraeme static bool sme_battery_check(void);
     77  1.44   xtraeme static bool sme_battery_critical(envsys_data_t *);
     78  1.47   xtraeme static bool sme_acadapter_check(void);
     79  1.38   xtraeme 
     80   1.3   xtraeme /*
     81   1.1   xtraeme  * sme_event_register:
     82   1.1   xtraeme  *
     83  1.24   xtraeme  * 	+ Registers a new sysmon envsys event or updates any event
     84  1.24   xtraeme  * 	  already in the queue.
     85   1.1   xtraeme  */
     86   1.1   xtraeme int
     87  1.24   xtraeme sme_event_register(prop_dictionary_t sdict, envsys_data_t *edata,
     88  1.67  pgoyette 		   struct sysmon_envsys *sme, sysmon_envsys_lim_t *lims,
     89  1.82  pgoyette 		   uint32_t props, int crittype, int powertype)
     90   1.1   xtraeme {
     91  1.51   xtraeme 	sme_event_t *see = NULL, *osee = NULL;
     92  1.24   xtraeme 	prop_object_t obj;
     93   1.1   xtraeme 	int error = 0;
     94  1.65  pgoyette 	const char *objkey;
     95   1.1   xtraeme 
     96  1.76  pgoyette 	KASSERT(sdict != NULL);
     97  1.76  pgoyette 	KASSERT(edata != NULL);
     98  1.76  pgoyette 	KASSERT(sme != NULL);
     99  1.77  pgoyette 	KASSERT(lims != NULL);
    100  1.77  pgoyette 
    101  1.77  pgoyette 	/*
    102  1.77  pgoyette 	 * Some validation first for limit-checking events
    103  1.77  pgoyette 	 *
    104  1.85  pgoyette 	 * 1. Limits are not permitted if the units is ENVSYS_INDICATOR.
    105  1.85  pgoyette 	 *
    106  1.85  pgoyette 	 * 2. Capacity limits are permitted only if the sensor has the
    107  1.85  pgoyette 	 *    ENVSYS_FPERCENT flag set and value_max is set.
    108  1.85  pgoyette 	 *
    109  1.85  pgoyette 	 * 3. It is not permissible for both capacity and value limits
    110  1.85  pgoyette 	 *    to coexist.
    111  1.85  pgoyette 	 *
    112  1.85  pgoyette 	 * Note that it permissible for a sensor to have value limits
    113  1.85  pgoyette 	 * even if its ENVSYS_FPERCENT flag and value_max are set.
    114  1.77  pgoyette 	 */
    115  1.77  pgoyette 
    116  1.90     njoly 	DPRINTF(("%s: units %d props 0x%04x upropset 0x%04x max_val %d"
    117  1.88  pgoyette 		" edata-flags 0x%04x\n", __func__, edata->units, props,
    118  1.88  pgoyette 		edata->upropset, edata->value_max, edata->flags));
    119  1.77  pgoyette 
    120  1.85  pgoyette 	if (props && edata->units == ENVSYS_INDICATOR)
    121  1.77  pgoyette 		return ENOTSUP;
    122  1.85  pgoyette 
    123  1.82  pgoyette 	if ((props & PROP_CAP_LIMITS) &&
    124  1.85  pgoyette 	    ((edata->value_max == 0) ||
    125  1.85  pgoyette 	     !(edata->flags & ENVSYS_FPERCENT) ||
    126  1.85  pgoyette 	     (props & PROP_VAL_LIMITS) ||
    127  1.85  pgoyette 	     (edata->upropset & PROP_VAL_LIMITS)))
    128  1.91  pgoyette 		props = 0;
    129  1.85  pgoyette 
    130  1.85  pgoyette 	if ((props & PROP_VAL_LIMITS) && (edata->upropset & PROP_CAP_LIMITS))
    131  1.91  pgoyette 		props = 0;
    132  1.56  pgoyette 
    133   1.1   xtraeme 	/*
    134  1.24   xtraeme 	 * check if the event is already on the list and return
    135  1.24   xtraeme 	 * EEXIST if value provided hasn't been changed.
    136   1.1   xtraeme 	 */
    137  1.51   xtraeme 	mutex_enter(&sme->sme_mtx);
    138  1.51   xtraeme 	LIST_FOREACH(osee, &sme->sme_events_list, see_list) {
    139  1.65  pgoyette 		if (strcmp(edata->desc, osee->see_pes.pes_sensname) != 0)
    140  1.65  pgoyette 			continue;
    141  1.65  pgoyette 		if (crittype != osee->see_type)
    142  1.65  pgoyette 			continue;
    143  1.65  pgoyette 
    144  1.76  pgoyette 		/*
    145  1.76  pgoyette 		 * We found an existing event for this sensor.  Make
    146  1.76  pgoyette 		 * sure it references the correct edata
    147  1.76  pgoyette 		 */
    148  1.76  pgoyette 		KASSERT(edata == osee->see_edata);
    149  1.76  pgoyette 
    150  1.77  pgoyette 		DPRINTF(("%s: dev %s sensor %s: event type %d exists\n",
    151  1.77  pgoyette 		    __func__, sme->sme_name, edata->desc, crittype));
    152  1.65  pgoyette 
    153  1.65  pgoyette 		see = osee;
    154  1.95  pgoyette 		if (props & edata->upropset & (PROP_CRITMAX | PROP_BATTMAX)) {
    155  1.76  pgoyette 			if (lims->sel_critmax == edata->limits.sel_critmax) {
    156  1.95  pgoyette 				DPRINTF(("%s: critmax exists\n", __func__));
    157  1.65  pgoyette 				error = EEXIST;
    158  1.84  pgoyette 				props &= ~(PROP_CRITMAX | PROP_BATTMAX);
    159  1.65  pgoyette 			}
    160  1.65  pgoyette 		}
    161  1.95  pgoyette 		if (props & edata->upropset & (PROP_WARNMAX | PROP_BATTHIGH)) {
    162  1.76  pgoyette 			if (lims->sel_warnmax == edata->limits.sel_warnmax) {
    163  1.77  pgoyette 				DPRINTF(("%s: warnmax exists\n", __func__));
    164  1.65  pgoyette 				error = EEXIST;
    165  1.84  pgoyette 				props &= ~(PROP_WARNMAX | PROP_BATTHIGH);
    166  1.65  pgoyette 			}
    167  1.65  pgoyette 		}
    168  1.95  pgoyette 		if (props & edata->upropset & (PROP_WARNMIN | PROP_BATTWARN)) {
    169  1.76  pgoyette 			if (lims->sel_warnmin == edata->limits.sel_warnmin) {
    170  1.77  pgoyette 				DPRINTF(("%s: warnmin exists\n", __func__));
    171  1.65  pgoyette 				error = EEXIST;
    172  1.82  pgoyette 				props &= ~(PROP_WARNMIN | PROP_BATTWARN);
    173   1.1   xtraeme 			}
    174  1.65  pgoyette 		}
    175  1.95  pgoyette 		if (props & edata->upropset & (PROP_CRITMIN | PROP_BATTCAP)) {
    176  1.76  pgoyette 			if (lims->sel_critmin == edata->limits.sel_critmin) {
    177  1.77  pgoyette 				DPRINTF(("%s: critmin exists\n", __func__));
    178  1.65  pgoyette 				error = EEXIST;
    179  1.82  pgoyette 				props &= ~(PROP_CRITMIN | PROP_BATTCAP);
    180  1.56  pgoyette 			}
    181   1.1   xtraeme 		}
    182  1.65  pgoyette 		break;
    183   1.1   xtraeme 	}
    184  1.65  pgoyette 	if (see == NULL) {
    185  1.65  pgoyette 		/*
    186  1.65  pgoyette 		 * New event requested - allocate a sysmon_envsys event.
    187  1.65  pgoyette 		 */
    188  1.65  pgoyette 		see = kmem_zalloc(sizeof(*see), KM_SLEEP);
    189  1.65  pgoyette 		if (see == NULL)
    190  1.65  pgoyette 			return ENOMEM;
    191  1.65  pgoyette 
    192  1.77  pgoyette 		DPRINTF(("%s: dev %s sensor %s: new event\n",
    193  1.79    jruoho 		    __func__, sme->sme_name, edata->desc));
    194  1.65  pgoyette 
    195  1.65  pgoyette 		see->see_type = crittype;
    196  1.65  pgoyette 		see->see_sme = sme;
    197  1.65  pgoyette 		see->see_edata = edata;
    198  1.65  pgoyette 
    199  1.65  pgoyette 		/* Initialize sensor type and previously-sent state */
    200  1.65  pgoyette 
    201  1.65  pgoyette 		see->see_pes.pes_type = powertype;
    202   1.1   xtraeme 
    203  1.56  pgoyette 		switch (crittype) {
    204  1.65  pgoyette 		case PENVSYS_EVENT_LIMITS:
    205  1.65  pgoyette 			see->see_evsent = ENVSYS_SVALID;
    206  1.65  pgoyette 			break;
    207  1.65  pgoyette 		case PENVSYS_EVENT_CAPACITY:
    208  1.65  pgoyette 			see->see_evsent = ENVSYS_BATTERY_CAPACITY_NORMAL;
    209  1.56  pgoyette 			break;
    210  1.65  pgoyette 		case PENVSYS_EVENT_STATE_CHANGED:
    211  1.65  pgoyette 			if (edata->units == ENVSYS_BATTERY_CAPACITY)
    212  1.65  pgoyette 				see->see_evsent = ENVSYS_BATTERY_CAPACITY_NORMAL;
    213  1.65  pgoyette 			else if (edata->units == ENVSYS_DRIVE)
    214  1.65  pgoyette 				see->see_evsent = ENVSYS_DRIVE_EMPTY;
    215  1.65  pgoyette 			else
    216  1.65  pgoyette 				panic("%s: bad units for "
    217  1.65  pgoyette 				      "PENVSYS_EVENT_STATE_CHANGED", __func__);
    218  1.56  pgoyette 			break;
    219  1.65  pgoyette 		case PENVSYS_EVENT_CRITICAL:
    220  1.56  pgoyette 		default:
    221  1.65  pgoyette 			see->see_evsent = 0;
    222  1.56  pgoyette 			break;
    223  1.56  pgoyette 		}
    224  1.65  pgoyette 
    225  1.65  pgoyette 		(void)strlcpy(see->see_pes.pes_dvname, sme->sme_name,
    226  1.65  pgoyette 		    sizeof(see->see_pes.pes_dvname));
    227  1.65  pgoyette 		(void)strlcpy(see->see_pes.pes_sensname, edata->desc,
    228  1.65  pgoyette 		    sizeof(see->see_pes.pes_sensname));
    229  1.56  pgoyette 	}
    230  1.65  pgoyette 
    231  1.56  pgoyette 	/*
    232  1.65  pgoyette 	 * Limit operation requested.
    233  1.24   xtraeme 	 */
    234  1.83  pgoyette #define	LIMIT_OP(k, l, p)						\
    235  1.83  pgoyette 	if (props & p) {						\
    236  1.83  pgoyette 		objkey = k;						\
    237  1.83  pgoyette 		obj = prop_dictionary_get(sdict, objkey);		\
    238  1.83  pgoyette 		if (obj != NULL &&					\
    239  1.83  pgoyette 		    prop_object_type(obj) != PROP_TYPE_NUMBER) {	\
    240  1.83  pgoyette 			DPRINTF(("%s: (%s) %s object no TYPE_NUMBER\n",	\
    241  1.83  pgoyette 			    __func__, sme->sme_name, objkey));		\
    242  1.83  pgoyette 			error = ENOTSUP;				\
    243  1.83  pgoyette 		} else {						\
    244  1.83  pgoyette 			edata->limits.l = lims->l;			\
    245  1.83  pgoyette 			error = sme_sensor_upint32(sdict, objkey,lims->l); \
    246  1.83  pgoyette 			DPRINTF(("%s: (%s) event [sensor=%s type=%d] "	\
    247  1.83  pgoyette 			    "(%s updated)\n", __func__, sme->sme_name,	\
    248  1.83  pgoyette 			    edata->desc, crittype, objkey));		\
    249  1.83  pgoyette 		}							\
    250  1.83  pgoyette 		if (error && error != EEXIST)				\
    251  1.83  pgoyette 			goto out;					\
    252  1.83  pgoyette 		edata->upropset |= p;					\
    253  1.27   xtraeme 	}
    254  1.65  pgoyette 
    255  1.83  pgoyette 	/* Value-based limits */
    256  1.83  pgoyette 	LIMIT_OP("critical-max", sel_critmax, PROP_CRITMAX);
    257  1.83  pgoyette 	LIMIT_OP("warning-max",  sel_warnmax, PROP_WARNMAX);
    258  1.83  pgoyette 	LIMIT_OP("warning-min",  sel_warnmin, PROP_WARNMIN);
    259  1.83  pgoyette 	LIMIT_OP("critical-min", sel_critmin, PROP_CRITMIN);
    260  1.83  pgoyette 
    261  1.83  pgoyette 	/* %Capacity-based limits */
    262  1.84  pgoyette 	LIMIT_OP("maximum-capacity",  sel_critmax,  PROP_BATTMAX);
    263  1.84  pgoyette 	LIMIT_OP("high-capacity",     sel_warnmax,  PROP_BATTHIGH);
    264  1.83  pgoyette 	LIMIT_OP("warning-capacity",  sel_warnmin,  PROP_BATTWARN);
    265  1.83  pgoyette 	LIMIT_OP("critical-capacity", sel_critmin,  PROP_BATTCAP);
    266  1.83  pgoyette 
    267  1.83  pgoyette #undef LIMIT_OP
    268  1.83  pgoyette 
    269  1.82  pgoyette 	if (props & PROP_DRIVER_LIMITS)
    270  1.76  pgoyette 		edata->upropset |= PROP_DRIVER_LIMITS;
    271  1.76  pgoyette 	else
    272  1.76  pgoyette 		edata->upropset &= ~PROP_DRIVER_LIMITS;
    273  1.74  pgoyette 
    274  1.51   xtraeme 	DPRINTF(("%s: (%s) event registered (sensor=%s snum=%d type=%d "
    275  1.56  pgoyette 	    "critmin=%" PRIu32 " warnmin=%" PRIu32 " warnmax=%" PRIu32
    276  1.65  pgoyette 	    " critmax=%" PRIu32 " props 0x%04x)\n", __func__,
    277  1.45   xtraeme 	    see->see_sme->sme_name, see->see_pes.pes_sensname,
    278  1.76  pgoyette 	    edata->sensor, see->see_type, edata->limits.sel_critmin,
    279  1.76  pgoyette 	    edata->limits.sel_warnmin, edata->limits.sel_warnmax,
    280  1.76  pgoyette 	    edata->limits.sel_critmax, edata->upropset));
    281   1.1   xtraeme 	/*
    282  1.45   xtraeme 	 * Initialize the events framework if it wasn't initialized before.
    283   1.1   xtraeme 	 */
    284  1.45   xtraeme 	if ((sme->sme_flags & SME_CALLOUT_INITIALIZED) == 0)
    285  1.45   xtraeme 		error = sme_events_init(sme);
    286  1.67  pgoyette 
    287  1.67  pgoyette 	/*
    288  1.67  pgoyette 	 * If driver requested notification, advise it of new
    289  1.67  pgoyette 	 * limit values
    290  1.67  pgoyette 	 */
    291  1.82  pgoyette 	if (sme->sme_set_limits)
    292  1.82  pgoyette 		(*sme->sme_set_limits)(sme, edata, &(edata->limits),
    293  1.82  pgoyette 					&(edata->upropset));
    294  1.67  pgoyette 
    295  1.27   xtraeme out:
    296  1.65  pgoyette 	if ((error == 0 || error == EEXIST) && osee == NULL)
    297  1.65  pgoyette 		LIST_INSERT_HEAD(&sme->sme_events_list, see, see_list);
    298  1.65  pgoyette 
    299  1.51   xtraeme 	mutex_exit(&sme->sme_mtx);
    300  1.65  pgoyette 
    301   1.1   xtraeme 	return error;
    302   1.1   xtraeme }
    303   1.1   xtraeme 
    304   1.1   xtraeme /*
    305  1.18   xtraeme  * sme_event_unregister_all:
    306  1.18   xtraeme  *
    307  1.51   xtraeme  * 	+ Unregisters all events associated with a sysmon envsys device.
    308  1.18   xtraeme  */
    309  1.18   xtraeme void
    310  1.45   xtraeme sme_event_unregister_all(struct sysmon_envsys *sme)
    311  1.18   xtraeme {
    312  1.18   xtraeme 	sme_event_t *see;
    313  1.18   xtraeme 	int evcounter = 0;
    314  1.18   xtraeme 
    315  1.45   xtraeme 	KASSERT(sme != NULL);
    316  1.18   xtraeme 
    317  1.51   xtraeme 	mutex_enter(&sme->sme_mtx);
    318  1.45   xtraeme 	LIST_FOREACH(see, &sme->sme_events_list, see_list) {
    319  1.56  pgoyette 		while (see->see_flags & SEE_EVENT_WORKING)
    320  1.51   xtraeme 			cv_wait(&sme->sme_condvar, &sme->sme_mtx);
    321  1.51   xtraeme 
    322  1.45   xtraeme 		if (strcmp(see->see_pes.pes_dvname, sme->sme_name) == 0)
    323  1.18   xtraeme 			evcounter++;
    324  1.18   xtraeme 	}
    325  1.18   xtraeme 
    326  1.18   xtraeme 	DPRINTF(("%s: total events %d (%s)\n", __func__,
    327  1.45   xtraeme 	    evcounter, sme->sme_name));
    328  1.18   xtraeme 
    329  1.45   xtraeme 	while ((see = LIST_FIRST(&sme->sme_events_list))) {
    330  1.18   xtraeme 		if (evcounter == 0)
    331  1.18   xtraeme 			break;
    332  1.18   xtraeme 
    333  1.45   xtraeme 		if (strcmp(see->see_pes.pes_dvname, sme->sme_name) == 0) {
    334  1.51   xtraeme 			LIST_REMOVE(see, see_list);
    335  1.18   xtraeme 			DPRINTF(("%s: event %s %d removed (%s)\n", __func__,
    336  1.45   xtraeme 			    see->see_pes.pes_sensname, see->see_type,
    337  1.45   xtraeme 			    sme->sme_name));
    338  1.18   xtraeme 			kmem_free(see, sizeof(*see));
    339  1.18   xtraeme 			evcounter--;
    340  1.18   xtraeme 		}
    341  1.18   xtraeme 	}
    342  1.18   xtraeme 
    343  1.51   xtraeme 	if (LIST_EMPTY(&sme->sme_events_list))
    344  1.45   xtraeme 		if (sme->sme_flags & SME_CALLOUT_INITIALIZED)
    345  1.45   xtraeme 			sme_events_destroy(sme);
    346  1.51   xtraeme 	mutex_exit(&sme->sme_mtx);
    347  1.18   xtraeme }
    348  1.18   xtraeme 
    349  1.18   xtraeme /*
    350   1.1   xtraeme  * sme_event_unregister:
    351   1.1   xtraeme  *
    352  1.45   xtraeme  * 	+ Unregisters an event from the specified sysmon envsys device.
    353   1.1   xtraeme  */
    354   1.1   xtraeme int
    355  1.45   xtraeme sme_event_unregister(struct sysmon_envsys *sme, const char *sensor, int type)
    356   1.1   xtraeme {
    357   1.1   xtraeme 	sme_event_t *see;
    358   1.1   xtraeme 	bool found = false;
    359   1.1   xtraeme 
    360   1.1   xtraeme 	KASSERT(sensor != NULL);
    361   1.1   xtraeme 
    362  1.51   xtraeme 	mutex_enter(&sme->sme_mtx);
    363  1.45   xtraeme 	LIST_FOREACH(see, &sme->sme_events_list, see_list) {
    364  1.45   xtraeme 		if (strcmp(see->see_pes.pes_sensname, sensor) == 0) {
    365  1.45   xtraeme 			if (see->see_type == type) {
    366   1.1   xtraeme 				found = true;
    367   1.1   xtraeme 				break;
    368   1.1   xtraeme 			}
    369   1.1   xtraeme 		}
    370   1.1   xtraeme 	}
    371   1.1   xtraeme 
    372  1.51   xtraeme 	if (!found) {
    373  1.51   xtraeme 		mutex_exit(&sme->sme_mtx);
    374   1.1   xtraeme 		return EINVAL;
    375  1.51   xtraeme 	}
    376   1.1   xtraeme 
    377  1.51   xtraeme 	/*
    378  1.51   xtraeme 	 * Wait for the event to finish its work, remove from the list
    379  1.51   xtraeme 	 * and release resouces.
    380  1.51   xtraeme 	 */
    381  1.56  pgoyette 	while (see->see_flags & SEE_EVENT_WORKING)
    382  1.51   xtraeme 		cv_wait(&sme->sme_condvar, &sme->sme_mtx);
    383  1.15   xtraeme 
    384  1.51   xtraeme 	DPRINTF(("%s: removed dev=%s sensor=%s type=%d\n",
    385  1.45   xtraeme 	    __func__, see->see_pes.pes_dvname, sensor, type));
    386   1.1   xtraeme 	LIST_REMOVE(see, see_list);
    387   1.1   xtraeme 	/*
    388   1.1   xtraeme 	 * So the events list is empty, we'll do the following:
    389   1.1   xtraeme 	 *
    390   1.9   xtraeme 	 * 	- stop and destroy the callout.
    391   1.1   xtraeme 	 * 	- destroy the workqueue.
    392   1.1   xtraeme 	 */
    393  1.51   xtraeme 	if (LIST_EMPTY(&sme->sme_events_list))
    394  1.45   xtraeme 		sme_events_destroy(sme);
    395  1.51   xtraeme 	mutex_exit(&sme->sme_mtx);
    396   1.1   xtraeme 
    397  1.20   xtraeme 	kmem_free(see, sizeof(*see));
    398   1.1   xtraeme 	return 0;
    399   1.1   xtraeme }
    400   1.1   xtraeme 
    401   1.1   xtraeme /*
    402   1.1   xtraeme  * sme_event_drvadd:
    403   1.1   xtraeme  *
    404  1.45   xtraeme  * 	+ Registers a new event for a device that had enabled any of
    405  1.45   xtraeme  * 	  the monitoring flags in the driver.
    406   1.1   xtraeme  */
    407   1.1   xtraeme void
    408   1.1   xtraeme sme_event_drvadd(void *arg)
    409   1.1   xtraeme {
    410   1.1   xtraeme 	sme_event_drv_t *sed_t = arg;
    411  1.67  pgoyette 	sysmon_envsys_lim_t lims;
    412  1.82  pgoyette 	uint32_t props;
    413   1.2   xtraeme 	int error = 0;
    414   1.1   xtraeme 
    415   1.1   xtraeme 	KASSERT(sed_t != NULL);
    416   1.1   xtraeme 
    417   1.1   xtraeme #define SEE_REGEVENT(a, b, c)						\
    418   1.1   xtraeme do {									\
    419  1.45   xtraeme 	if (sed_t->sed_edata->flags & (a)) {				\
    420  1.36   xtraeme 		char str[ENVSYS_DESCLEN] = "monitoring-state-";		\
    421   1.1   xtraeme 									\
    422  1.45   xtraeme 		error = sme_event_register(sed_t->sed_sdict,		\
    423  1.45   xtraeme 				      sed_t->sed_edata,			\
    424  1.45   xtraeme 				      sed_t->sed_sme,			\
    425  1.82  pgoyette 				      &lims, props,			\
    426   1.2   xtraeme 				      (b),				\
    427  1.45   xtraeme 				      sed_t->sed_powertype);		\
    428   1.2   xtraeme 		if (error && error != EEXIST)				\
    429   1.2   xtraeme 			printf("%s: failed to add event! "		\
    430   1.2   xtraeme 			    "error=%d sensor=%s event=%s\n",		\
    431  1.45   xtraeme 			    __func__, error,				\
    432  1.45   xtraeme 			    sed_t->sed_edata->desc, (c));		\
    433   1.2   xtraeme 		else {							\
    434   1.2   xtraeme 			(void)strlcat(str, (c), sizeof(str));		\
    435  1.45   xtraeme 			prop_dictionary_set_bool(sed_t->sed_sdict,	\
    436   1.2   xtraeme 						 str,			\
    437   1.2   xtraeme 						 true);			\
    438   1.2   xtraeme 		}							\
    439   1.1   xtraeme 	}								\
    440   1.1   xtraeme } while (/* CONSTCOND */ 0)
    441   1.1   xtraeme 
    442  1.71  pgoyette 	/*
    443  1.73  pgoyette 	 * If driver provides a method to retrieve its internal limit
    444  1.74  pgoyette 	 * values, call it and use those returned values as initial
    445  1.73  pgoyette 	 * limits for event monitoring.
    446  1.71  pgoyette 	 */
    447  1.82  pgoyette 	props = 0;
    448  1.71  pgoyette 	if (sed_t->sed_edata->flags & ENVSYS_FMONLIMITS)
    449  1.67  pgoyette 		if (sed_t->sed_sme->sme_get_limits)
    450  1.67  pgoyette 			(*sed_t->sed_sme->sme_get_limits)(sed_t->sed_sme,
    451  1.68  pgoyette 							  sed_t->sed_edata,
    452  1.82  pgoyette 							  &lims, &props);
    453  1.73  pgoyette 	/*
    454  1.73  pgoyette 	 * If driver doesn't provide a way to "absorb" user-specified
    455  1.73  pgoyette 	 * limit values, we must monitor all limits ourselves
    456  1.73  pgoyette 	 */
    457  1.91  pgoyette 	if (sed_t->sed_sme->sme_set_limits == NULL)
    458  1.82  pgoyette 		props &= ~PROP_DRIVER_LIMITS;
    459  1.71  pgoyette 
    460  1.71  pgoyette 	/* Register the events that were specified */
    461  1.67  pgoyette 
    462   1.1   xtraeme 	SEE_REGEVENT(ENVSYS_FMONCRITICAL,
    463   1.1   xtraeme 		     PENVSYS_EVENT_CRITICAL,
    464   1.1   xtraeme 		     "critical");
    465   1.1   xtraeme 
    466  1.67  pgoyette 	SEE_REGEVENT(ENVSYS_FMONSTCHANGED,
    467  1.67  pgoyette 		     PENVSYS_EVENT_STATE_CHANGED,
    468  1.67  pgoyette 		     "state-changed");
    469  1.67  pgoyette 
    470  1.64  pgoyette 	SEE_REGEVENT(ENVSYS_FMONLIMITS,
    471  1.65  pgoyette 		     PENVSYS_EVENT_LIMITS,
    472  1.56  pgoyette 		     "hw-range-limits");
    473   1.1   xtraeme 
    474  1.45   xtraeme 	/*
    475  1.45   xtraeme 	 * we are done, free memory now.
    476  1.45   xtraeme 	 */
    477   1.1   xtraeme 	kmem_free(sed_t, sizeof(*sed_t));
    478   1.1   xtraeme }
    479   1.1   xtraeme 
    480   1.1   xtraeme /*
    481   1.1   xtraeme  * sme_events_init:
    482   1.1   xtraeme  *
    483  1.45   xtraeme  * 	+ Initialize the events framework for this device.
    484   1.1   xtraeme  */
    485   1.1   xtraeme int
    486  1.45   xtraeme sme_events_init(struct sysmon_envsys *sme)
    487   1.1   xtraeme {
    488  1.51   xtraeme 	int error = 0;
    489  1.45   xtraeme 	uint64_t timo;
    490   1.1   xtraeme 
    491  1.45   xtraeme 	KASSERT(sme != NULL);
    492  1.51   xtraeme 	KASSERT(mutex_owned(&sme->sme_mtx));
    493  1.22   xtraeme 
    494  1.45   xtraeme 	if (sme->sme_events_timeout)
    495  1.45   xtraeme 		timo = sme->sme_events_timeout * hz;
    496  1.45   xtraeme 	else
    497  1.45   xtraeme 		timo = SME_EVTIMO;
    498  1.45   xtraeme 
    499  1.45   xtraeme 	error = workqueue_create(&sme->sme_wq, sme->sme_name,
    500  1.45   xtraeme 	    sme_events_worker, sme, PRI_NONE, IPL_SOFTCLOCK, WQ_MPSAFE);
    501   1.1   xtraeme 	if (error)
    502  1.51   xtraeme 		return error;
    503   1.1   xtraeme 
    504  1.51   xtraeme 	mutex_init(&sme->sme_callout_mtx, MUTEX_DEFAULT, IPL_SOFTCLOCK);
    505  1.54   xtraeme 	callout_init(&sme->sme_callout, CALLOUT_MPSAFE);
    506  1.45   xtraeme 	callout_setfunc(&sme->sme_callout, sme_events_check, sme);
    507  1.45   xtraeme 	callout_schedule(&sme->sme_callout, timo);
    508  1.45   xtraeme 	sme->sme_flags |= SME_CALLOUT_INITIALIZED;
    509  1.45   xtraeme 	DPRINTF(("%s: events framework initialized for '%s'\n",
    510  1.45   xtraeme 	    __func__, sme->sme_name));
    511   1.1   xtraeme 
    512   1.1   xtraeme 	return error;
    513   1.1   xtraeme }
    514   1.1   xtraeme 
    515   1.1   xtraeme /*
    516  1.18   xtraeme  * sme_events_destroy:
    517  1.18   xtraeme  *
    518  1.51   xtraeme  * 	+ Destroys the event framework for this device: callout
    519  1.51   xtraeme  * 	  stopped, workqueue destroyed and callout mutex destroyed.
    520  1.18   xtraeme  */
    521  1.18   xtraeme void
    522  1.45   xtraeme sme_events_destroy(struct sysmon_envsys *sme)
    523  1.18   xtraeme {
    524  1.51   xtraeme 	KASSERT(mutex_owned(&sme->sme_mtx));
    525  1.22   xtraeme 
    526  1.45   xtraeme 	callout_stop(&sme->sme_callout);
    527  1.54   xtraeme 	workqueue_destroy(sme->sme_wq);
    528  1.54   xtraeme 	mutex_destroy(&sme->sme_callout_mtx);
    529  1.54   xtraeme 	callout_destroy(&sme->sme_callout);
    530  1.45   xtraeme 	sme->sme_flags &= ~SME_CALLOUT_INITIALIZED;
    531  1.45   xtraeme 	DPRINTF(("%s: events framework destroyed for '%s'\n",
    532  1.45   xtraeme 	    __func__, sme->sme_name));
    533  1.18   xtraeme }
    534  1.18   xtraeme 
    535  1.18   xtraeme /*
    536  1.91  pgoyette  * sysmon_envsys_update_limits
    537  1.91  pgoyette  *
    538  1.91  pgoyette  *	+ If a driver needs to update the limits that it is providing,
    539  1.91  pgoyette  *	  we need to update the dictionary data as well as the limits.
    540  1.91  pgoyette  *	  This only makes sense if the driver is capable of providing
    541  1.91  pgoyette  *	  its limits, and if there is a limits event-monitor.
    542  1.91  pgoyette  */
    543  1.91  pgoyette int
    544  1.91  pgoyette sysmon_envsys_update_limits(struct sysmon_envsys *sme, envsys_data_t *edata)
    545  1.91  pgoyette {
    546  1.92  pgoyette 	int err;
    547  1.92  pgoyette 
    548  1.93  pgoyette 	sysmon_envsys_acquire(sme, false);
    549  1.92  pgoyette 	if (sme->sme_get_limits == NULL ||
    550  1.92  pgoyette 	    (edata->flags & ENVSYS_FMONLIMITS) == 0)
    551  1.93  pgoyette 		err = EINVAL;
    552  1.93  pgoyette 	else
    553  1.93  pgoyette 		err = sme_update_limits(sme, edata);
    554  1.92  pgoyette 	sysmon_envsys_release(sme, false);
    555  1.92  pgoyette 
    556  1.92  pgoyette 	return err;
    557  1.92  pgoyette }
    558  1.92  pgoyette 
    559  1.92  pgoyette /*
    560  1.92  pgoyette  * sme_update_limits
    561  1.92  pgoyette  *
    562  1.92  pgoyette  *	+ Internal version of sysmon_envsys_update_limits() to be used
    563  1.92  pgoyette  *	  when the device has already been sysmon_envsys_acquire()d.
    564  1.92  pgoyette  */
    565  1.92  pgoyette 
    566  1.92  pgoyette int
    567  1.92  pgoyette sme_update_limits(struct sysmon_envsys *sme, envsys_data_t *edata)
    568  1.92  pgoyette {
    569  1.91  pgoyette 	prop_dictionary_t sdict = NULL;
    570  1.91  pgoyette 	prop_array_t array = NULL;
    571  1.91  pgoyette 	sysmon_envsys_lim_t lims;
    572  1.91  pgoyette 	sme_event_t *see;
    573  1.91  pgoyette 	uint32_t props = 0;
    574  1.91  pgoyette 
    575  1.91  pgoyette 	/* Find the dictionary for this sensor */
    576  1.91  pgoyette 	array = prop_dictionary_get(sme_propd, sme->sme_name);
    577  1.91  pgoyette 	if (array == NULL ||
    578  1.91  pgoyette 	    prop_object_type(array) != PROP_TYPE_ARRAY) {
    579  1.91  pgoyette 		DPRINTF(("%s: array device failed\n", __func__));
    580  1.91  pgoyette 		return EINVAL;
    581  1.91  pgoyette 	}
    582  1.91  pgoyette 
    583  1.91  pgoyette 	sdict = prop_array_get(array, edata->sensor);
    584  1.91  pgoyette 	if (sdict == NULL) {
    585  1.91  pgoyette 		return EINVAL;
    586  1.91  pgoyette 	}
    587  1.91  pgoyette 
    588  1.91  pgoyette 	/* Find the event definition to get its powertype */
    589  1.91  pgoyette 	LIST_FOREACH(see, &sme->sme_events_list, see_list) {
    590  1.91  pgoyette 		if (edata == see->see_edata &&
    591  1.91  pgoyette 		    see->see_type == PENVSYS_EVENT_LIMITS)
    592  1.91  pgoyette 			break;
    593  1.91  pgoyette 	}
    594  1.92  pgoyette 	if (see == NULL)
    595  1.91  pgoyette 		return EINVAL;
    596  1.92  pgoyette 
    597  1.93  pgoyette 	/* Update limit values from driver if possible */
    598  1.93  pgoyette 	if (sme->sme_get_limits != NULL)
    599  1.93  pgoyette 		(*sme->sme_get_limits)(sme, edata, &lims, &props);
    600  1.91  pgoyette 
    601  1.91  pgoyette 	/* Update event and dictionary */
    602  1.91  pgoyette 	sme_event_register(sdict, edata, sme, &lims, props,
    603  1.91  pgoyette 			   PENVSYS_EVENT_LIMITS, see->see_pes.pes_type);
    604  1.91  pgoyette 
    605  1.91  pgoyette 	return 0;
    606  1.91  pgoyette }
    607  1.91  pgoyette 
    608  1.91  pgoyette /*
    609   1.1   xtraeme  * sme_events_check:
    610   1.1   xtraeme  *
    611  1.51   xtraeme  * 	+ Passes the events to the workqueue thread and stops
    612  1.51   xtraeme  * 	  the callout if the 'low-power' condition is triggered.
    613   1.1   xtraeme  */
    614   1.1   xtraeme void
    615   1.1   xtraeme sme_events_check(void *arg)
    616   1.1   xtraeme {
    617  1.45   xtraeme 	struct sysmon_envsys *sme = arg;
    618   1.1   xtraeme 	sme_event_t *see;
    619  1.45   xtraeme 	uint64_t timo;
    620  1.45   xtraeme 
    621  1.45   xtraeme 	KASSERT(sme != NULL);
    622  1.45   xtraeme 
    623  1.51   xtraeme 	mutex_enter(&sme->sme_callout_mtx);
    624  1.51   xtraeme 	LIST_FOREACH(see, &sme->sme_events_list, see_list) {
    625  1.45   xtraeme 		workqueue_enqueue(sme->sme_wq, &see->see_wk, NULL);
    626  1.56  pgoyette 		see->see_edata->flags |= ENVSYS_FNEED_REFRESH;
    627  1.51   xtraeme 	}
    628  1.45   xtraeme 	if (sme->sme_events_timeout)
    629  1.45   xtraeme 		timo = sme->sme_events_timeout * hz;
    630  1.45   xtraeme 	else
    631  1.45   xtraeme 		timo = SME_EVTIMO;
    632  1.38   xtraeme 	if (!sysmon_low_power)
    633  1.45   xtraeme 		callout_schedule(&sme->sme_callout, timo);
    634  1.51   xtraeme 	mutex_exit(&sme->sme_callout_mtx);
    635   1.1   xtraeme }
    636   1.1   xtraeme 
    637   1.1   xtraeme /*
    638   1.1   xtraeme  * sme_events_worker:
    639   1.1   xtraeme  *
    640   1.1   xtraeme  * 	+ workqueue thread that checks if there's a critical condition
    641  1.51   xtraeme  * 	  and sends an event if it was triggered.
    642   1.1   xtraeme  */
    643   1.1   xtraeme void
    644   1.1   xtraeme sme_events_worker(struct work *wk, void *arg)
    645   1.1   xtraeme {
    646   1.1   xtraeme 	sme_event_t *see = (void *)wk;
    647  1.51   xtraeme 	struct sysmon_envsys *sme = see->see_sme;
    648  1.51   xtraeme 	envsys_data_t *edata = see->see_edata;
    649   1.1   xtraeme 
    650   1.1   xtraeme 	KASSERT(wk == &see->see_wk);
    651  1.51   xtraeme 	KASSERT(sme != NULL || edata != NULL);
    652   1.1   xtraeme 
    653  1.51   xtraeme 	mutex_enter(&sme->sme_mtx);
    654  1.86  pgoyette 	see->see_flags |= SEE_EVENT_WORKING;
    655   1.1   xtraeme 	/*
    656  1.65  pgoyette 	 * sme_events_check marks the sensors to make us refresh them here.
    657  1.65  pgoyette 	 * Don't refresh if the driver uses its own method for refreshing.
    658   1.1   xtraeme 	 */
    659  1.45   xtraeme 	if ((sme->sme_flags & SME_DISABLE_REFRESH) == 0) {
    660  1.65  pgoyette 		if ((edata->flags & ENVSYS_FNEED_REFRESH) != 0) {
    661  1.51   xtraeme 			/* refresh sensor in device */
    662  1.51   xtraeme 			(*sme->sme_refresh)(sme, edata);
    663  1.65  pgoyette 			edata->flags &= ~ENVSYS_FNEED_REFRESH;
    664  1.42   xtraeme 		}
    665   1.1   xtraeme 	}
    666   1.1   xtraeme 
    667  1.56  pgoyette 	DPRINTFOBJ(("%s: (%s) desc=%s sensor=%d type=%d state=%d units=%d "
    668  1.82  pgoyette 	    "value_cur=%d upropset=%d\n", __func__, sme->sme_name, edata->desc,
    669  1.56  pgoyette 	    edata->sensor, see->see_type, edata->state, edata->units,
    670  1.82  pgoyette 	    edata->value_cur, edata->upropset));
    671   1.1   xtraeme 
    672  1.50   xtraeme 	/* skip the event if current sensor is in invalid state */
    673  1.51   xtraeme 	if (edata->state == ENVSYS_SINVALID)
    674  1.50   xtraeme 		goto out;
    675  1.50   xtraeme 
    676  1.10   xtraeme 	/*
    677  1.67  pgoyette 	 * For range limits, if the driver claims responsibility for
    678  1.67  pgoyette 	 * limit/range checking, just user driver-supplied status.
    679  1.67  pgoyette 	 * Else calculate our own status.  Note that driver must
    680  1.67  pgoyette 	 * relinquish responsibility for ALL limits if there is even
    681  1.67  pgoyette 	 * one limit that it cannot handle!
    682  1.91  pgoyette 	 *
    683  1.91  pgoyette 	 * If this is a CAPACITY monitor, but the sensor's max_value
    684  1.91  pgoyette 	 * is not set, treat it as though the monitor does not exist.
    685  1.56  pgoyette 	 */
    686  1.86  pgoyette 	if ((see->see_type == PENVSYS_EVENT_LIMITS ||
    687  1.86  pgoyette 	     see->see_type == PENVSYS_EVENT_CAPACITY) &&
    688  1.86  pgoyette 	    (edata->upropset & PROP_DRIVER_LIMITS) == 0) {
    689  1.91  pgoyette 		if ((see->see_type == PENVSYS_EVENT_CAPACITY) &&
    690  1.91  pgoyette 		    (edata->value_max == 0))
    691  1.91  pgoyette 			edata->state = ENVSYS_SVALID;
    692  1.91  pgoyette 		else if ((edata->upropset & (PROP_CRITMIN | PROP_BATTCAP)) &&
    693  1.86  pgoyette 		    (edata->value_cur < edata->limits.sel_critmin))
    694  1.86  pgoyette 			edata->state = ENVSYS_SCRITUNDER;
    695  1.86  pgoyette 		else if ((edata->upropset & (PROP_WARNMIN | PROP_BATTWARN)) &&
    696  1.86  pgoyette 			 (edata->value_cur < edata->limits.sel_warnmin))
    697  1.86  pgoyette 			edata->state = ENVSYS_SWARNUNDER;
    698  1.86  pgoyette 		else if ((edata->upropset & (PROP_CRITMAX | PROP_BATTMAX)) &&
    699  1.86  pgoyette 			 (edata->value_cur > edata->limits.sel_critmax))
    700  1.86  pgoyette 			edata->state = ENVSYS_SCRITOVER;
    701  1.86  pgoyette 		else if ((edata->upropset & (PROP_WARNMAX | PROP_BATTHIGH)) &&
    702  1.86  pgoyette 			 (edata->value_cur > edata->limits.sel_warnmax))
    703  1.86  pgoyette 			edata->state = ENVSYS_SWARNOVER;
    704  1.86  pgoyette 		else
    705  1.86  pgoyette 			edata->state = ENVSYS_SVALID;
    706  1.86  pgoyette 	}
    707  1.86  pgoyette 	sme_deliver_event(see);
    708  1.86  pgoyette 
    709  1.86  pgoyette out:
    710  1.86  pgoyette 	see->see_flags &= ~SEE_EVENT_WORKING;
    711  1.86  pgoyette 	cv_broadcast(&sme->sme_condvar);
    712  1.86  pgoyette 	mutex_exit(&sme->sme_mtx);
    713  1.86  pgoyette }
    714  1.86  pgoyette 
    715  1.86  pgoyette /*
    716  1.87  pgoyette  * sysmon_envsys_sensor_event
    717  1.86  pgoyette  *
    718  1.86  pgoyette  *	+ Find the monitor event of a particular type for a given sensor
    719  1.89  pgoyette  *	  on a device and deliver the event if one is required.  If
    720  1.89  pgoyette  *	  no event type is specified, deliver all events for the sensor.
    721  1.86  pgoyette  */
    722  1.86  pgoyette void
    723  1.87  pgoyette sysmon_envsys_sensor_event(struct sysmon_envsys *sme, envsys_data_t *edata,
    724  1.87  pgoyette 			   int ev_type)
    725  1.86  pgoyette {
    726  1.86  pgoyette 	sme_event_t *see;
    727  1.86  pgoyette 
    728  1.86  pgoyette 	mutex_enter(&sme->sme_mtx);
    729  1.86  pgoyette 	LIST_FOREACH(see, &sme->sme_events_list, see_list) {
    730  1.89  pgoyette 		if (edata != see->see_edata)
    731  1.89  pgoyette 			continue;
    732  1.89  pgoyette 		if (ev_type == 0 ||
    733  1.89  pgoyette 		    ev_type == see->see_type) {
    734  1.89  pgoyette 			sme_deliver_event(see);
    735  1.89  pgoyette 			if (ev_type != 0)
    736  1.89  pgoyette 				break;
    737  1.89  pgoyette 		}
    738  1.86  pgoyette 	}
    739  1.86  pgoyette 	mutex_exit(&sme->sme_mtx);
    740  1.86  pgoyette }
    741  1.86  pgoyette 
    742  1.86  pgoyette /*
    743  1.86  pgoyette  * sme_deliver_event:
    744  1.86  pgoyette  *
    745  1.86  pgoyette  * 	+ If new sensor state requires it, send an event to powerd
    746  1.86  pgoyette  *
    747  1.86  pgoyette  *	  Must be called with the device's sysmon mutex held
    748  1.86  pgoyette  *		see->see_sme->sme_mtx
    749  1.86  pgoyette  */
    750  1.86  pgoyette void
    751  1.86  pgoyette sme_deliver_event(sme_event_t *see)
    752  1.86  pgoyette {
    753  1.86  pgoyette 	envsys_data_t *edata = see->see_edata;
    754  1.86  pgoyette 	const struct sme_description_table *sdt = NULL;
    755  1.86  pgoyette 	const struct sme_sensor_event *sse = sme_sensor_event;
    756  1.86  pgoyette 	int i, state = 0;
    757  1.86  pgoyette 
    758  1.86  pgoyette 	switch (see->see_type) {
    759  1.65  pgoyette 	case PENVSYS_EVENT_LIMITS:
    760  1.65  pgoyette 	case PENVSYS_EVENT_CAPACITY:
    761  1.67  pgoyette 		/*
    762  1.67  pgoyette 		 * Send event if state has changed
    763  1.67  pgoyette 		 */
    764  1.58  pgoyette 		if (edata->state == see->see_evsent)
    765  1.58  pgoyette 			break;
    766  1.56  pgoyette 
    767  1.58  pgoyette 		for (i = 0; sse[i].state != -1; i++)
    768  1.58  pgoyette 			if (sse[i].state == edata->state)
    769  1.10   xtraeme 				break;
    770   1.1   xtraeme 
    771  1.58  pgoyette 		if (sse[i].state == -1)
    772  1.58  pgoyette 			break;
    773  1.58  pgoyette 
    774  1.58  pgoyette 		if (edata->state == ENVSYS_SVALID)
    775  1.58  pgoyette 			sysmon_penvsys_event(&see->see_pes,
    776  1.58  pgoyette 					     PENVSYS_EVENT_NORMAL);
    777  1.58  pgoyette 		else
    778  1.58  pgoyette 			sysmon_penvsys_event(&see->see_pes, sse[i].event);
    779  1.58  pgoyette 
    780  1.58  pgoyette 		see->see_evsent = edata->state;
    781  1.83  pgoyette 		DPRINTFOBJ(("%s: (%s) desc=%s sensor=%d state=%d send_ev=%d\n",
    782  1.94  pgoyette 		    __func__, see->see_sme->sme_name, edata->desc,
    783  1.94  pgoyette 		    edata->sensor, edata->state,
    784  1.83  pgoyette 		    (edata->state == ENVSYS_SVALID) ? PENVSYS_EVENT_NORMAL :
    785  1.83  pgoyette 			sse[i].event));
    786  1.58  pgoyette 
    787  1.58  pgoyette 		break;
    788   1.1   xtraeme 
    789  1.58  pgoyette 	/*
    790  1.59  pgoyette 	 * Send PENVSYS_EVENT_CRITICAL event if:
    791  1.59  pgoyette 	 *	State has gone from non-CRITICAL to CRITICAL,
    792  1.59  pgoyette 	 *	State remains CRITICAL and value has changed, or
    793  1.59  pgoyette 	 *	State has returned from CRITICAL to non-CRITICAL
    794  1.58  pgoyette 	 */
    795  1.58  pgoyette 	case PENVSYS_EVENT_CRITICAL:
    796  1.59  pgoyette 		if (edata->state == ENVSYS_SVALID &&
    797  1.59  pgoyette 		    see->see_evsent != 0) {
    798  1.58  pgoyette 			sysmon_penvsys_event(&see->see_pes,
    799  1.58  pgoyette 					     PENVSYS_EVENT_NORMAL);
    800  1.59  pgoyette 			see->see_evsent = 0;
    801  1.59  pgoyette 		} else if (edata->state == ENVSYS_SCRITICAL &&
    802  1.59  pgoyette 		    see->see_evsent != edata->value_cur) {
    803  1.58  pgoyette 			sysmon_penvsys_event(&see->see_pes,
    804  1.58  pgoyette 					     PENVSYS_EVENT_CRITICAL);
    805  1.60  pgoyette 			see->see_evsent = edata->value_cur;
    806  1.56  pgoyette 		}
    807   1.1   xtraeme 		break;
    808   1.1   xtraeme 
    809  1.10   xtraeme 	/*
    810  1.28   xtraeme 	 * if value_cur is not normal (battery) or online (drive),
    811  1.28   xtraeme 	 * send the event...
    812  1.10   xtraeme 	 */
    813  1.28   xtraeme 	case PENVSYS_EVENT_STATE_CHANGED:
    814  1.45   xtraeme 		/*
    815  1.45   xtraeme 		 * the state has not been changed, just ignore the event.
    816  1.45   xtraeme 		 */
    817  1.51   xtraeme 		if (edata->value_cur == see->see_evsent)
    818   1.1   xtraeme 			break;
    819   1.1   xtraeme 
    820  1.51   xtraeme 		switch (edata->units) {
    821  1.28   xtraeme 		case ENVSYS_DRIVE:
    822  1.28   xtraeme 			sdt = sme_get_description_table(SME_DESC_DRIVE_STATES);
    823  1.28   xtraeme 			state = ENVSYS_DRIVE_ONLINE;
    824  1.28   xtraeme 			break;
    825  1.44   xtraeme 		case ENVSYS_BATTERY_CAPACITY:
    826  1.51   xtraeme 			sdt = sme_get_description_table(
    827  1.51   xtraeme 			    SME_DESC_BATTERY_CAPACITY);
    828  1.44   xtraeme 			state = ENVSYS_BATTERY_CAPACITY_NORMAL;
    829  1.28   xtraeme 			break;
    830  1.34   xtraeme 		default:
    831  1.65  pgoyette 			panic("%s: bad units for PENVSYS_EVENT_STATE_CHANGED",
    832  1.35   xtraeme 			    __func__);
    833  1.28   xtraeme 		}
    834  1.28   xtraeme 
    835  1.28   xtraeme 		for (i = 0; sdt[i].type != -1; i++)
    836  1.51   xtraeme 			if (sdt[i].type == edata->value_cur)
    837   1.1   xtraeme 				break;
    838   1.1   xtraeme 
    839  1.51   xtraeme 		if (sdt[i].type == -1)
    840  1.51   xtraeme 			break;
    841  1.51   xtraeme 
    842  1.45   xtraeme 		/*
    843  1.45   xtraeme 		 * copy current state description.
    844  1.45   xtraeme 		 */
    845  1.45   xtraeme 		(void)strlcpy(see->see_pes.pes_statedesc, sdt[i].desc,
    846  1.45   xtraeme 		    sizeof(see->see_pes.pes_statedesc));
    847   1.1   xtraeme 
    848  1.65  pgoyette 		if (edata->value_cur == state)
    849  1.65  pgoyette 			/*
    850  1.65  pgoyette 			 * state returned to normal condition
    851  1.65  pgoyette 			 */
    852  1.56  pgoyette 			sysmon_penvsys_event(&see->see_pes,
    853  1.56  pgoyette 					     PENVSYS_EVENT_NORMAL);
    854  1.65  pgoyette 		else
    855  1.65  pgoyette 			/*
    856  1.65  pgoyette 			 * state changed to abnormal condition
    857  1.45   xtraeme 			 */
    858  1.45   xtraeme 			sysmon_penvsys_event(&see->see_pes, see->see_type);
    859  1.65  pgoyette 
    860  1.65  pgoyette 		see->see_evsent = edata->value_cur;
    861   1.1   xtraeme 
    862  1.49   xtraeme 		/*
    863  1.49   xtraeme 		 * There's no need to continue if it's a drive sensor.
    864  1.49   xtraeme 		 */
    865  1.51   xtraeme 		if (edata->units == ENVSYS_DRIVE)
    866  1.49   xtraeme 			break;
    867  1.49   xtraeme 
    868  1.39   xtraeme 		/*
    869  1.39   xtraeme 		 * Check if the system is running in low power and send the
    870  1.39   xtraeme 		 * event to powerd (if running) or shutdown the system
    871  1.39   xtraeme 		 * otherwise.
    872  1.39   xtraeme 		 */
    873  1.39   xtraeme 		if (!sysmon_low_power && sme_event_check_low_power()) {
    874  1.39   xtraeme 			struct penvsys_state pes;
    875  1.39   xtraeme 
    876  1.45   xtraeme 			/*
    877  1.45   xtraeme 			 * Stop the callout and send the 'low-power' event.
    878  1.45   xtraeme 			 */
    879  1.45   xtraeme 			sysmon_low_power = true;
    880  1.86  pgoyette 			callout_stop(&see->see_sme->sme_callout);
    881  1.39   xtraeme 			pes.pes_type = PENVSYS_TYPE_BATTERY;
    882  1.39   xtraeme 			sysmon_penvsys_event(&pes, PENVSYS_EVENT_LOW_POWER);
    883  1.39   xtraeme 		}
    884   1.1   xtraeme 		break;
    885  1.56  pgoyette 	default:
    886  1.56  pgoyette 		panic("%s: invalid event type %d", __func__, see->see_type);
    887   1.1   xtraeme 	}
    888   1.1   xtraeme }
    889  1.38   xtraeme 
    890  1.47   xtraeme /*
    891  1.51   xtraeme  * Returns true if the system is in low power state: an AC adapter
    892  1.51   xtraeme  * is OFF and all batteries are in LOW/CRITICAL state.
    893  1.47   xtraeme  */
    894  1.44   xtraeme static bool
    895  1.38   xtraeme sme_event_check_low_power(void)
    896  1.38   xtraeme {
    897  1.47   xtraeme 	if (!sme_acadapter_check())
    898  1.47   xtraeme 		return false;
    899  1.47   xtraeme 
    900  1.47   xtraeme 	return sme_battery_check();
    901  1.47   xtraeme }
    902  1.47   xtraeme 
    903  1.51   xtraeme /*
    904  1.51   xtraeme  * Called with the sysmon_envsys device mtx held through the
    905  1.51   xtraeme  * workqueue thread.
    906  1.51   xtraeme  */
    907  1.47   xtraeme static bool
    908  1.47   xtraeme sme_acadapter_check(void)
    909  1.47   xtraeme {
    910  1.38   xtraeme 	struct sysmon_envsys *sme;
    911  1.38   xtraeme 	envsys_data_t *edata;
    912  1.50   xtraeme 	bool dev = false, sensor = false;
    913  1.38   xtraeme 
    914  1.50   xtraeme 	LIST_FOREACH(sme, &sysmon_envsys_list, sme_list) {
    915  1.50   xtraeme 		if (sme->sme_class == SME_CLASS_ACADAPTER) {
    916  1.50   xtraeme 			dev = true;
    917  1.38   xtraeme 			break;
    918  1.50   xtraeme 		}
    919  1.50   xtraeme 	}
    920  1.51   xtraeme 
    921  1.38   xtraeme 	/*
    922  1.47   xtraeme 	 * No AC Adapter devices were found.
    923  1.38   xtraeme 	 */
    924  1.50   xtraeme 	if (!dev)
    925  1.44   xtraeme 		return false;
    926  1.51   xtraeme 
    927  1.44   xtraeme 	/*
    928  1.47   xtraeme 	 * Check if there's an AC adapter device connected.
    929  1.44   xtraeme 	 */
    930  1.45   xtraeme 	TAILQ_FOREACH(edata, &sme->sme_sensors_list, sensors_head) {
    931  1.38   xtraeme 		if (edata->units == ENVSYS_INDICATOR) {
    932  1.47   xtraeme 			sensor = true;
    933  1.50   xtraeme 			/* refresh current sensor */
    934  1.78  pgoyette 			if ((sme->sme_flags & SME_DISABLE_REFRESH) == 0)
    935  1.78  pgoyette 				(*sme->sme_refresh)(sme, edata);
    936  1.44   xtraeme 			if (edata->value_cur)
    937  1.44   xtraeme 				return false;
    938  1.38   xtraeme 		}
    939  1.38   xtraeme 	}
    940  1.51   xtraeme 
    941  1.47   xtraeme 	if (!sensor)
    942  1.47   xtraeme 		return false;
    943  1.47   xtraeme 
    944  1.51   xtraeme 	/*
    945  1.51   xtraeme 	 * AC adapter found and not connected.
    946  1.51   xtraeme 	 */
    947  1.47   xtraeme 	return true;
    948  1.47   xtraeme }
    949  1.47   xtraeme 
    950  1.51   xtraeme /*
    951  1.51   xtraeme  * Called with the sysmon_envsys device mtx held through the
    952  1.51   xtraeme  * workqueue thread.
    953  1.51   xtraeme  */
    954  1.47   xtraeme static bool
    955  1.47   xtraeme sme_battery_check(void)
    956  1.47   xtraeme {
    957  1.47   xtraeme 	struct sysmon_envsys *sme;
    958  1.47   xtraeme 	envsys_data_t *edata;
    959  1.55  drochner 	int batteriesfound = 0;
    960  1.55  drochner 	bool present, batterycap, batterycharge;
    961  1.44   xtraeme 
    962  1.38   xtraeme 	/*
    963  1.44   xtraeme 	 * Check for battery devices and its state.
    964  1.38   xtraeme 	 */
    965  1.44   xtraeme 	LIST_FOREACH(sme, &sysmon_envsys_list, sme_list) {
    966  1.44   xtraeme 		if (sme->sme_class != SME_CLASS_BATTERY)
    967  1.44   xtraeme 			continue;
    968  1.38   xtraeme 
    969  1.55  drochner 		present = true;
    970  1.55  drochner 		TAILQ_FOREACH(edata, &sme->sme_sensors_list, sensors_head) {
    971  1.55  drochner 			if (edata->units == ENVSYS_INDICATOR &&
    972  1.55  drochner 			    !edata->value_cur) {
    973  1.55  drochner 				present = false;
    974  1.55  drochner 				break;
    975  1.55  drochner 			}
    976  1.55  drochner 		}
    977  1.55  drochner 		if (!present)
    978  1.55  drochner 			continue;
    979  1.44   xtraeme 		/*
    980  1.44   xtraeme 		 * We've found a battery device...
    981  1.44   xtraeme 		 */
    982  1.55  drochner 		batteriesfound++;
    983  1.55  drochner 		batterycap = batterycharge = false;
    984  1.45   xtraeme 		TAILQ_FOREACH(edata, &sme->sme_sensors_list, sensors_head) {
    985  1.44   xtraeme 			if (edata->units == ENVSYS_BATTERY_CAPACITY) {
    986  1.44   xtraeme 				batterycap = true;
    987  1.44   xtraeme 				if (!sme_battery_critical(edata))
    988  1.44   xtraeme 					return false;
    989  1.44   xtraeme 			} else if (edata->units == ENVSYS_BATTERY_CHARGE) {
    990  1.44   xtraeme 				batterycharge = true;
    991  1.44   xtraeme 				if (edata->value_cur)
    992  1.44   xtraeme 					return false;
    993  1.38   xtraeme 			}
    994  1.38   xtraeme 		}
    995  1.55  drochner 		if (!batterycap || !batterycharge)
    996  1.55  drochner 			return false;
    997  1.38   xtraeme 	}
    998  1.51   xtraeme 
    999  1.55  drochner 	if (!batteriesfound)
   1000  1.44   xtraeme 		return false;
   1001  1.38   xtraeme 
   1002  1.38   xtraeme 	/*
   1003  1.44   xtraeme 	 * All batteries in low/critical capacity and discharging.
   1004  1.38   xtraeme 	 */
   1005  1.44   xtraeme 	return true;
   1006  1.44   xtraeme }
   1007  1.38   xtraeme 
   1008  1.44   xtraeme static bool
   1009  1.44   xtraeme sme_battery_critical(envsys_data_t *edata)
   1010  1.44   xtraeme {
   1011  1.44   xtraeme 	if (edata->value_cur == ENVSYS_BATTERY_CAPACITY_CRITICAL ||
   1012  1.44   xtraeme 	    edata->value_cur == ENVSYS_BATTERY_CAPACITY_LOW)
   1013  1.44   xtraeme 		return true;
   1014  1.44   xtraeme 
   1015  1.44   xtraeme 	return false;
   1016  1.38   xtraeme }
   1017