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