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