sysmon_envsys.c revision 1.36 1 1.36 xtraeme /* $NetBSD: sysmon_envsys.c,v 1.36 2007/07/21 15:30:04 xtraeme Exp $ */
2 1.18 xtraeme
3 1.18 xtraeme /*-
4 1.18 xtraeme * Copyright (c) 2007 The NetBSD Foundation, Inc.
5 1.18 xtraeme * All rights reserved.
6 1.18 xtraeme *
7 1.18 xtraeme * This code is derived from software contributed to The NetBSD Foundation
8 1.18 xtraeme * by Juan Romero Pardines.
9 1.18 xtraeme *
10 1.18 xtraeme * Redistribution and use in source and binary forms, with or without
11 1.18 xtraeme * modification, are permitted provided that the following conditions
12 1.18 xtraeme * are met:
13 1.18 xtraeme * 1. Redistributions of source code must retain the above copyright
14 1.18 xtraeme * notice, this list of conditions and the following disclaimer.
15 1.18 xtraeme * 2. Redistributions in binary form must reproduce the above copyright
16 1.18 xtraeme * notice, this list of conditions and the following disclaimer in the
17 1.18 xtraeme * documentation and/or other materials provided with the distribution.
18 1.18 xtraeme * 3. All advertising materials mentioning features or use of this software
19 1.18 xtraeme * must display the following acknowledgement:
20 1.18 xtraeme * This product includes software developed by Juan Romero Pardines
21 1.18 xtraeme * for the NetBSD Foundation, Inc. and its contributors.
22 1.18 xtraeme * 4. Neither the name of The NetBSD Foundation nor the names of its
23 1.18 xtraeme * contributors may be used to endorse or promote products derived
24 1.18 xtraeme * from this software without specific prior written permission.
25 1.18 xtraeme *
26 1.18 xtraeme * THIS SOFTWARE IS PROVIDED BY THE NETBSD FOUNDATION, INC. AND CONTRIBUTORS
27 1.18 xtraeme * ``AS IS'' AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED
28 1.18 xtraeme * TO, THE IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR
29 1.18 xtraeme * PURPOSE ARE DISCLAIMED. IN NO EVENT SHALL THE FOUNDATION OR CONTRIBUTORS
30 1.18 xtraeme * BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR
31 1.18 xtraeme * CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF
32 1.18 xtraeme * SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS
33 1.18 xtraeme * INTERRUPTION) HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN
34 1.18 xtraeme * CONTRACT, STRICT LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE)
35 1.18 xtraeme * ARISING IN ANY WAY OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE
36 1.18 xtraeme * POSSIBILITY OF SUCH DAMAGE.
37 1.18 xtraeme */
38 1.1 thorpej
39 1.1 thorpej /*-
40 1.1 thorpej * Copyright (c) 2000 Zembu Labs, Inc.
41 1.1 thorpej * All rights reserved.
42 1.1 thorpej *
43 1.1 thorpej * Author: Jason R. Thorpe <thorpej (at) zembu.com>
44 1.1 thorpej *
45 1.1 thorpej * Redistribution and use in source and binary forms, with or without
46 1.1 thorpej * modification, are permitted provided that the following conditions
47 1.1 thorpej * are met:
48 1.1 thorpej * 1. Redistributions of source code must retain the above copyright
49 1.1 thorpej * notice, this list of conditions and the following disclaimer.
50 1.1 thorpej * 2. Redistributions in binary form must reproduce the above copyright
51 1.1 thorpej * notice, this list of conditions and the following disclaimer in the
52 1.1 thorpej * documentation and/or other materials provided with the distribution.
53 1.1 thorpej * 3. All advertising materials mentioning features or use of this software
54 1.1 thorpej * must display the following acknowledgement:
55 1.1 thorpej * This product includes software developed by Zembu Labs, Inc.
56 1.1 thorpej * 4. Neither the name of Zembu Labs nor the names of its employees may
57 1.1 thorpej * be used to endorse or promote products derived from this software
58 1.1 thorpej * without specific prior written permission.
59 1.1 thorpej *
60 1.1 thorpej * THIS SOFTWARE IS PROVIDED BY ZEMBU LABS, INC. ``AS IS'' AND ANY EXPRESS
61 1.1 thorpej * OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE IMPLIED WAR-
62 1.1 thorpej * RANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE ARE DIS-
63 1.1 thorpej * CLAIMED. IN NO EVENT SHALL ZEMBU LABS BE LIABLE FOR ANY DIRECT, INDIRECT,
64 1.1 thorpej * INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT
65 1.1 thorpej * NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE,
66 1.1 thorpej * DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY
67 1.1 thorpej * THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT
68 1.1 thorpej * (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE OF
69 1.1 thorpej * THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.
70 1.1 thorpej */
71 1.1 thorpej
72 1.1 thorpej /*
73 1.18 xtraeme * Environmental sensor framework for sysmon, exported to userland
74 1.18 xtraeme * with proplib(3).
75 1.1 thorpej */
76 1.2 lukem
77 1.2 lukem #include <sys/cdefs.h>
78 1.36 xtraeme __KERNEL_RCSID(0, "$NetBSD: sysmon_envsys.c,v 1.36 2007/07/21 15:30:04 xtraeme Exp $");
79 1.1 thorpej
80 1.1 thorpej #include <sys/param.h>
81 1.18 xtraeme #include <sys/types.h>
82 1.1 thorpej #include <sys/conf.h>
83 1.1 thorpej #include <sys/errno.h>
84 1.22 xtraeme #include <sys/fcntl.h>
85 1.1 thorpej #include <sys/kernel.h>
86 1.1 thorpej #include <sys/systm.h>
87 1.1 thorpej #include <sys/proc.h>
88 1.18 xtraeme #include <sys/mutex.h>
89 1.18 xtraeme #include <sys/kmem.h>
90 1.1 thorpej
91 1.1 thorpej #include <dev/sysmon/sysmonvar.h>
92 1.18 xtraeme #include <dev/sysmon/sysmon_envsysvar.h>
93 1.18 xtraeme #include <dev/sysmon/sysmon_taskq.h>
94 1.1 thorpej
95 1.18 xtraeme #include "opt_compat_netbsd.h"
96 1.1 thorpej
97 1.18 xtraeme struct sme_sensor_type {
98 1.18 xtraeme int type;
99 1.18 xtraeme int crittype;
100 1.18 xtraeme const char *desc;
101 1.18 xtraeme };
102 1.18 xtraeme
103 1.18 xtraeme static const struct sme_sensor_type sme_sensor_type[] = {
104 1.18 xtraeme { ENVSYS_STEMP, PENVSYS_TYPE_TEMP, "Temperature" },
105 1.18 xtraeme { ENVSYS_SFANRPM, PENVSYS_TYPE_FAN, "Fan" },
106 1.18 xtraeme { ENVSYS_SVOLTS_AC, PENVSYS_TYPE_VOLTAGE, "Voltage AC" },
107 1.18 xtraeme { ENVSYS_SVOLTS_DC, PENVSYS_TYPE_VOLTAGE, "Voltage DC" },
108 1.18 xtraeme { ENVSYS_SOHMS, PENVSYS_TYPE_RESISTANCE,"Ohms" },
109 1.18 xtraeme { ENVSYS_SWATTS, PENVSYS_TYPE_POWER, "Watts" },
110 1.18 xtraeme { ENVSYS_SAMPS, PENVSYS_TYPE_POWER, "Ampere" },
111 1.18 xtraeme { ENVSYS_SWATTHOUR, PENVSYS_TYPE_BATTERY, "Watt hour" },
112 1.18 xtraeme { ENVSYS_SAMPHOUR, PENVSYS_TYPE_BATTERY, "Ampere hour" },
113 1.19 xtraeme { ENVSYS_INDICATOR, PENVSYS_TYPE_INDICATOR, "Indicator" },
114 1.21 xtraeme { ENVSYS_INTEGER, PENVSYS_TYPE_INDICATOR, "Integer" },
115 1.18 xtraeme { ENVSYS_DRIVE, PENVSYS_TYPE_DRIVE, "Drive" },
116 1.18 xtraeme { -1, -1, NULL }
117 1.18 xtraeme };
118 1.18 xtraeme
119 1.18 xtraeme struct sme_sensor_state {
120 1.18 xtraeme int type;
121 1.18 xtraeme const char *desc;
122 1.18 xtraeme };
123 1.18 xtraeme
124 1.18 xtraeme static const struct sme_sensor_state sme_sensor_state[] = {
125 1.18 xtraeme { ENVSYS_SVALID, "valid" },
126 1.18 xtraeme { ENVSYS_SINVALID, "invalid" },
127 1.18 xtraeme { ENVSYS_SCRITICAL, "critical" },
128 1.18 xtraeme { ENVSYS_SCRITUNDER, "critical-under" },
129 1.18 xtraeme { ENVSYS_SCRITOVER, "critical-over" },
130 1.18 xtraeme { ENVSYS_SWARNUNDER, "warning-under" },
131 1.18 xtraeme { ENVSYS_SWARNOVER, "warning-over" },
132 1.18 xtraeme { -1, "unknown" }
133 1.18 xtraeme };
134 1.18 xtraeme
135 1.18 xtraeme static const struct sme_sensor_state sme_sensor_drive_state[] = {
136 1.18 xtraeme { ENVSYS_DRIVE_EMPTY, "drive state is unknown" },
137 1.18 xtraeme { ENVSYS_DRIVE_READY, "drive is ready" },
138 1.18 xtraeme { ENVSYS_DRIVE_POWERUP, "drive is powering up" },
139 1.18 xtraeme { ENVSYS_DRIVE_ONLINE, "drive is online" },
140 1.18 xtraeme { ENVSYS_DRIVE_IDLE, "drive is idle" },
141 1.18 xtraeme { ENVSYS_DRIVE_ACTIVE, "drive is active" },
142 1.18 xtraeme { ENVSYS_DRIVE_REBUILD, "drive is rebuilding" },
143 1.18 xtraeme { ENVSYS_DRIVE_POWERDOWN, "drive is powering down" },
144 1.18 xtraeme { ENVSYS_DRIVE_FAIL, "drive failed" },
145 1.18 xtraeme { ENVSYS_DRIVE_PFAIL, "drive degraded" },
146 1.18 xtraeme { -1, "unknown" }
147 1.18 xtraeme };
148 1.18 xtraeme
149 1.27 xtraeme struct sme_sensor_names {
150 1.27 xtraeme SLIST_ENTRY(sme_sensor_names) sme_names;
151 1.27 xtraeme int assigned;
152 1.27 xtraeme char desc[ENVSYS_DESCLEN];
153 1.27 xtraeme };
154 1.27 xtraeme
155 1.27 xtraeme static SLIST_HEAD(, sme_sensor_names) sme_names_list;
156 1.18 xtraeme static prop_dictionary_t sme_propd;
157 1.18 xtraeme static kmutex_t sme_list_mtx;
158 1.18 xtraeme static kcondvar_t sme_list_cv;
159 1.18 xtraeme
160 1.18 xtraeme #ifdef COMPAT_40
161 1.18 xtraeme static u_int sysmon_envsys_next_sensor_index = 0;
162 1.18 xtraeme static struct sysmon_envsys *sysmon_envsys_find_40(u_int);
163 1.18 xtraeme #endif
164 1.1 thorpej
165 1.18 xtraeme static void sysmon_envsys_release(struct sysmon_envsys *);
166 1.1 thorpej
167 1.18 xtraeme kmutex_t sme_mtx, sme_event_mtx;
168 1.26 xtraeme kcondvar_t sme_event_cv;
169 1.16 ad
170 1.18 xtraeme /*
171 1.18 xtraeme * sysmon_envsys_init:
172 1.18 xtraeme *
173 1.18 xtraeme * + Initialize global mutexes, dictionary and the linked lists.
174 1.18 xtraeme */
175 1.18 xtraeme void
176 1.18 xtraeme sysmon_envsys_init(void)
177 1.18 xtraeme {
178 1.18 xtraeme LIST_INIT(&sysmon_envsys_list);
179 1.18 xtraeme LIST_INIT(&sme_events_list);
180 1.18 xtraeme mutex_init(&sme_mtx, MUTEX_DRIVER, IPL_NONE);
181 1.18 xtraeme mutex_init(&sme_list_mtx, MUTEX_DRIVER, IPL_NONE);
182 1.18 xtraeme mutex_init(&sme_event_mtx, MUTEX_DRIVER, IPL_NONE);
183 1.18 xtraeme mutex_init(&sme_event_init_mtx, MUTEX_DRIVER, IPL_NONE);
184 1.18 xtraeme cv_init(&sme_list_cv, "smefind");
185 1.26 xtraeme cv_init(&sme_event_cv, "smeevent");
186 1.18 xtraeme sme_propd = prop_dictionary_create();
187 1.18 xtraeme }
188 1.1 thorpej
189 1.1 thorpej /*
190 1.1 thorpej * sysmonopen_envsys:
191 1.1 thorpej *
192 1.18 xtraeme * + Open the system monitor device.
193 1.1 thorpej */
194 1.1 thorpej int
195 1.18 xtraeme sysmonopen_envsys(dev_t dev, int flag, int mode, struct lwp *l)
196 1.1 thorpej {
197 1.18 xtraeme return 0;
198 1.1 thorpej }
199 1.1 thorpej
200 1.1 thorpej /*
201 1.1 thorpej * sysmonclose_envsys:
202 1.1 thorpej *
203 1.18 xtraeme * + Close the system monitor device.
204 1.1 thorpej */
205 1.1 thorpej int
206 1.18 xtraeme sysmonclose_envsys(dev_t dev, int flag, int mode, struct lwp *l)
207 1.1 thorpej {
208 1.3 jdolecek /* Nothing to do */
209 1.18 xtraeme return 0;
210 1.1 thorpej }
211 1.1 thorpej
212 1.1 thorpej /*
213 1.1 thorpej * sysmonioctl_envsys:
214 1.1 thorpej *
215 1.18 xtraeme * + Perform an envsys control request.
216 1.1 thorpej */
217 1.1 thorpej int
218 1.18 xtraeme sysmonioctl_envsys(dev_t dev, u_long cmd, void *data, int flag, struct lwp *l)
219 1.1 thorpej {
220 1.18 xtraeme struct sysmon_envsys *sme = NULL;
221 1.1 thorpej int error = 0;
222 1.18 xtraeme #ifdef COMPAT_40
223 1.1 thorpej u_int oidx;
224 1.18 xtraeme #endif
225 1.1 thorpej
226 1.1 thorpej switch (cmd) {
227 1.18 xtraeme case ENVSYS_GETDICTIONARY:
228 1.18 xtraeme {
229 1.18 xtraeme struct plistref *plist = (struct plistref *)data;
230 1.18 xtraeme
231 1.18 xtraeme /*
232 1.18 xtraeme * Update all sysmon envsys devices dictionaries with
233 1.18 xtraeme * new data if it's different than we have currently
234 1.18 xtraeme * in the dictionary.
235 1.18 xtraeme */
236 1.18 xtraeme mutex_enter(&sme_mtx);
237 1.18 xtraeme LIST_FOREACH(sme, &sysmon_envsys_list, sme_list) {
238 1.18 xtraeme if (sme == NULL)
239 1.18 xtraeme continue;
240 1.18 xtraeme
241 1.18 xtraeme error = sme_update_dictionary(sme);
242 1.18 xtraeme if (error) {
243 1.18 xtraeme DPRINTF(("%s: sme_update_dictionary, "
244 1.18 xtraeme "error=%d\n", __func__, error));
245 1.18 xtraeme mutex_exit(&sme_mtx);
246 1.18 xtraeme return error;
247 1.18 xtraeme }
248 1.18 xtraeme }
249 1.18 xtraeme mutex_exit(&sme_mtx);
250 1.18 xtraeme /*
251 1.18 xtraeme * Copy global dictionary to userland.
252 1.18 xtraeme */
253 1.18 xtraeme error = prop_dictionary_copyout_ioctl(plist, cmd, sme_propd);
254 1.1 thorpej break;
255 1.18 xtraeme }
256 1.18 xtraeme case ENVSYS_SETDICTIONARY:
257 1.1 thorpej {
258 1.18 xtraeme const struct plistref *plist = (const struct plistref *)data;
259 1.18 xtraeme prop_dictionary_t udict;
260 1.18 xtraeme prop_object_t obj;
261 1.18 xtraeme const char *devname = NULL;
262 1.18 xtraeme
263 1.22 xtraeme if ((flag & FWRITE) == 0)
264 1.22 xtraeme return EPERM;
265 1.22 xtraeme
266 1.18 xtraeme /*
267 1.18 xtraeme * Get dictionary from userland.
268 1.18 xtraeme */
269 1.18 xtraeme error = prop_dictionary_copyin_ioctl(plist, cmd, &udict);
270 1.18 xtraeme DPRINTF(("%s: copyin_ioctl error=%d\n", __func__, error));
271 1.18 xtraeme if (error)
272 1.18 xtraeme break;
273 1.4 explorer
274 1.18 xtraeme /*
275 1.18 xtraeme * Parse "driver-name" key to obtain the driver we
276 1.18 xtraeme * are searching for.
277 1.18 xtraeme */
278 1.18 xtraeme obj = prop_dictionary_get(udict, "driver-name");
279 1.18 xtraeme if (obj == NULL || prop_object_type(obj) != PROP_TYPE_STRING) {
280 1.18 xtraeme DPRINTF(("%s: driver-name failed\n", __func__));
281 1.18 xtraeme prop_object_release(udict);
282 1.18 xtraeme error = EINVAL;
283 1.18 xtraeme break;
284 1.18 xtraeme }
285 1.4 explorer
286 1.18 xtraeme /* driver name */
287 1.18 xtraeme devname = prop_string_cstring_nocopy(obj);
288 1.4 explorer
289 1.18 xtraeme /* find the correct sme device */
290 1.18 xtraeme sme = sysmon_envsys_find(devname);
291 1.18 xtraeme if (sme == NULL) {
292 1.18 xtraeme DPRINTF(("%s: NULL sme\n", __func__));
293 1.18 xtraeme prop_object_release(udict);
294 1.18 xtraeme error = EINVAL;
295 1.4 explorer break;
296 1.4 explorer }
297 1.1 thorpej
298 1.18 xtraeme /*
299 1.18 xtraeme * Find the correct array object with the string supplied
300 1.18 xtraeme * by the userland dictionary.
301 1.18 xtraeme */
302 1.18 xtraeme obj = prop_dictionary_get(sme_propd, devname);
303 1.18 xtraeme if (prop_object_type(obj) != PROP_TYPE_ARRAY) {
304 1.18 xtraeme DPRINTF(("%s: array device failed\n", __func__));
305 1.18 xtraeme prop_object_release(udict);
306 1.18 xtraeme error = EINVAL;
307 1.1 thorpej break;
308 1.1 thorpej }
309 1.18 xtraeme
310 1.18 xtraeme /* do the real work now */
311 1.18 xtraeme error = sme_userset_dictionary(sme, udict, obj);
312 1.1 thorpej sysmon_envsys_release(sme);
313 1.1 thorpej break;
314 1.1 thorpej }
315 1.18 xtraeme /*
316 1.18 xtraeme * Compatibility functions with the old interface, only
317 1.18 xtraeme * implemented ENVSYS_GTREDATA and ENVSYS_GTREINFO; enough
318 1.18 xtraeme * to make old applications work.
319 1.18 xtraeme */
320 1.18 xtraeme #ifdef COMPAT_40
321 1.1 thorpej case ENVSYS_GTREDATA:
322 1.1 thorpej {
323 1.18 xtraeme struct envsys_tre_data *tred = (void *)data;
324 1.18 xtraeme envsys_data_t *edata = NULL;
325 1.1 thorpej
326 1.1 thorpej tred->validflags = 0;
327 1.1 thorpej
328 1.18 xtraeme sme = sysmon_envsys_find_40(tred->sensor);
329 1.1 thorpej if (sme == NULL)
330 1.1 thorpej break;
331 1.18 xtraeme
332 1.18 xtraeme mutex_enter(&sme_mtx);
333 1.1 thorpej oidx = tred->sensor;
334 1.1 thorpej tred->sensor = SME_SENSOR_IDX(sme, tred->sensor);
335 1.18 xtraeme
336 1.18 xtraeme DPRINTFOBJ(("%s: sensor=%d oidx=%d dev=%s nsensors=%d\n",
337 1.18 xtraeme __func__, tred->sensor, oidx, sme->sme_name,
338 1.18 xtraeme sme->sme_nsensors));
339 1.18 xtraeme
340 1.18 xtraeme edata = &sme->sme_sensor_data[tred->sensor];
341 1.18 xtraeme
342 1.36 xtraeme if (edata->flags & ENVSYS_FDUPDESC) {
343 1.36 xtraeme tred->validflags &= ~ENVSYS_FCURVALID;
344 1.36 xtraeme tred->cur.data_s = tred->cur.data_us = 0;
345 1.36 xtraeme goto out;
346 1.36 xtraeme }
347 1.36 xtraeme
348 1.18 xtraeme if (tred->sensor < sme->sme_nsensors) {
349 1.18 xtraeme if ((sme->sme_flags & SME_DISABLE_GTREDATA) == 0) {
350 1.18 xtraeme error = (*sme->sme_gtredata)(sme, edata);
351 1.18 xtraeme if (error) {
352 1.18 xtraeme DPRINTF(("%s: sme_gtredata failed\n",
353 1.18 xtraeme __func__));
354 1.18 xtraeme mutex_exit(&sme_mtx);
355 1.18 xtraeme return error;
356 1.18 xtraeme }
357 1.18 xtraeme }
358 1.18 xtraeme
359 1.18 xtraeme /* copy required values to the old interface */
360 1.18 xtraeme tred->sensor = edata->sensor;
361 1.18 xtraeme tred->cur.data_us = edata->value_cur;
362 1.18 xtraeme tred->cur.data_s = edata->value_cur;
363 1.18 xtraeme tred->max.data_us = edata->value_max;
364 1.18 xtraeme tred->max.data_s = edata->value_max;
365 1.18 xtraeme tred->min.data_us = edata->value_min;
366 1.18 xtraeme tred->min.data_s = edata->value_min;
367 1.18 xtraeme tred->avg.data_us = edata->value_avg;
368 1.18 xtraeme tred->avg.data_s = edata->value_avg;
369 1.18 xtraeme tred->units = edata->units;
370 1.18 xtraeme
371 1.20 xtraeme tred->validflags |= ENVSYS_FVALID;
372 1.20 xtraeme tred->validflags |= ENVSYS_FCURVALID;
373 1.20 xtraeme
374 1.20 xtraeme if (edata->flags & ENVSYS_FPERCENT) {
375 1.20 xtraeme tred->validflags |= ENVSYS_FMAXVALID;
376 1.20 xtraeme tred->validflags |= ENVSYS_FFRACVALID;
377 1.20 xtraeme }
378 1.20 xtraeme
379 1.18 xtraeme if (edata->state == ENVSYS_SINVALID) {
380 1.20 xtraeme tred->validflags &= ~ENVSYS_FCURVALID;
381 1.18 xtraeme tred->cur.data_us = tred->cur.data_s = 0;
382 1.18 xtraeme }
383 1.18 xtraeme
384 1.18 xtraeme DPRINTFOBJ(("%s: sensor=%s tred->cur.data_s=%d\n",
385 1.18 xtraeme __func__, edata->desc, tred->cur.data_s));
386 1.18 xtraeme DPRINTFOBJ(("%s: tred->validflags=%d tred->units=%d"
387 1.18 xtraeme " tred->sensor=%d\n", __func__, tred->validflags,
388 1.18 xtraeme tred->units, tred->sensor));
389 1.3 jdolecek }
390 1.36 xtraeme
391 1.36 xtraeme out:
392 1.1 thorpej tred->sensor = oidx;
393 1.18 xtraeme mutex_exit(&sme_mtx);
394 1.1 thorpej
395 1.1 thorpej break;
396 1.1 thorpej }
397 1.1 thorpej case ENVSYS_GTREINFO:
398 1.1 thorpej {
399 1.18 xtraeme struct envsys_basic_info *binfo = (void *)data;
400 1.18 xtraeme envsys_data_t *edata = NULL;
401 1.1 thorpej
402 1.1 thorpej binfo->validflags = 0;
403 1.1 thorpej
404 1.18 xtraeme sme = sysmon_envsys_find_40(binfo->sensor);
405 1.1 thorpej if (sme == NULL)
406 1.1 thorpej break;
407 1.18 xtraeme
408 1.18 xtraeme mutex_enter(&sme_mtx);
409 1.1 thorpej oidx = binfo->sensor;
410 1.1 thorpej binfo->sensor = SME_SENSOR_IDX(sme, binfo->sensor);
411 1.18 xtraeme
412 1.18 xtraeme edata = &sme->sme_sensor_data[binfo->sensor];
413 1.18 xtraeme
414 1.20 xtraeme binfo->validflags |= ENVSYS_FVALID;
415 1.18 xtraeme
416 1.18 xtraeme if (binfo->sensor < sme->sme_nsensors) {
417 1.18 xtraeme binfo->units = edata->units;
418 1.18 xtraeme (void)strlcpy(binfo->desc, edata->desc,
419 1.18 xtraeme sizeof(binfo->desc));
420 1.18 xtraeme }
421 1.18 xtraeme
422 1.18 xtraeme DPRINTFOBJ(("%s: binfo->units=%d binfo->validflags=%d\n",
423 1.18 xtraeme __func__, binfo->units, binfo->validflags));
424 1.18 xtraeme DPRINTFOBJ(("%s: binfo->desc=%s binfo->sensor=%d\n",
425 1.18 xtraeme __func__, binfo->desc, binfo->sensor));
426 1.18 xtraeme
427 1.1 thorpej binfo->sensor = oidx;
428 1.18 xtraeme mutex_exit(&sme_mtx);
429 1.18 xtraeme
430 1.1 thorpej break;
431 1.1 thorpej }
432 1.18 xtraeme #endif /* COMPAT_40 */
433 1.1 thorpej default:
434 1.1 thorpej error = ENOTTY;
435 1.18 xtraeme break;
436 1.1 thorpej }
437 1.1 thorpej
438 1.18 xtraeme return error;
439 1.1 thorpej }
440 1.1 thorpej
441 1.1 thorpej /*
442 1.1 thorpej * sysmon_envsys_register:
443 1.1 thorpej *
444 1.18 xtraeme * + Register an envsys device.
445 1.18 xtraeme * + Create device dictionary.
446 1.1 thorpej */
447 1.1 thorpej int
448 1.1 thorpej sysmon_envsys_register(struct sysmon_envsys *sme)
449 1.1 thorpej {
450 1.18 xtraeme struct sysmon_envsys *lsme;
451 1.1 thorpej int error = 0;
452 1.1 thorpej
453 1.18 xtraeme /*
454 1.18 xtraeme * sanity check 1, make sure the driver has initialized
455 1.18 xtraeme * the sensors count or the value is not too high.
456 1.18 xtraeme */
457 1.18 xtraeme if (!sme->sme_nsensors || sme->sme_nsensors > ENVSYS_MAXSENSORS)
458 1.18 xtraeme return EINVAL;
459 1.18 xtraeme
460 1.18 xtraeme /*
461 1.18 xtraeme * sanity check 2, make sure that sme->sme_name and
462 1.18 xtraeme * sme->sme_data are not NULL.
463 1.18 xtraeme */
464 1.18 xtraeme if (sme->sme_name == NULL || sme->sme_sensor_data == NULL)
465 1.18 xtraeme return EINVAL;
466 1.1 thorpej
467 1.18 xtraeme /*
468 1.18 xtraeme * sanity check 3, if SME_DISABLE_GTREDATA is not set
469 1.18 xtraeme * the sme_gtredata function callback must be non NULL.
470 1.18 xtraeme */
471 1.18 xtraeme if ((sme->sme_flags & SME_DISABLE_GTREDATA) == 0) {
472 1.18 xtraeme if (sme->sme_gtredata == NULL)
473 1.18 xtraeme return EINVAL;
474 1.1 thorpej }
475 1.1 thorpej
476 1.18 xtraeme /*
477 1.18 xtraeme * - check if requested sysmon_envsys device is valid
478 1.18 xtraeme * and does not exist already in the list.
479 1.18 xtraeme * - add device into the list.
480 1.18 xtraeme * - create the plist structure.
481 1.18 xtraeme */
482 1.18 xtraeme mutex_enter(&sme_list_mtx);
483 1.18 xtraeme LIST_FOREACH(lsme, &sysmon_envsys_list, sme_list) {
484 1.18 xtraeme if (strcmp(lsme->sme_name, sme->sme_name) == 0) {
485 1.18 xtraeme mutex_exit(&sme_list_mtx);
486 1.18 xtraeme error = EEXIST;
487 1.18 xtraeme goto out;
488 1.18 xtraeme }
489 1.18 xtraeme }
490 1.27 xtraeme
491 1.27 xtraeme /* initialize the singly linked list for sensor descriptions */
492 1.27 xtraeme SLIST_INIT(&sme_names_list);
493 1.27 xtraeme
494 1.18 xtraeme #ifdef COMPAT_40
495 1.1 thorpej sme->sme_fsensor = sysmon_envsys_next_sensor_index;
496 1.1 thorpej sysmon_envsys_next_sensor_index += sme->sme_nsensors;
497 1.18 xtraeme #endif
498 1.18 xtraeme mutex_exit(&sme_list_mtx);
499 1.18 xtraeme error = sysmon_envsys_createplist(sme);
500 1.18 xtraeme if (!error) {
501 1.18 xtraeme mutex_enter(&sme_list_mtx);
502 1.18 xtraeme LIST_INSERT_HEAD(&sysmon_envsys_list, sme, sme_list);
503 1.18 xtraeme mutex_exit(&sme_list_mtx);
504 1.18 xtraeme }
505 1.1 thorpej
506 1.18 xtraeme out:
507 1.18 xtraeme return error;
508 1.1 thorpej }
509 1.1 thorpej
510 1.1 thorpej /*
511 1.1 thorpej * sysmon_envsys_unregister:
512 1.1 thorpej *
513 1.18 xtraeme * + Unregister an envsys device.
514 1.18 xtraeme * + Unregister all events associated with this device.
515 1.18 xtraeme * + Remove device dictionary.
516 1.1 thorpej */
517 1.1 thorpej void
518 1.1 thorpej sysmon_envsys_unregister(struct sysmon_envsys *sme)
519 1.1 thorpej {
520 1.27 xtraeme struct sme_sensor_names *snames;
521 1.35 xtraeme
522 1.35 xtraeme KASSERT(sme != NULL);
523 1.1 thorpej
524 1.18 xtraeme mutex_enter(&sme_list_mtx);
525 1.7 yamt while (sme->sme_flags & SME_FLAG_BUSY) {
526 1.8 yamt sme->sme_flags |= SME_FLAG_WANTED;
527 1.18 xtraeme cv_wait(&sme_list_cv, &sme_list_mtx);
528 1.18 xtraeme }
529 1.18 xtraeme prop_dictionary_remove(sme_propd, sme->sme_name);
530 1.27 xtraeme /*
531 1.27 xtraeme * Unregister all events associated with this device.
532 1.27 xtraeme */
533 1.35 xtraeme mutex_exit(&sme_list_mtx);
534 1.35 xtraeme sme_event_unregister_all(sme);
535 1.35 xtraeme mutex_enter(&sme_list_mtx);
536 1.35 xtraeme
537 1.27 xtraeme /*
538 1.27 xtraeme * Remove all elements from the sensor names singly linked list.
539 1.27 xtraeme */
540 1.27 xtraeme while (!SLIST_EMPTY(&sme_names_list)) {
541 1.27 xtraeme snames = SLIST_FIRST(&sme_names_list);
542 1.27 xtraeme SLIST_REMOVE_HEAD(&sme_names_list, sme_names);
543 1.29 xtraeme mutex_exit(&sme_list_mtx);
544 1.27 xtraeme kmem_free(snames, sizeof(*snames));
545 1.29 xtraeme mutex_enter(&sme_list_mtx);
546 1.27 xtraeme }
547 1.1 thorpej LIST_REMOVE(sme, sme_list);
548 1.18 xtraeme mutex_exit(&sme_list_mtx);
549 1.1 thorpej }
550 1.1 thorpej
551 1.1 thorpej /*
552 1.1 thorpej * sysmon_envsys_find:
553 1.1 thorpej *
554 1.18 xtraeme * + Find an envsys device.
555 1.1 thorpej */
556 1.1 thorpej struct sysmon_envsys *
557 1.18 xtraeme sysmon_envsys_find(const char *name)
558 1.1 thorpej {
559 1.1 thorpej struct sysmon_envsys *sme;
560 1.1 thorpej
561 1.18 xtraeme mutex_enter(&sme_list_mtx);
562 1.7 yamt again:
563 1.1 thorpej for (sme = LIST_FIRST(&sysmon_envsys_list); sme != NULL;
564 1.1 thorpej sme = LIST_NEXT(sme, sme_list)) {
565 1.18 xtraeme if (strcmp(sme->sme_name, name) == 0) {
566 1.18 xtraeme if (sme->sme_flags & SME_FLAG_BUSY) {
567 1.18 xtraeme sme->sme_flags |= SME_FLAG_WANTED;
568 1.18 xtraeme cv_wait(&sme_list_cv, &sme_list_mtx);
569 1.18 xtraeme goto again;
570 1.18 xtraeme }
571 1.18 xtraeme sme->sme_flags |= SME_FLAG_BUSY;
572 1.18 xtraeme break;
573 1.18 xtraeme }
574 1.18 xtraeme }
575 1.18 xtraeme mutex_exit(&sme_list_mtx);
576 1.18 xtraeme return sme;
577 1.18 xtraeme }
578 1.18 xtraeme
579 1.18 xtraeme /*
580 1.18 xtraeme * sysmon_envsys_release:
581 1.18 xtraeme *
582 1.18 xtraeme * + Release an envsys device.
583 1.18 xtraeme */
584 1.18 xtraeme void
585 1.18 xtraeme sysmon_envsys_release(struct sysmon_envsys *sme)
586 1.18 xtraeme {
587 1.18 xtraeme mutex_enter(&sme_list_mtx);
588 1.18 xtraeme if (sme->sme_flags & SME_FLAG_WANTED)
589 1.18 xtraeme cv_broadcast(&sme_list_cv);
590 1.18 xtraeme sme->sme_flags &= ~(SME_FLAG_BUSY | SME_FLAG_WANTED);
591 1.18 xtraeme mutex_exit(&sme_list_mtx);
592 1.18 xtraeme }
593 1.18 xtraeme
594 1.18 xtraeme /* compatibility function */
595 1.18 xtraeme #ifdef COMPAT_40
596 1.18 xtraeme struct sysmon_envsys *
597 1.18 xtraeme sysmon_envsys_find_40(u_int idx)
598 1.18 xtraeme {
599 1.18 xtraeme struct sysmon_envsys *sme;
600 1.18 xtraeme
601 1.18 xtraeme mutex_enter(&sme_list_mtx);
602 1.18 xtraeme for (sme = LIST_FIRST(&sysmon_envsys_list); sme != NULL;
603 1.18 xtraeme sme = LIST_NEXT(sme, sme_list)) {
604 1.1 thorpej if (idx >= sme->sme_fsensor &&
605 1.18 xtraeme idx < (sme->sme_fsensor + sme->sme_nsensors))
606 1.18 xtraeme break;
607 1.18 xtraeme }
608 1.18 xtraeme mutex_exit(&sme_list_mtx);
609 1.18 xtraeme return sme;
610 1.18 xtraeme }
611 1.18 xtraeme #endif
612 1.18 xtraeme
613 1.18 xtraeme /*
614 1.18 xtraeme * sysmon_envsys_createplist:
615 1.18 xtraeme *
616 1.18 xtraeme * + Create the property list structure for a device.
617 1.18 xtraeme */
618 1.18 xtraeme int
619 1.18 xtraeme sysmon_envsys_createplist(struct sysmon_envsys *sme)
620 1.18 xtraeme {
621 1.18 xtraeme envsys_data_t *edata;
622 1.18 xtraeme prop_array_t array;
623 1.18 xtraeme int i, error = 0;
624 1.18 xtraeme
625 1.18 xtraeme /* create the sysmon envsys device array. */
626 1.18 xtraeme array = prop_array_create();
627 1.34 xtraeme if (array == NULL)
628 1.34 xtraeme return EINVAL;
629 1.18 xtraeme
630 1.18 xtraeme /*
631 1.18 xtraeme * <dict>
632 1.18 xtraeme * <key>foo0</key>
633 1.18 xtraeme * <array>
634 1.18 xtraeme * ...
635 1.18 xtraeme */
636 1.18 xtraeme mutex_enter(&sme_mtx);
637 1.18 xtraeme if (!prop_dictionary_set(sme_propd, sme->sme_name, array)) {
638 1.18 xtraeme DPRINTF(("%s: prop_dictionary_set\n", __func__));
639 1.18 xtraeme mutex_exit(&sme_mtx);
640 1.18 xtraeme error = EINVAL;
641 1.18 xtraeme goto out;
642 1.18 xtraeme }
643 1.18 xtraeme mutex_exit(&sme_mtx);
644 1.18 xtraeme
645 1.18 xtraeme /*
646 1.18 xtraeme * Iterate over all sensors and create a dictionary with all
647 1.18 xtraeme * values specified by the sysmon envsys driver.
648 1.18 xtraeme */
649 1.18 xtraeme for (i = 0; i < sme->sme_nsensors; i++) {
650 1.18 xtraeme edata = &sme->sme_sensor_data[i];
651 1.18 xtraeme /*
652 1.18 xtraeme * refresh sensor data via sme_gtredata only if the
653 1.18 xtraeme * flag is not set.
654 1.18 xtraeme */
655 1.18 xtraeme if ((sme->sme_flags & SME_DISABLE_GTREDATA) == 0) {
656 1.18 xtraeme mutex_enter(&sme_mtx);
657 1.18 xtraeme error = (*sme->sme_gtredata)(sme, edata);
658 1.18 xtraeme if (error) {
659 1.18 xtraeme DPRINTF(("%s: sme->sme_gtredata[%d]\n",
660 1.18 xtraeme __func__, i));
661 1.18 xtraeme mutex_exit(&sme_mtx);
662 1.18 xtraeme continue;
663 1.7 yamt }
664 1.18 xtraeme mutex_exit(&sme_mtx);
665 1.18 xtraeme }
666 1.18 xtraeme
667 1.18 xtraeme error = sme_make_dictionary(sme, array, edata);
668 1.27 xtraeme if (error == EINVAL)
669 1.18 xtraeme goto out;
670 1.27 xtraeme else if (error == EEXIST) {
671 1.23 xtraeme error = 0;
672 1.23 xtraeme continue;
673 1.18 xtraeme }
674 1.18 xtraeme }
675 1.18 xtraeme
676 1.18 xtraeme out:
677 1.18 xtraeme prop_object_release(array);
678 1.18 xtraeme return error;
679 1.18 xtraeme }
680 1.18 xtraeme
681 1.18 xtraeme /*
682 1.27 xtraeme * sme_register_sensorname:
683 1.27 xtraeme *
684 1.27 xtraeme * + Registers a sensor name into the list maintained per device.
685 1.27 xtraeme */
686 1.27 xtraeme static int
687 1.27 xtraeme sme_register_sensorname(envsys_data_t *edata)
688 1.27 xtraeme {
689 1.27 xtraeme struct sme_sensor_names *snames, *snames2 = NULL;
690 1.27 xtraeme
691 1.35 xtraeme KASSERT(edata != NULL);
692 1.35 xtraeme
693 1.27 xtraeme snames = kmem_zalloc(sizeof(*snames), KM_SLEEP);
694 1.27 xtraeme
695 1.35 xtraeme mutex_enter(&sme_list_mtx);
696 1.34 xtraeme SLIST_FOREACH(snames2, &sme_names_list, sme_names) {
697 1.34 xtraeme if (strcmp(snames2->desc, edata->desc) == 0)
698 1.34 xtraeme if (snames2->assigned) {
699 1.34 xtraeme edata->flags |= ENVSYS_FDUPDESC;
700 1.35 xtraeme mutex_exit(&sme_list_mtx);
701 1.34 xtraeme DPRINTF(("%s: duplicate name "
702 1.34 xtraeme "(%s)\n", __func__, edata->desc));
703 1.34 xtraeme kmem_free(snames, sizeof(*snames));
704 1.34 xtraeme return EEXIST;
705 1.34 xtraeme }
706 1.27 xtraeme }
707 1.27 xtraeme
708 1.27 xtraeme snames->assigned = true;
709 1.27 xtraeme (void)strlcpy(snames->desc, edata->desc, sizeof(snames->desc));
710 1.27 xtraeme DPRINTF(("%s: registering sensor name=%s\n", __func__, edata->desc));
711 1.27 xtraeme SLIST_INSERT_HEAD(&sme_names_list, snames, sme_names);
712 1.35 xtraeme mutex_exit(&sme_list_mtx);
713 1.27 xtraeme
714 1.27 xtraeme return 0;
715 1.27 xtraeme }
716 1.27 xtraeme
717 1.27 xtraeme /*
718 1.18 xtraeme * sme_make_dictionary:
719 1.18 xtraeme *
720 1.18 xtraeme * + Create sensor's dictionary in device's dictionary array.
721 1.18 xtraeme */
722 1.18 xtraeme int
723 1.18 xtraeme sme_make_dictionary(struct sysmon_envsys *sme, prop_array_t array,
724 1.18 xtraeme envsys_data_t *edata)
725 1.18 xtraeme {
726 1.18 xtraeme const struct sme_sensor_type *est = sme_sensor_type;
727 1.18 xtraeme const struct sme_sensor_state *ess = sme_sensor_state;
728 1.18 xtraeme const struct sme_sensor_state *esds = sme_sensor_drive_state;
729 1.18 xtraeme sme_event_drv_t *sme_evdrv_t = NULL;
730 1.18 xtraeme prop_dictionary_t dict;
731 1.35 xtraeme int i, j, k, error;
732 1.18 xtraeme
733 1.35 xtraeme i = j = k = error = 0;
734 1.27 xtraeme
735 1.27 xtraeme /*
736 1.27 xtraeme * Check if description was already assigned in other sensor.
737 1.27 xtraeme */
738 1.35 xtraeme error = sme_register_sensorname(edata);
739 1.35 xtraeme if (error)
740 1.35 xtraeme return error;
741 1.18 xtraeme
742 1.18 xtraeme /*
743 1.18 xtraeme * <array>
744 1.18 xtraeme * <dict>
745 1.18 xtraeme * ...
746 1.18 xtraeme */
747 1.18 xtraeme dict = prop_dictionary_create();
748 1.35 xtraeme if (dict == NULL) {
749 1.35 xtraeme DPRINTF(("%s: couldn't allocate a dictionary\n", __func__));
750 1.34 xtraeme return EINVAL;
751 1.35 xtraeme }
752 1.18 xtraeme
753 1.18 xtraeme mutex_enter(&sme_mtx);
754 1.18 xtraeme if (!prop_array_add(array, dict)) {
755 1.18 xtraeme mutex_exit(&sme_mtx);
756 1.25 xtraeme prop_object_release(dict);
757 1.18 xtraeme DPRINTF(("%s: prop_array_add\n", __func__));
758 1.18 xtraeme return EINVAL;
759 1.18 xtraeme }
760 1.18 xtraeme
761 1.18 xtraeme /* find the correct unit for this sensor. */
762 1.18 xtraeme for (i = 0; est[i].type != -1; i++)
763 1.18 xtraeme if (est[i].type == edata->units)
764 1.18 xtraeme break;
765 1.18 xtraeme
766 1.18 xtraeme /*
767 1.18 xtraeme * ...
768 1.18 xtraeme * <key>type</key>
769 1.18 xtraeme * <string>foo</string>
770 1.18 xtraeme * <key>description</key>
771 1.18 xtraeme * <string>blah blah</string>
772 1.18 xtraeme * ...
773 1.18 xtraeme */
774 1.35 xtraeme error = sme_sensor_upstring(dict, "type", est[i].desc);
775 1.35 xtraeme if (error)
776 1.30 xtraeme goto out;
777 1.30 xtraeme
778 1.35 xtraeme error = sme_sensor_upstring(dict, "description", edata->desc);
779 1.35 xtraeme if (error)
780 1.30 xtraeme goto out;
781 1.30 xtraeme
782 1.18 xtraeme
783 1.18 xtraeme /*
784 1.18 xtraeme * Add sensor's state description.
785 1.18 xtraeme *
786 1.18 xtraeme * ...
787 1.18 xtraeme * <key>state</key>
788 1.18 xtraeme * <string>valid</string>
789 1.18 xtraeme * ...
790 1.18 xtraeme */
791 1.18 xtraeme for (j = 0; ess[j].type != -1; j++)
792 1.18 xtraeme if (ess[j].type == edata->state)
793 1.7 yamt break;
794 1.18 xtraeme
795 1.35 xtraeme error = sme_sensor_upstring(dict, "state", ess[j].desc);
796 1.35 xtraeme if (error)
797 1.30 xtraeme goto out;
798 1.18 xtraeme
799 1.18 xtraeme /*
800 1.18 xtraeme * add the percentage boolean object:
801 1.18 xtraeme *
802 1.18 xtraeme * ...
803 1.18 xtraeme * <key>want-percentage</key>
804 1.18 xtraeme * <true/>
805 1.18 xtraeme * ...
806 1.18 xtraeme */
807 1.35 xtraeme if (edata->flags & ENVSYS_FPERCENT) {
808 1.35 xtraeme error = sme_sensor_upbool(dict, "want-percentage", true);
809 1.35 xtraeme if (error)
810 1.30 xtraeme goto out;
811 1.35 xtraeme }
812 1.18 xtraeme
813 1.18 xtraeme /*
814 1.18 xtraeme * Add the monitoring boolean object:
815 1.18 xtraeme *
816 1.18 xtraeme * ...
817 1.18 xtraeme * <key>monitoring-supported</key>
818 1.18 xtraeme * <true/>
819 1.18 xtraeme * ...
820 1.18 xtraeme *
821 1.21 xtraeme * always false on Drive and Indicator types, they
822 1.18 xtraeme * cannot be monitored.
823 1.18 xtraeme *
824 1.18 xtraeme */
825 1.18 xtraeme if ((edata->flags & ENVSYS_FMONNOTSUPP) ||
826 1.18 xtraeme (edata->units == ENVSYS_INDICATOR) ||
827 1.18 xtraeme (edata->units == ENVSYS_DRIVE)) {
828 1.35 xtraeme error = sme_sensor_upbool(dict, "monitoring-supported", false);
829 1.35 xtraeme if (error)
830 1.30 xtraeme goto out;
831 1.18 xtraeme } else {
832 1.35 xtraeme error = sme_sensor_upbool(dict, "monitoring-supported", true);
833 1.35 xtraeme if (error)
834 1.30 xtraeme goto out;
835 1.18 xtraeme }
836 1.18 xtraeme
837 1.18 xtraeme /*
838 1.18 xtraeme * Add the drive-state object for drive sensors:
839 1.18 xtraeme *
840 1.18 xtraeme * ...
841 1.18 xtraeme * <key>drive-state</key>
842 1.18 xtraeme * <string>drive is online</string>
843 1.18 xtraeme * ...
844 1.18 xtraeme */
845 1.18 xtraeme if (edata->units == ENVSYS_DRIVE) {
846 1.18 xtraeme for (k = 0; esds[k].type != -1; k++)
847 1.18 xtraeme if (esds[k].type == edata->value_cur)
848 1.18 xtraeme break;
849 1.30 xtraeme
850 1.35 xtraeme error = sme_sensor_upstring(dict, "drive-state", esds[k].desc);
851 1.35 xtraeme if (error)
852 1.30 xtraeme goto out;
853 1.18 xtraeme }
854 1.18 xtraeme
855 1.18 xtraeme mutex_exit(&sme_mtx);
856 1.18 xtraeme /*
857 1.18 xtraeme * Add a new event if a monitoring flag was set.
858 1.18 xtraeme */
859 1.21 xtraeme if (edata->monitor) {
860 1.18 xtraeme sme_evdrv_t = kmem_zalloc(sizeof(*sme_evdrv_t), KM_SLEEP);
861 1.18 xtraeme
862 1.18 xtraeme sme_evdrv_t->sdict = dict;
863 1.18 xtraeme sme_evdrv_t->edata = edata;
864 1.18 xtraeme sme_evdrv_t->sme = sme;
865 1.18 xtraeme sme_evdrv_t->powertype = est[i].crittype;
866 1.18 xtraeme
867 1.18 xtraeme sysmon_task_queue_init();
868 1.18 xtraeme sysmon_task_queue_sched(0, sme_event_drvadd, sme_evdrv_t);
869 1.18 xtraeme }
870 1.18 xtraeme
871 1.18 xtraeme mutex_enter(&sme_mtx);
872 1.18 xtraeme /* if sensor is enabled, add the following properties... */
873 1.18 xtraeme if (edata->state == ENVSYS_SVALID) {
874 1.18 xtraeme /*
875 1.18 xtraeme * ...
876 1.18 xtraeme * <key>rpms</key>
877 1.18 xtraeme * <integer>2500</integer>
878 1.18 xtraeme * <key>rfact</key>
879 1.18 xtraeme * <integer>10000</integer>
880 1.18 xtraeme * <key>cur-value</key>
881 1.18 xtraeme * <integer>1250</integer>
882 1.18 xtraeme * <key>min-value</key>
883 1.18 xtraeme * <integer>800</integer>
884 1.18 xtraeme * <key>max-value</integer>
885 1.18 xtraeme * <integer>3000</integer>
886 1.18 xtraeme * <key>avg-value</integer>
887 1.18 xtraeme * <integer>1400</integer>
888 1.18 xtraeme * </dict>
889 1.18 xtraeme */
890 1.35 xtraeme if ((edata->units == ENVSYS_SFANRPM) && edata->rpms) {
891 1.35 xtraeme error = sme_sensor_upuint32(dict, "rpms", edata->rpms);
892 1.35 xtraeme if (error)
893 1.30 xtraeme goto out;
894 1.35 xtraeme }
895 1.18 xtraeme
896 1.18 xtraeme if ((edata->units == ENVSYS_SVOLTS_AC ||
897 1.35 xtraeme edata->units == ENVSYS_SVOLTS_DC) && edata->rfact) {
898 1.35 xtraeme error = sme_sensor_upint32(dict, "rfact", edata->rfact);
899 1.35 xtraeme if (error)
900 1.30 xtraeme goto out;
901 1.35 xtraeme }
902 1.18 xtraeme
903 1.30 xtraeme if (edata->value_cur) {
904 1.35 xtraeme error= sme_sensor_upint32(dict,
905 1.35 xtraeme "cur-value",
906 1.35 xtraeme edata->value_cur);
907 1.35 xtraeme if (error)
908 1.30 xtraeme goto out;
909 1.30 xtraeme }
910 1.30 xtraeme
911 1.30 xtraeme if ((edata->flags & ENVSYS_FVALID_MIN) && edata->value_min) {
912 1.35 xtraeme error = sme_sensor_upint32(dict,
913 1.35 xtraeme "min-value",
914 1.35 xtraeme edata->value_min);
915 1.35 xtraeme if (error)
916 1.30 xtraeme goto out;
917 1.30 xtraeme }
918 1.30 xtraeme
919 1.30 xtraeme if ((edata->flags & ENVSYS_FVALID_MAX) && edata->value_max) {
920 1.35 xtraeme error = sme_sensor_upint32(dict,
921 1.35 xtraeme "max-value",
922 1.35 xtraeme edata->value_max);
923 1.35 xtraeme if (error)
924 1.30 xtraeme goto out;
925 1.30 xtraeme }
926 1.30 xtraeme
927 1.30 xtraeme if ((edata->flags & ENVSYS_FVALID_AVG) && edata->value_avg) {
928 1.35 xtraeme error = sme_sensor_upint32(dict,
929 1.35 xtraeme "avg-value",
930 1.35 xtraeme edata->value_avg);
931 1.35 xtraeme if (error)
932 1.30 xtraeme goto out;
933 1.30 xtraeme }
934 1.18 xtraeme }
935 1.18 xtraeme
936 1.18 xtraeme /*
937 1.18 xtraeme * ...
938 1.18 xtraeme * </array>
939 1.18 xtraeme */
940 1.18 xtraeme out:
941 1.18 xtraeme mutex_exit(&sme_mtx);
942 1.18 xtraeme prop_object_release(dict);
943 1.35 xtraeme return error;
944 1.18 xtraeme }
945 1.18 xtraeme
946 1.18 xtraeme /*
947 1.18 xtraeme * sme_update_dictionary:
948 1.18 xtraeme *
949 1.18 xtraeme * + Update per-sensor dictionaries with new values if there were
950 1.18 xtraeme * changes, otherwise the object in dictionary is untouched.
951 1.18 xtraeme * + Send a critical event if any sensor is in a critical condition.
952 1.18 xtraeme */
953 1.18 xtraeme int
954 1.18 xtraeme sme_update_dictionary(struct sysmon_envsys *sme)
955 1.18 xtraeme {
956 1.18 xtraeme const struct sme_sensor_state *ess = sme_sensor_state;
957 1.18 xtraeme const struct sme_sensor_state *esds = sme_sensor_drive_state;
958 1.18 xtraeme envsys_data_t *edata = NULL;
959 1.34 xtraeme prop_object_t array, dict;
960 1.18 xtraeme int i, j, error = 0;
961 1.18 xtraeme
962 1.34 xtraeme array = dict = NULL;
963 1.30 xtraeme
964 1.18 xtraeme /* retrieve the array of dictionaries in device. */
965 1.18 xtraeme array = prop_dictionary_get(sme_propd, sme->sme_name);
966 1.24 xtraeme if (prop_object_type(array) != PROP_TYPE_ARRAY) {
967 1.24 xtraeme DPRINTF(("%s: not an array (%s)\n", __func__, sme->sme_name));
968 1.18 xtraeme return EINVAL;
969 1.24 xtraeme }
970 1.18 xtraeme
971 1.18 xtraeme /*
972 1.18 xtraeme * - iterate over all sensors.
973 1.18 xtraeme * - fetch new data.
974 1.18 xtraeme * - check if data in dictionary is different than new data.
975 1.18 xtraeme * - update dictionary if there were changes.
976 1.18 xtraeme */
977 1.18 xtraeme for (i = 0; i < sme->sme_nsensors; i++) {
978 1.18 xtraeme edata = &sme->sme_sensor_data[i];
979 1.24 xtraeme if (edata->flags & ENVSYS_FDUPDESC) {
980 1.27 xtraeme --sme->sme_nsensors;
981 1.27 xtraeme --i;
982 1.23 xtraeme continue;
983 1.24 xtraeme }
984 1.23 xtraeme
985 1.18 xtraeme /*
986 1.18 xtraeme * refresh sensor data via sme_gtredata only if the
987 1.18 xtraeme * flag is not set.
988 1.18 xtraeme */
989 1.18 xtraeme if ((sme->sme_flags & SME_DISABLE_GTREDATA) == 0) {
990 1.18 xtraeme error = (*sme->sme_gtredata)(sme, edata);
991 1.18 xtraeme if (error) {
992 1.18 xtraeme DPRINTF(("%s: gtredata[%d] failed\n",
993 1.18 xtraeme __func__, i));
994 1.18 xtraeme return error;
995 1.18 xtraeme }
996 1.18 xtraeme }
997 1.18 xtraeme
998 1.18 xtraeme /* retrieve sensor's dictionary. */
999 1.18 xtraeme dict = prop_array_get(array, i);
1000 1.24 xtraeme if (prop_object_type(dict) != PROP_TYPE_DICTIONARY) {
1001 1.24 xtraeme DPRINTF(("%s: not a dictionary (%d:%s)\n",
1002 1.24 xtraeme __func__, edata->sensor, sme->sme_name));
1003 1.18 xtraeme return EINVAL;
1004 1.24 xtraeme }
1005 1.18 xtraeme
1006 1.18 xtraeme /* update state sensor. */
1007 1.18 xtraeme for (j = 0; ess[j].type != -1; j++)
1008 1.18 xtraeme if (ess[j].type == edata->state)
1009 1.18 xtraeme break;
1010 1.18 xtraeme
1011 1.18 xtraeme DPRINTFOBJ(("%s: state=%s type=%d flags=%d "
1012 1.18 xtraeme "units=%d sensor=%d\n", __func__, ess[j].desc,
1013 1.18 xtraeme ess[j].type, edata->flags, edata->units, edata->sensor));
1014 1.18 xtraeme
1015 1.18 xtraeme /* update sensor state */
1016 1.34 xtraeme error = sme_sensor_upstring(dict, "state", ess[j].desc);
1017 1.30 xtraeme if (error)
1018 1.30 xtraeme break;
1019 1.18 xtraeme
1020 1.18 xtraeme /* update sensor current value */
1021 1.34 xtraeme error = sme_sensor_upint32(dict,
1022 1.30 xtraeme "cur-value",
1023 1.30 xtraeme edata->value_cur);
1024 1.30 xtraeme if (error)
1025 1.30 xtraeme break;
1026 1.18 xtraeme
1027 1.18 xtraeme /*
1028 1.18 xtraeme * Integer and Indicator types do not the following
1029 1.18 xtraeme * values, so skip them.
1030 1.18 xtraeme */
1031 1.18 xtraeme if (edata->units == ENVSYS_INTEGER ||
1032 1.18 xtraeme edata->units == ENVSYS_INDICATOR)
1033 1.18 xtraeme continue;
1034 1.18 xtraeme
1035 1.18 xtraeme /* update sensor flags */
1036 1.30 xtraeme if (edata->flags & ENVSYS_FPERCENT) {
1037 1.34 xtraeme error = sme_sensor_upbool(dict,
1038 1.30 xtraeme "want-percentage",
1039 1.30 xtraeme true);
1040 1.30 xtraeme if (error)
1041 1.30 xtraeme break;
1042 1.18 xtraeme }
1043 1.18 xtraeme
1044 1.30 xtraeme if (edata->flags & ENVSYS_FVALID_MAX) {
1045 1.34 xtraeme error = sme_sensor_upint32(dict,
1046 1.30 xtraeme "max-value",
1047 1.30 xtraeme edata->value_max);
1048 1.30 xtraeme if (error)
1049 1.30 xtraeme break;
1050 1.30 xtraeme }
1051 1.30 xtraeme
1052 1.30 xtraeme if (edata->flags & ENVSYS_FVALID_MIN) {
1053 1.34 xtraeme error = sme_sensor_upint32(dict,
1054 1.30 xtraeme "min-value",
1055 1.30 xtraeme edata->value_min);
1056 1.30 xtraeme if (error)
1057 1.30 xtraeme break;
1058 1.30 xtraeme }
1059 1.18 xtraeme
1060 1.30 xtraeme if (edata->flags & ENVSYS_FVALID_AVG) {
1061 1.34 xtraeme error = sme_sensor_upint32(dict,
1062 1.30 xtraeme "avg-value",
1063 1.30 xtraeme edata->value_avg);
1064 1.30 xtraeme if (error)
1065 1.30 xtraeme break;
1066 1.30 xtraeme }
1067 1.18 xtraeme
1068 1.18 xtraeme /* update 'rpms' only in ENVSYS_SFANRPM. */
1069 1.30 xtraeme if (edata->units == ENVSYS_SFANRPM) {
1070 1.34 xtraeme error = sme_sensor_upuint32(dict,
1071 1.30 xtraeme "rpms",
1072 1.30 xtraeme edata->rpms);
1073 1.30 xtraeme if (error)
1074 1.30 xtraeme break;
1075 1.30 xtraeme }
1076 1.18 xtraeme
1077 1.18 xtraeme /* update 'rfact' only in ENVSYS_SVOLTS_[AD]C. */
1078 1.18 xtraeme if (edata->units == ENVSYS_SVOLTS_AC ||
1079 1.18 xtraeme edata->units == ENVSYS_SVOLTS_DC) {
1080 1.34 xtraeme error = sme_sensor_upint32(dict,
1081 1.30 xtraeme "rfact",
1082 1.30 xtraeme edata->rfact);
1083 1.30 xtraeme if (error)
1084 1.30 xtraeme break;
1085 1.18 xtraeme }
1086 1.18 xtraeme
1087 1.18 xtraeme /* update 'drive-state' only in ENVSYS_DRIVE. */
1088 1.18 xtraeme if (edata->units == ENVSYS_DRIVE) {
1089 1.18 xtraeme for (j = 0; esds[j].type != -1; j++)
1090 1.18 xtraeme if (esds[j].type == edata->value_cur)
1091 1.18 xtraeme break;
1092 1.18 xtraeme
1093 1.34 xtraeme error = sme_sensor_upstring(dict,
1094 1.30 xtraeme "drive-state",
1095 1.30 xtraeme esds[j].desc);
1096 1.32 xtraeme if (error)
1097 1.32 xtraeme break;
1098 1.7 yamt }
1099 1.1 thorpej }
1100 1.1 thorpej
1101 1.18 xtraeme return error;
1102 1.1 thorpej }
1103 1.1 thorpej
1104 1.1 thorpej /*
1105 1.18 xtraeme * sme_userset_dictionary:
1106 1.1 thorpej *
1107 1.18 xtraeme * + Parses the userland dictionary and run the appropiate
1108 1.18 xtraeme * tasks that were requested.
1109 1.1 thorpej */
1110 1.18 xtraeme int
1111 1.18 xtraeme sme_userset_dictionary(struct sysmon_envsys *sme, prop_dictionary_t udict,
1112 1.18 xtraeme prop_array_t array)
1113 1.1 thorpej {
1114 1.18 xtraeme const struct sme_sensor_type *sst = sme_sensor_type;
1115 1.23 xtraeme envsys_data_t *edata, *nedata;
1116 1.18 xtraeme prop_dictionary_t dict;
1117 1.18 xtraeme prop_object_t obj, obj1, obj2;
1118 1.18 xtraeme int32_t critval;
1119 1.18 xtraeme int i, error = 0;
1120 1.18 xtraeme const char *blah, *sname;
1121 1.18 xtraeme bool targetfound = false;
1122 1.18 xtraeme
1123 1.18 xtraeme blah = sname = NULL;
1124 1.18 xtraeme
1125 1.18 xtraeme /* get sensor's name from userland dictionary. */
1126 1.18 xtraeme obj = prop_dictionary_get(udict, "sensor-name");
1127 1.18 xtraeme if (prop_object_type(obj) != PROP_TYPE_STRING) {
1128 1.18 xtraeme DPRINTF(("%s: sensor-name failed\n", __func__));
1129 1.18 xtraeme return EINVAL;
1130 1.18 xtraeme }
1131 1.1 thorpej
1132 1.18 xtraeme /* iterate over the sensors to find the right one */
1133 1.18 xtraeme for (i = 0; i < sme->sme_nsensors; i++) {
1134 1.18 xtraeme edata = &sme->sme_sensor_data[i];
1135 1.27 xtraeme
1136 1.27 xtraeme /* duplicate description? skip it */
1137 1.27 xtraeme if (edata->flags & ENVSYS_FDUPDESC)
1138 1.27 xtraeme continue;
1139 1.27 xtraeme
1140 1.18 xtraeme dict = prop_array_get(array, i);
1141 1.18 xtraeme obj1 = prop_dictionary_get(dict, "description");
1142 1.18 xtraeme
1143 1.18 xtraeme /* is it our sensor? */
1144 1.18 xtraeme if (!prop_string_equals(obj1, obj))
1145 1.18 xtraeme continue;
1146 1.18 xtraeme
1147 1.18 xtraeme /*
1148 1.18 xtraeme * Check if a new description operation was
1149 1.18 xtraeme * requested by the user and set new description.
1150 1.18 xtraeme */
1151 1.18 xtraeme if ((obj2 = prop_dictionary_get(udict, "new-description"))) {
1152 1.18 xtraeme targetfound = true;
1153 1.18 xtraeme blah = prop_string_cstring_nocopy(obj2);
1154 1.23 xtraeme
1155 1.23 xtraeme for (i = 0; i < sme->sme_nsensors; i++) {
1156 1.23 xtraeme if (i == edata->sensor)
1157 1.23 xtraeme continue;
1158 1.23 xtraeme
1159 1.23 xtraeme nedata = &sme->sme_sensor_data[i];
1160 1.23 xtraeme if (strcmp(blah, nedata->desc) == 0) {
1161 1.23 xtraeme error = EEXIST;
1162 1.30 xtraeme break;
1163 1.23 xtraeme }
1164 1.23 xtraeme }
1165 1.23 xtraeme
1166 1.31 xtraeme if (error)
1167 1.31 xtraeme break;
1168 1.31 xtraeme
1169 1.34 xtraeme error = sme_sensor_upstring(dict,
1170 1.30 xtraeme "description",
1171 1.30 xtraeme blah);
1172 1.33 xtraeme if (!error)
1173 1.33 xtraeme (void)strlcpy(edata->desc,
1174 1.33 xtraeme blah,
1175 1.33 xtraeme sizeof(edata->desc));
1176 1.33 xtraeme
1177 1.18 xtraeme break;
1178 1.18 xtraeme }
1179 1.18 xtraeme
1180 1.18 xtraeme /* did the user want to remove a critical capacity limit? */
1181 1.18 xtraeme obj2 = prop_dictionary_get(udict, "remove-critical-cap");
1182 1.18 xtraeme if (obj2 != NULL) {
1183 1.18 xtraeme targetfound = true;
1184 1.18 xtraeme if ((edata->flags & ENVSYS_FMONNOTSUPP) ||
1185 1.18 xtraeme (edata->flags & ENVSYS_FPERCENT) == 0) {
1186 1.18 xtraeme error = ENOTSUP;
1187 1.18 xtraeme break;
1188 1.18 xtraeme }
1189 1.18 xtraeme
1190 1.18 xtraeme sname = prop_string_cstring_nocopy(obj);
1191 1.18 xtraeme error = sme_event_unregister(sname,
1192 1.18 xtraeme PENVSYS_EVENT_BATT_USERCAP);
1193 1.18 xtraeme if (error)
1194 1.18 xtraeme break;
1195 1.18 xtraeme
1196 1.18 xtraeme prop_dictionary_remove(dict, "critical-capacity");
1197 1.18 xtraeme break;
1198 1.18 xtraeme }
1199 1.18 xtraeme
1200 1.18 xtraeme /* did the user want to remove a critical min limit? */
1201 1.18 xtraeme obj2 = prop_dictionary_get(udict, "remove-cmin-limit");
1202 1.18 xtraeme if (obj2 != NULL) {
1203 1.18 xtraeme targetfound = true;
1204 1.18 xtraeme sname = prop_string_cstring_nocopy(obj);
1205 1.18 xtraeme error = sme_event_unregister(sname,
1206 1.18 xtraeme PENVSYS_EVENT_USER_CRITMIN);
1207 1.18 xtraeme if (error)
1208 1.18 xtraeme break;
1209 1.18 xtraeme
1210 1.18 xtraeme prop_dictionary_remove(dict, "critical-min-limit");
1211 1.18 xtraeme break;
1212 1.18 xtraeme }
1213 1.18 xtraeme
1214 1.18 xtraeme /* did the user want to remove a critical max limit? */
1215 1.18 xtraeme obj2 = prop_dictionary_get(udict, "remove-cmax-limit");
1216 1.18 xtraeme if (obj2 != NULL) {
1217 1.18 xtraeme targetfound = true;
1218 1.18 xtraeme sname = prop_string_cstring_nocopy(obj);
1219 1.18 xtraeme error = sme_event_unregister(sname,
1220 1.18 xtraeme PENVSYS_EVENT_USER_CRITMAX);
1221 1.18 xtraeme if (error)
1222 1.18 xtraeme break;
1223 1.7 yamt
1224 1.18 xtraeme prop_dictionary_remove(dict, "critical-max-limit");
1225 1.18 xtraeme break;
1226 1.18 xtraeme }
1227 1.18 xtraeme
1228 1.18 xtraeme /* did the user want to change rfact? */
1229 1.18 xtraeme obj2 = prop_dictionary_get(udict, "new-rfact");
1230 1.18 xtraeme if (obj2 != NULL) {
1231 1.18 xtraeme targetfound = true;
1232 1.18 xtraeme if (edata->flags & ENVSYS_FCHANGERFACT)
1233 1.18 xtraeme edata->rfact = prop_number_integer_value(obj2);
1234 1.18 xtraeme else
1235 1.18 xtraeme error = ENOTSUP;
1236 1.18 xtraeme
1237 1.18 xtraeme break;
1238 1.18 xtraeme }
1239 1.18 xtraeme
1240 1.18 xtraeme for (i = 0; sst[i].type != -1; i++)
1241 1.18 xtraeme if (sst[i].type == edata->units)
1242 1.18 xtraeme break;
1243 1.18 xtraeme
1244 1.18 xtraeme /* did the user want to set a critical capacity event? */
1245 1.18 xtraeme obj2 = prop_dictionary_get(udict, "critical-capacity");
1246 1.18 xtraeme if (obj2 != NULL) {
1247 1.18 xtraeme targetfound = true;
1248 1.18 xtraeme if ((edata->flags & ENVSYS_FMONNOTSUPP) ||
1249 1.18 xtraeme (edata->flags & ENVSYS_FPERCENT) == 0) {
1250 1.18 xtraeme error = ENOTSUP;
1251 1.18 xtraeme break;
1252 1.18 xtraeme }
1253 1.18 xtraeme
1254 1.18 xtraeme critval = prop_number_integer_value(obj2);
1255 1.18 xtraeme error = sme_event_add(dict,
1256 1.18 xtraeme edata,
1257 1.18 xtraeme sme->sme_name,
1258 1.18 xtraeme "critical-capacity",
1259 1.18 xtraeme critval,
1260 1.18 xtraeme PENVSYS_EVENT_BATT_USERCAP,
1261 1.18 xtraeme sst[i].crittype);
1262 1.18 xtraeme break;
1263 1.18 xtraeme }
1264 1.18 xtraeme
1265 1.18 xtraeme /* did the user want to set a critical max event? */
1266 1.18 xtraeme obj2 = prop_dictionary_get(udict, "critical-max-limit");
1267 1.18 xtraeme if (obj2 != NULL) {
1268 1.18 xtraeme targetfound = true;
1269 1.18 xtraeme if (edata->units == ENVSYS_INDICATOR ||
1270 1.18 xtraeme edata->flags & ENVSYS_FMONNOTSUPP) {
1271 1.18 xtraeme error = ENOTSUP;
1272 1.18 xtraeme break;
1273 1.18 xtraeme }
1274 1.18 xtraeme
1275 1.18 xtraeme critval = prop_number_integer_value(obj2);
1276 1.18 xtraeme error = sme_event_add(dict,
1277 1.18 xtraeme edata,
1278 1.18 xtraeme sme->sme_name,
1279 1.18 xtraeme "critical-max-limit",
1280 1.18 xtraeme critval,
1281 1.18 xtraeme PENVSYS_EVENT_USER_CRITMAX,
1282 1.18 xtraeme sst[i].crittype);
1283 1.18 xtraeme break;
1284 1.18 xtraeme }
1285 1.18 xtraeme
1286 1.18 xtraeme /* did the user want to set a critical min event? */
1287 1.18 xtraeme obj2 = prop_dictionary_get(udict, "critical-min-limit");
1288 1.18 xtraeme if (obj2 != NULL) {
1289 1.18 xtraeme targetfound = true;
1290 1.18 xtraeme if (edata->units == ENVSYS_INDICATOR ||
1291 1.18 xtraeme edata->flags & ENVSYS_FMONNOTSUPP) {
1292 1.18 xtraeme error = ENOTSUP;
1293 1.18 xtraeme break;
1294 1.18 xtraeme }
1295 1.18 xtraeme
1296 1.18 xtraeme critval = prop_number_integer_value(obj2);
1297 1.18 xtraeme error = sme_event_add(dict,
1298 1.18 xtraeme edata,
1299 1.18 xtraeme sme->sme_name,
1300 1.18 xtraeme "critical-min-limit",
1301 1.18 xtraeme critval,
1302 1.18 xtraeme PENVSYS_EVENT_USER_CRITMIN,
1303 1.18 xtraeme sst[i].crittype);
1304 1.18 xtraeme break;
1305 1.18 xtraeme }
1306 1.18 xtraeme }
1307 1.18 xtraeme
1308 1.18 xtraeme /* invalid target? return the error */
1309 1.18 xtraeme if (!targetfound)
1310 1.18 xtraeme error = EINVAL;
1311 1.18 xtraeme
1312 1.18 xtraeme return error;
1313 1.1 thorpej }
1314