sysmon_envsys.c revision 1.26 1 1.26 xtraeme /* $NetBSD: sysmon_envsys.c,v 1.26 2007/07/18 20:31:41 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.26 xtraeme __KERNEL_RCSID(0, "$NetBSD: sysmon_envsys.c,v 1.26 2007/07/18 20:31:41 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.18 xtraeme static prop_dictionary_t sme_propd;
150 1.18 xtraeme static kmutex_t sme_list_mtx;
151 1.18 xtraeme static kcondvar_t sme_list_cv;
152 1.18 xtraeme
153 1.18 xtraeme #ifdef COMPAT_40
154 1.18 xtraeme static u_int sysmon_envsys_next_sensor_index = 0;
155 1.18 xtraeme static struct sysmon_envsys *sysmon_envsys_find_40(u_int);
156 1.18 xtraeme #endif
157 1.1 thorpej
158 1.18 xtraeme static void sysmon_envsys_release(struct sysmon_envsys *);
159 1.1 thorpej
160 1.18 xtraeme kmutex_t sme_mtx, sme_event_mtx;
161 1.26 xtraeme kcondvar_t sme_event_cv;
162 1.16 ad
163 1.18 xtraeme /*
164 1.18 xtraeme * sysmon_envsys_init:
165 1.18 xtraeme *
166 1.18 xtraeme * + Initialize global mutexes, dictionary and the linked lists.
167 1.18 xtraeme */
168 1.18 xtraeme void
169 1.18 xtraeme sysmon_envsys_init(void)
170 1.18 xtraeme {
171 1.18 xtraeme LIST_INIT(&sysmon_envsys_list);
172 1.18 xtraeme LIST_INIT(&sme_events_list);
173 1.18 xtraeme mutex_init(&sme_mtx, MUTEX_DRIVER, IPL_NONE);
174 1.18 xtraeme mutex_init(&sme_list_mtx, MUTEX_DRIVER, IPL_NONE);
175 1.18 xtraeme mutex_init(&sme_event_mtx, MUTEX_DRIVER, IPL_NONE);
176 1.18 xtraeme mutex_init(&sme_event_init_mtx, MUTEX_DRIVER, IPL_NONE);
177 1.18 xtraeme cv_init(&sme_list_cv, "smefind");
178 1.26 xtraeme cv_init(&sme_event_cv, "smeevent");
179 1.18 xtraeme sme_propd = prop_dictionary_create();
180 1.18 xtraeme }
181 1.1 thorpej
182 1.1 thorpej /*
183 1.1 thorpej * sysmonopen_envsys:
184 1.1 thorpej *
185 1.18 xtraeme * + Open the system monitor device.
186 1.1 thorpej */
187 1.1 thorpej int
188 1.18 xtraeme sysmonopen_envsys(dev_t dev, int flag, int mode, struct lwp *l)
189 1.1 thorpej {
190 1.18 xtraeme return 0;
191 1.1 thorpej }
192 1.1 thorpej
193 1.1 thorpej /*
194 1.1 thorpej * sysmonclose_envsys:
195 1.1 thorpej *
196 1.18 xtraeme * + Close the system monitor device.
197 1.1 thorpej */
198 1.1 thorpej int
199 1.18 xtraeme sysmonclose_envsys(dev_t dev, int flag, int mode, struct lwp *l)
200 1.1 thorpej {
201 1.3 jdolecek /* Nothing to do */
202 1.18 xtraeme return 0;
203 1.1 thorpej }
204 1.1 thorpej
205 1.1 thorpej /*
206 1.1 thorpej * sysmonioctl_envsys:
207 1.1 thorpej *
208 1.18 xtraeme * + Perform an envsys control request.
209 1.1 thorpej */
210 1.1 thorpej int
211 1.18 xtraeme sysmonioctl_envsys(dev_t dev, u_long cmd, void *data, int flag, struct lwp *l)
212 1.1 thorpej {
213 1.18 xtraeme struct sysmon_envsys *sme = NULL;
214 1.1 thorpej int error = 0;
215 1.18 xtraeme #ifdef COMPAT_40
216 1.1 thorpej u_int oidx;
217 1.18 xtraeme #endif
218 1.1 thorpej
219 1.1 thorpej switch (cmd) {
220 1.18 xtraeme case ENVSYS_GETDICTIONARY:
221 1.18 xtraeme {
222 1.18 xtraeme struct plistref *plist = (struct plistref *)data;
223 1.18 xtraeme
224 1.18 xtraeme /*
225 1.18 xtraeme * Update all sysmon envsys devices dictionaries with
226 1.18 xtraeme * new data if it's different than we have currently
227 1.18 xtraeme * in the dictionary.
228 1.18 xtraeme */
229 1.18 xtraeme mutex_enter(&sme_mtx);
230 1.18 xtraeme LIST_FOREACH(sme, &sysmon_envsys_list, sme_list) {
231 1.18 xtraeme if (sme == NULL)
232 1.18 xtraeme continue;
233 1.18 xtraeme
234 1.18 xtraeme error = sme_update_dictionary(sme);
235 1.18 xtraeme if (error) {
236 1.18 xtraeme DPRINTF(("%s: sme_update_dictionary, "
237 1.18 xtraeme "error=%d\n", __func__, error));
238 1.18 xtraeme mutex_exit(&sme_mtx);
239 1.18 xtraeme return error;
240 1.18 xtraeme }
241 1.18 xtraeme }
242 1.18 xtraeme mutex_exit(&sme_mtx);
243 1.18 xtraeme /*
244 1.18 xtraeme * Copy global dictionary to userland.
245 1.18 xtraeme */
246 1.18 xtraeme error = prop_dictionary_copyout_ioctl(plist, cmd, sme_propd);
247 1.1 thorpej break;
248 1.18 xtraeme }
249 1.18 xtraeme case ENVSYS_SETDICTIONARY:
250 1.1 thorpej {
251 1.18 xtraeme const struct plistref *plist = (const struct plistref *)data;
252 1.18 xtraeme prop_dictionary_t udict;
253 1.18 xtraeme prop_object_t obj;
254 1.18 xtraeme const char *devname = NULL;
255 1.18 xtraeme
256 1.22 xtraeme if ((flag & FWRITE) == 0)
257 1.22 xtraeme return EPERM;
258 1.22 xtraeme
259 1.18 xtraeme /*
260 1.18 xtraeme * Get dictionary from userland.
261 1.18 xtraeme */
262 1.18 xtraeme error = prop_dictionary_copyin_ioctl(plist, cmd, &udict);
263 1.18 xtraeme DPRINTF(("%s: copyin_ioctl error=%d\n", __func__, error));
264 1.18 xtraeme if (error)
265 1.18 xtraeme break;
266 1.4 explorer
267 1.18 xtraeme /*
268 1.18 xtraeme * Parse "driver-name" key to obtain the driver we
269 1.18 xtraeme * are searching for.
270 1.18 xtraeme */
271 1.18 xtraeme obj = prop_dictionary_get(udict, "driver-name");
272 1.18 xtraeme if (obj == NULL || prop_object_type(obj) != PROP_TYPE_STRING) {
273 1.18 xtraeme DPRINTF(("%s: driver-name failed\n", __func__));
274 1.18 xtraeme prop_object_release(udict);
275 1.18 xtraeme error = EINVAL;
276 1.18 xtraeme break;
277 1.18 xtraeme }
278 1.4 explorer
279 1.18 xtraeme /* driver name */
280 1.18 xtraeme devname = prop_string_cstring_nocopy(obj);
281 1.4 explorer
282 1.18 xtraeme /* find the correct sme device */
283 1.18 xtraeme sme = sysmon_envsys_find(devname);
284 1.18 xtraeme if (sme == NULL) {
285 1.18 xtraeme DPRINTF(("%s: NULL sme\n", __func__));
286 1.18 xtraeme prop_object_release(udict);
287 1.18 xtraeme error = EINVAL;
288 1.4 explorer break;
289 1.4 explorer }
290 1.1 thorpej
291 1.18 xtraeme /*
292 1.18 xtraeme * Find the correct array object with the string supplied
293 1.18 xtraeme * by the userland dictionary.
294 1.18 xtraeme */
295 1.18 xtraeme obj = prop_dictionary_get(sme_propd, devname);
296 1.18 xtraeme if (prop_object_type(obj) != PROP_TYPE_ARRAY) {
297 1.18 xtraeme DPRINTF(("%s: array device failed\n", __func__));
298 1.18 xtraeme prop_object_release(udict);
299 1.18 xtraeme error = EINVAL;
300 1.1 thorpej break;
301 1.1 thorpej }
302 1.18 xtraeme
303 1.18 xtraeme /* do the real work now */
304 1.18 xtraeme error = sme_userset_dictionary(sme, udict, obj);
305 1.1 thorpej sysmon_envsys_release(sme);
306 1.1 thorpej break;
307 1.1 thorpej }
308 1.18 xtraeme /*
309 1.18 xtraeme * Compatibility functions with the old interface, only
310 1.18 xtraeme * implemented ENVSYS_GTREDATA and ENVSYS_GTREINFO; enough
311 1.18 xtraeme * to make old applications work.
312 1.18 xtraeme */
313 1.18 xtraeme #ifdef COMPAT_40
314 1.1 thorpej case ENVSYS_GTREDATA:
315 1.1 thorpej {
316 1.18 xtraeme struct envsys_tre_data *tred = (void *)data;
317 1.18 xtraeme envsys_data_t *edata = NULL;
318 1.1 thorpej
319 1.1 thorpej tred->validflags = 0;
320 1.1 thorpej
321 1.18 xtraeme sme = sysmon_envsys_find_40(tred->sensor);
322 1.1 thorpej if (sme == NULL)
323 1.1 thorpej break;
324 1.18 xtraeme
325 1.18 xtraeme mutex_enter(&sme_mtx);
326 1.1 thorpej oidx = tred->sensor;
327 1.1 thorpej tred->sensor = SME_SENSOR_IDX(sme, tred->sensor);
328 1.18 xtraeme
329 1.18 xtraeme DPRINTFOBJ(("%s: sensor=%d oidx=%d dev=%s nsensors=%d\n",
330 1.18 xtraeme __func__, tred->sensor, oidx, sme->sme_name,
331 1.18 xtraeme sme->sme_nsensors));
332 1.18 xtraeme
333 1.18 xtraeme edata = &sme->sme_sensor_data[tred->sensor];
334 1.18 xtraeme
335 1.18 xtraeme if (tred->sensor < sme->sme_nsensors) {
336 1.18 xtraeme if ((sme->sme_flags & SME_DISABLE_GTREDATA) == 0) {
337 1.18 xtraeme error = (*sme->sme_gtredata)(sme, edata);
338 1.18 xtraeme if (error) {
339 1.18 xtraeme DPRINTF(("%s: sme_gtredata failed\n",
340 1.18 xtraeme __func__));
341 1.18 xtraeme mutex_exit(&sme_mtx);
342 1.18 xtraeme return error;
343 1.18 xtraeme }
344 1.18 xtraeme }
345 1.18 xtraeme
346 1.18 xtraeme /* copy required values to the old interface */
347 1.18 xtraeme tred->sensor = edata->sensor;
348 1.18 xtraeme tred->cur.data_us = edata->value_cur;
349 1.18 xtraeme tred->cur.data_s = edata->value_cur;
350 1.18 xtraeme tred->max.data_us = edata->value_max;
351 1.18 xtraeme tred->max.data_s = edata->value_max;
352 1.18 xtraeme tred->min.data_us = edata->value_min;
353 1.18 xtraeme tred->min.data_s = edata->value_min;
354 1.18 xtraeme tred->avg.data_us = edata->value_avg;
355 1.18 xtraeme tred->avg.data_s = edata->value_avg;
356 1.18 xtraeme tred->units = edata->units;
357 1.18 xtraeme
358 1.20 xtraeme tred->validflags |= ENVSYS_FVALID;
359 1.20 xtraeme tred->validflags |= ENVSYS_FCURVALID;
360 1.20 xtraeme
361 1.20 xtraeme if (edata->flags & ENVSYS_FPERCENT) {
362 1.20 xtraeme tred->validflags |= ENVSYS_FMAXVALID;
363 1.20 xtraeme tred->validflags |= ENVSYS_FFRACVALID;
364 1.20 xtraeme }
365 1.20 xtraeme
366 1.18 xtraeme if (edata->state == ENVSYS_SINVALID) {
367 1.20 xtraeme tred->validflags &= ~ENVSYS_FCURVALID;
368 1.18 xtraeme tred->cur.data_us = tred->cur.data_s = 0;
369 1.18 xtraeme }
370 1.18 xtraeme
371 1.18 xtraeme DPRINTFOBJ(("%s: sensor=%s tred->cur.data_s=%d\n",
372 1.18 xtraeme __func__, edata->desc, tred->cur.data_s));
373 1.18 xtraeme DPRINTFOBJ(("%s: tred->validflags=%d tred->units=%d"
374 1.18 xtraeme " tred->sensor=%d\n", __func__, tred->validflags,
375 1.18 xtraeme tred->units, tred->sensor));
376 1.3 jdolecek }
377 1.1 thorpej tred->sensor = oidx;
378 1.18 xtraeme mutex_exit(&sme_mtx);
379 1.1 thorpej
380 1.1 thorpej break;
381 1.1 thorpej }
382 1.1 thorpej case ENVSYS_GTREINFO:
383 1.1 thorpej {
384 1.18 xtraeme struct envsys_basic_info *binfo = (void *)data;
385 1.18 xtraeme envsys_data_t *edata = NULL;
386 1.1 thorpej
387 1.1 thorpej binfo->validflags = 0;
388 1.1 thorpej
389 1.18 xtraeme sme = sysmon_envsys_find_40(binfo->sensor);
390 1.1 thorpej if (sme == NULL)
391 1.1 thorpej break;
392 1.18 xtraeme
393 1.18 xtraeme mutex_enter(&sme_mtx);
394 1.1 thorpej oidx = binfo->sensor;
395 1.1 thorpej binfo->sensor = SME_SENSOR_IDX(sme, binfo->sensor);
396 1.18 xtraeme
397 1.18 xtraeme edata = &sme->sme_sensor_data[binfo->sensor];
398 1.18 xtraeme
399 1.20 xtraeme binfo->validflags |= ENVSYS_FVALID;
400 1.18 xtraeme
401 1.18 xtraeme if (binfo->sensor < sme->sme_nsensors) {
402 1.18 xtraeme binfo->units = edata->units;
403 1.18 xtraeme (void)strlcpy(binfo->desc, edata->desc,
404 1.18 xtraeme sizeof(binfo->desc));
405 1.18 xtraeme }
406 1.18 xtraeme
407 1.18 xtraeme DPRINTFOBJ(("%s: binfo->units=%d binfo->validflags=%d\n",
408 1.18 xtraeme __func__, binfo->units, binfo->validflags));
409 1.18 xtraeme DPRINTFOBJ(("%s: binfo->desc=%s binfo->sensor=%d\n",
410 1.18 xtraeme __func__, binfo->desc, binfo->sensor));
411 1.18 xtraeme
412 1.1 thorpej binfo->sensor = oidx;
413 1.18 xtraeme mutex_exit(&sme_mtx);
414 1.18 xtraeme
415 1.1 thorpej break;
416 1.1 thorpej }
417 1.18 xtraeme #endif /* COMPAT_40 */
418 1.1 thorpej default:
419 1.1 thorpej error = ENOTTY;
420 1.18 xtraeme break;
421 1.1 thorpej }
422 1.1 thorpej
423 1.18 xtraeme return error;
424 1.1 thorpej }
425 1.1 thorpej
426 1.1 thorpej /*
427 1.1 thorpej * sysmon_envsys_register:
428 1.1 thorpej *
429 1.18 xtraeme * + Register an envsys device.
430 1.18 xtraeme * + Create device dictionary.
431 1.1 thorpej */
432 1.1 thorpej int
433 1.1 thorpej sysmon_envsys_register(struct sysmon_envsys *sme)
434 1.1 thorpej {
435 1.18 xtraeme struct sysmon_envsys *lsme;
436 1.1 thorpej int error = 0;
437 1.1 thorpej
438 1.18 xtraeme /*
439 1.18 xtraeme * sanity check 1, make sure the driver has initialized
440 1.18 xtraeme * the sensors count or the value is not too high.
441 1.18 xtraeme */
442 1.18 xtraeme if (!sme->sme_nsensors || sme->sme_nsensors > ENVSYS_MAXSENSORS)
443 1.18 xtraeme return EINVAL;
444 1.18 xtraeme
445 1.18 xtraeme /*
446 1.18 xtraeme * sanity check 2, make sure that sme->sme_name and
447 1.18 xtraeme * sme->sme_data are not NULL.
448 1.18 xtraeme */
449 1.18 xtraeme if (sme->sme_name == NULL || sme->sme_sensor_data == NULL)
450 1.18 xtraeme return EINVAL;
451 1.1 thorpej
452 1.18 xtraeme /*
453 1.18 xtraeme * sanity check 3, if SME_DISABLE_GTREDATA is not set
454 1.18 xtraeme * the sme_gtredata function callback must be non NULL.
455 1.18 xtraeme */
456 1.18 xtraeme if ((sme->sme_flags & SME_DISABLE_GTREDATA) == 0) {
457 1.18 xtraeme if (sme->sme_gtredata == NULL)
458 1.18 xtraeme return EINVAL;
459 1.1 thorpej }
460 1.1 thorpej
461 1.18 xtraeme /*
462 1.18 xtraeme * - check if requested sysmon_envsys device is valid
463 1.18 xtraeme * and does not exist already in the list.
464 1.18 xtraeme * - add device into the list.
465 1.18 xtraeme * - create the plist structure.
466 1.18 xtraeme */
467 1.18 xtraeme mutex_enter(&sme_list_mtx);
468 1.18 xtraeme LIST_FOREACH(lsme, &sysmon_envsys_list, sme_list) {
469 1.18 xtraeme if (strcmp(lsme->sme_name, sme->sme_name) == 0) {
470 1.18 xtraeme mutex_exit(&sme_list_mtx);
471 1.18 xtraeme error = EEXIST;
472 1.18 xtraeme goto out;
473 1.18 xtraeme }
474 1.18 xtraeme }
475 1.18 xtraeme #ifdef COMPAT_40
476 1.1 thorpej sme->sme_fsensor = sysmon_envsys_next_sensor_index;
477 1.1 thorpej sysmon_envsys_next_sensor_index += sme->sme_nsensors;
478 1.18 xtraeme #endif
479 1.18 xtraeme mutex_exit(&sme_list_mtx);
480 1.18 xtraeme error = sysmon_envsys_createplist(sme);
481 1.18 xtraeme if (!error) {
482 1.18 xtraeme mutex_enter(&sme_list_mtx);
483 1.18 xtraeme LIST_INSERT_HEAD(&sysmon_envsys_list, sme, sme_list);
484 1.18 xtraeme mutex_exit(&sme_list_mtx);
485 1.18 xtraeme }
486 1.1 thorpej
487 1.18 xtraeme out:
488 1.18 xtraeme return error;
489 1.1 thorpej }
490 1.1 thorpej
491 1.1 thorpej /*
492 1.1 thorpej * sysmon_envsys_unregister:
493 1.1 thorpej *
494 1.18 xtraeme * + Unregister an envsys device.
495 1.18 xtraeme * + Unregister all events associated with this device.
496 1.18 xtraeme * + Remove device dictionary.
497 1.1 thorpej */
498 1.1 thorpej void
499 1.1 thorpej sysmon_envsys_unregister(struct sysmon_envsys *sme)
500 1.1 thorpej {
501 1.18 xtraeme sme_event_t *see;
502 1.1 thorpej
503 1.18 xtraeme mutex_enter(&sme_list_mtx);
504 1.7 yamt while (sme->sme_flags & SME_FLAG_BUSY) {
505 1.8 yamt sme->sme_flags |= SME_FLAG_WANTED;
506 1.18 xtraeme cv_wait(&sme_list_cv, &sme_list_mtx);
507 1.18 xtraeme }
508 1.18 xtraeme prop_dictionary_remove(sme_propd, sme->sme_name);
509 1.18 xtraeme LIST_FOREACH(see, &sme_events_list, see_list) {
510 1.18 xtraeme if (strcmp(see->pes.pes_dvname, sme->sme_name) == 0)
511 1.18 xtraeme sme_event_unregister(see->pes.pes_sensname,
512 1.18 xtraeme see->type);
513 1.7 yamt }
514 1.1 thorpej LIST_REMOVE(sme, sme_list);
515 1.18 xtraeme mutex_exit(&sme_list_mtx);
516 1.1 thorpej }
517 1.1 thorpej
518 1.1 thorpej /*
519 1.1 thorpej * sysmon_envsys_find:
520 1.1 thorpej *
521 1.18 xtraeme * + Find an envsys device.
522 1.1 thorpej */
523 1.1 thorpej struct sysmon_envsys *
524 1.18 xtraeme sysmon_envsys_find(const char *name)
525 1.1 thorpej {
526 1.1 thorpej struct sysmon_envsys *sme;
527 1.1 thorpej
528 1.18 xtraeme mutex_enter(&sme_list_mtx);
529 1.7 yamt again:
530 1.1 thorpej for (sme = LIST_FIRST(&sysmon_envsys_list); sme != NULL;
531 1.1 thorpej sme = LIST_NEXT(sme, sme_list)) {
532 1.18 xtraeme if (strcmp(sme->sme_name, name) == 0) {
533 1.18 xtraeme if (sme->sme_flags & SME_FLAG_BUSY) {
534 1.18 xtraeme sme->sme_flags |= SME_FLAG_WANTED;
535 1.18 xtraeme cv_wait(&sme_list_cv, &sme_list_mtx);
536 1.18 xtraeme goto again;
537 1.18 xtraeme }
538 1.18 xtraeme sme->sme_flags |= SME_FLAG_BUSY;
539 1.18 xtraeme break;
540 1.18 xtraeme }
541 1.18 xtraeme }
542 1.18 xtraeme mutex_exit(&sme_list_mtx);
543 1.18 xtraeme return sme;
544 1.18 xtraeme }
545 1.18 xtraeme
546 1.18 xtraeme /*
547 1.18 xtraeme * sysmon_envsys_release:
548 1.18 xtraeme *
549 1.18 xtraeme * + Release an envsys device.
550 1.18 xtraeme */
551 1.18 xtraeme void
552 1.18 xtraeme sysmon_envsys_release(struct sysmon_envsys *sme)
553 1.18 xtraeme {
554 1.18 xtraeme mutex_enter(&sme_list_mtx);
555 1.18 xtraeme if (sme->sme_flags & SME_FLAG_WANTED)
556 1.18 xtraeme cv_broadcast(&sme_list_cv);
557 1.18 xtraeme sme->sme_flags &= ~(SME_FLAG_BUSY | SME_FLAG_WANTED);
558 1.18 xtraeme mutex_exit(&sme_list_mtx);
559 1.18 xtraeme }
560 1.18 xtraeme
561 1.18 xtraeme /* compatibility function */
562 1.18 xtraeme #ifdef COMPAT_40
563 1.18 xtraeme struct sysmon_envsys *
564 1.18 xtraeme sysmon_envsys_find_40(u_int idx)
565 1.18 xtraeme {
566 1.18 xtraeme struct sysmon_envsys *sme;
567 1.18 xtraeme
568 1.18 xtraeme mutex_enter(&sme_list_mtx);
569 1.18 xtraeme for (sme = LIST_FIRST(&sysmon_envsys_list); sme != NULL;
570 1.18 xtraeme sme = LIST_NEXT(sme, sme_list)) {
571 1.1 thorpej if (idx >= sme->sme_fsensor &&
572 1.18 xtraeme idx < (sme->sme_fsensor + sme->sme_nsensors))
573 1.18 xtraeme break;
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 #endif
579 1.18 xtraeme
580 1.18 xtraeme /*
581 1.18 xtraeme * sysmon_envsys_createplist:
582 1.18 xtraeme *
583 1.18 xtraeme * + Create the property list structure for a device.
584 1.18 xtraeme */
585 1.18 xtraeme int
586 1.18 xtraeme sysmon_envsys_createplist(struct sysmon_envsys *sme)
587 1.18 xtraeme {
588 1.18 xtraeme envsys_data_t *edata;
589 1.18 xtraeme prop_array_t array;
590 1.18 xtraeme int i, error = 0;
591 1.18 xtraeme
592 1.18 xtraeme /* create the sysmon envsys device array. */
593 1.18 xtraeme array = prop_array_create();
594 1.18 xtraeme
595 1.18 xtraeme /*
596 1.18 xtraeme * <dict>
597 1.18 xtraeme * <key>foo0</key>
598 1.18 xtraeme * <array>
599 1.18 xtraeme * ...
600 1.18 xtraeme */
601 1.18 xtraeme mutex_enter(&sme_mtx);
602 1.18 xtraeme if (!prop_dictionary_set(sme_propd, sme->sme_name, array)) {
603 1.18 xtraeme DPRINTF(("%s: prop_dictionary_set\n", __func__));
604 1.18 xtraeme mutex_exit(&sme_mtx);
605 1.18 xtraeme error = EINVAL;
606 1.18 xtraeme goto out;
607 1.18 xtraeme }
608 1.18 xtraeme mutex_exit(&sme_mtx);
609 1.18 xtraeme
610 1.18 xtraeme /*
611 1.18 xtraeme * Iterate over all sensors and create a dictionary with all
612 1.18 xtraeme * values specified by the sysmon envsys driver.
613 1.18 xtraeme */
614 1.18 xtraeme for (i = 0; i < sme->sme_nsensors; i++) {
615 1.18 xtraeme edata = &sme->sme_sensor_data[i];
616 1.18 xtraeme /*
617 1.18 xtraeme * refresh sensor data via sme_gtredata only if the
618 1.18 xtraeme * flag is not set.
619 1.18 xtraeme */
620 1.18 xtraeme if ((sme->sme_flags & SME_DISABLE_GTREDATA) == 0) {
621 1.18 xtraeme mutex_enter(&sme_mtx);
622 1.18 xtraeme error = (*sme->sme_gtredata)(sme, edata);
623 1.18 xtraeme if (error) {
624 1.18 xtraeme DPRINTF(("%s: sme->sme_gtredata[%d]\n",
625 1.18 xtraeme __func__, i));
626 1.18 xtraeme mutex_exit(&sme_mtx);
627 1.18 xtraeme continue;
628 1.7 yamt }
629 1.18 xtraeme mutex_exit(&sme_mtx);
630 1.18 xtraeme }
631 1.18 xtraeme
632 1.18 xtraeme error = sme_make_dictionary(sme, array, edata);
633 1.23 xtraeme if (error && error != EEXIST)
634 1.18 xtraeme goto out;
635 1.23 xtraeme else {
636 1.23 xtraeme error = 0;
637 1.23 xtraeme continue;
638 1.18 xtraeme }
639 1.18 xtraeme }
640 1.18 xtraeme
641 1.18 xtraeme out:
642 1.18 xtraeme prop_object_release(array);
643 1.18 xtraeme return error;
644 1.18 xtraeme }
645 1.18 xtraeme
646 1.18 xtraeme /*
647 1.18 xtraeme * sme_make_dictionary:
648 1.18 xtraeme *
649 1.18 xtraeme * + Create sensor's dictionary in device's dictionary array.
650 1.18 xtraeme */
651 1.18 xtraeme int
652 1.18 xtraeme sme_make_dictionary(struct sysmon_envsys *sme, prop_array_t array,
653 1.18 xtraeme envsys_data_t *edata)
654 1.18 xtraeme {
655 1.18 xtraeme const struct sme_sensor_type *est = sme_sensor_type;
656 1.18 xtraeme const struct sme_sensor_state *ess = sme_sensor_state;
657 1.18 xtraeme const struct sme_sensor_state *esds = sme_sensor_drive_state;
658 1.18 xtraeme sme_event_drv_t *sme_evdrv_t = NULL;
659 1.18 xtraeme prop_dictionary_t dict;
660 1.23 xtraeme envsys_data_t *nedata = NULL;
661 1.23 xtraeme int i, j, k, l;
662 1.18 xtraeme
663 1.23 xtraeme i = j = k = l = 0;
664 1.18 xtraeme
665 1.18 xtraeme /*
666 1.18 xtraeme * <array>
667 1.18 xtraeme * <dict>
668 1.18 xtraeme * ...
669 1.18 xtraeme */
670 1.18 xtraeme dict = prop_dictionary_create();
671 1.18 xtraeme
672 1.18 xtraeme mutex_enter(&sme_mtx);
673 1.18 xtraeme if (!prop_array_add(array, dict)) {
674 1.18 xtraeme mutex_exit(&sme_mtx);
675 1.25 xtraeme prop_object_release(dict);
676 1.18 xtraeme DPRINTF(("%s: prop_array_add\n", __func__));
677 1.18 xtraeme return EINVAL;
678 1.18 xtraeme }
679 1.18 xtraeme
680 1.18 xtraeme /* find the correct unit for this sensor. */
681 1.18 xtraeme for (i = 0; est[i].type != -1; i++)
682 1.18 xtraeme if (est[i].type == edata->units)
683 1.18 xtraeme break;
684 1.18 xtraeme
685 1.18 xtraeme /*
686 1.18 xtraeme * ...
687 1.18 xtraeme * <key>type</key>
688 1.18 xtraeme * <string>foo</string>
689 1.18 xtraeme * <key>description</key>
690 1.18 xtraeme * <string>blah blah</string>
691 1.18 xtraeme * ...
692 1.18 xtraeme */
693 1.18 xtraeme SENSOR_SSTRING(dict, "type", est[i].desc);
694 1.23 xtraeme
695 1.23 xtraeme /*
696 1.23 xtraeme * Check if description was already assigned in other sensor.
697 1.23 xtraeme */
698 1.23 xtraeme for (l = 0; l < sme->sme_nsensors; l++) {
699 1.23 xtraeme /* skip the same sensor */
700 1.23 xtraeme if (l == edata->sensor)
701 1.23 xtraeme continue;
702 1.23 xtraeme nedata = &sme->sme_sensor_data[l];
703 1.23 xtraeme if (strcmp(edata->desc, nedata->desc) == 0) {
704 1.23 xtraeme edata->flags |= ENVSYS_FDUPDESC;
705 1.23 xtraeme mutex_exit(&sme_mtx);
706 1.24 xtraeme DPRINTF(("%s: dupdesc=%s sensor=%d dev=%s\n",
707 1.24 xtraeme __func__, edata->desc, edata->sensor,
708 1.24 xtraeme sme->sme_name));
709 1.23 xtraeme return EEXIST;
710 1.23 xtraeme }
711 1.23 xtraeme }
712 1.23 xtraeme
713 1.18 xtraeme SENSOR_SSTRING(dict, "description", edata->desc);
714 1.18 xtraeme
715 1.18 xtraeme /*
716 1.18 xtraeme * Add sensor's state description.
717 1.18 xtraeme *
718 1.18 xtraeme * ...
719 1.18 xtraeme * <key>state</key>
720 1.18 xtraeme * <string>valid</string>
721 1.18 xtraeme * ...
722 1.18 xtraeme */
723 1.18 xtraeme for (j = 0; ess[j].type != -1; j++)
724 1.18 xtraeme if (ess[j].type == edata->state)
725 1.7 yamt break;
726 1.18 xtraeme
727 1.18 xtraeme SENSOR_SSTRING(dict, "state", ess[j].desc);
728 1.18 xtraeme
729 1.18 xtraeme /*
730 1.18 xtraeme * add the percentage boolean object:
731 1.18 xtraeme *
732 1.18 xtraeme * ...
733 1.18 xtraeme * <key>want-percentage</key>
734 1.18 xtraeme * <true/>
735 1.18 xtraeme * ...
736 1.18 xtraeme */
737 1.18 xtraeme if (edata->flags & ENVSYS_FPERCENT)
738 1.18 xtraeme SENSOR_SBOOL(dict, "want-percentage", true);
739 1.18 xtraeme
740 1.18 xtraeme /*
741 1.18 xtraeme * Add the monitoring boolean object:
742 1.18 xtraeme *
743 1.18 xtraeme * ...
744 1.18 xtraeme * <key>monitoring-supported</key>
745 1.18 xtraeme * <true/>
746 1.18 xtraeme * ...
747 1.18 xtraeme *
748 1.21 xtraeme * always false on Drive and Indicator types, they
749 1.18 xtraeme * cannot be monitored.
750 1.18 xtraeme *
751 1.18 xtraeme */
752 1.18 xtraeme if ((edata->flags & ENVSYS_FMONNOTSUPP) ||
753 1.18 xtraeme (edata->units == ENVSYS_INDICATOR) ||
754 1.18 xtraeme (edata->units == ENVSYS_DRIVE)) {
755 1.18 xtraeme SENSOR_SBOOL(dict, "monitoring-supported", false);
756 1.18 xtraeme } else {
757 1.18 xtraeme SENSOR_SBOOL(dict, "monitoring-supported", true);
758 1.18 xtraeme }
759 1.18 xtraeme
760 1.18 xtraeme /*
761 1.18 xtraeme * Add the drive-state object for drive sensors:
762 1.18 xtraeme *
763 1.18 xtraeme * ...
764 1.18 xtraeme * <key>drive-state</key>
765 1.18 xtraeme * <string>drive is online</string>
766 1.18 xtraeme * ...
767 1.18 xtraeme */
768 1.18 xtraeme if (edata->units == ENVSYS_DRIVE) {
769 1.18 xtraeme for (k = 0; esds[k].type != -1; k++)
770 1.18 xtraeme if (esds[k].type == edata->value_cur)
771 1.18 xtraeme break;
772 1.18 xtraeme SENSOR_SSTRING(dict, "drive-state", esds[k].desc);
773 1.18 xtraeme }
774 1.18 xtraeme
775 1.18 xtraeme mutex_exit(&sme_mtx);
776 1.18 xtraeme /*
777 1.18 xtraeme * Add a new event if a monitoring flag was set.
778 1.18 xtraeme */
779 1.21 xtraeme if (edata->monitor) {
780 1.18 xtraeme sme_evdrv_t = kmem_zalloc(sizeof(*sme_evdrv_t), KM_SLEEP);
781 1.18 xtraeme
782 1.18 xtraeme sme_evdrv_t->sdict = dict;
783 1.18 xtraeme sme_evdrv_t->edata = edata;
784 1.18 xtraeme sme_evdrv_t->sme = sme;
785 1.18 xtraeme sme_evdrv_t->powertype = est[i].crittype;
786 1.18 xtraeme
787 1.18 xtraeme sysmon_task_queue_init();
788 1.18 xtraeme sysmon_task_queue_sched(0, sme_event_drvadd, sme_evdrv_t);
789 1.18 xtraeme }
790 1.18 xtraeme
791 1.18 xtraeme mutex_enter(&sme_mtx);
792 1.18 xtraeme /* if sensor is enabled, add the following properties... */
793 1.18 xtraeme if (edata->state == ENVSYS_SVALID) {
794 1.18 xtraeme /*
795 1.18 xtraeme * ...
796 1.18 xtraeme * <key>rpms</key>
797 1.18 xtraeme * <integer>2500</integer>
798 1.18 xtraeme * <key>rfact</key>
799 1.18 xtraeme * <integer>10000</integer>
800 1.18 xtraeme * <key>cur-value</key>
801 1.18 xtraeme * <integer>1250</integer>
802 1.18 xtraeme * <key>min-value</key>
803 1.18 xtraeme * <integer>800</integer>
804 1.18 xtraeme * <key>max-value</integer>
805 1.18 xtraeme * <integer>3000</integer>
806 1.18 xtraeme * <key>avg-value</integer>
807 1.18 xtraeme * <integer>1400</integer>
808 1.18 xtraeme * </dict>
809 1.18 xtraeme */
810 1.18 xtraeme if ((edata->units == ENVSYS_SFANRPM) && edata->rpms)
811 1.18 xtraeme SENSOR_SUINT32(dict, "rpms", edata->rpms);
812 1.18 xtraeme
813 1.18 xtraeme if ((edata->units == ENVSYS_SVOLTS_AC ||
814 1.18 xtraeme edata->units == ENVSYS_SVOLTS_DC) && edata->rfact)
815 1.18 xtraeme SENSOR_SINT32(dict, "rfact", edata->rfact);
816 1.18 xtraeme
817 1.18 xtraeme if (edata->value_cur)
818 1.18 xtraeme SENSOR_SINT32(dict, "cur-value", edata->value_cur);
819 1.18 xtraeme
820 1.18 xtraeme if ((edata->flags & ENVSYS_FVALID_MIN) && edata->value_min)
821 1.18 xtraeme SENSOR_SINT32(dict, "min-value", edata->value_min);
822 1.18 xtraeme
823 1.18 xtraeme if ((edata->flags & ENVSYS_FVALID_MAX) && edata->value_max)
824 1.18 xtraeme SENSOR_SINT32(dict, "max-value", edata->value_max);
825 1.18 xtraeme
826 1.18 xtraeme if ((edata->flags & ENVSYS_FVALID_AVG) && edata->value_avg)
827 1.18 xtraeme SENSOR_SINT32(dict, "avg-value", edata->value_avg);
828 1.18 xtraeme }
829 1.18 xtraeme
830 1.18 xtraeme /*
831 1.18 xtraeme * ...
832 1.18 xtraeme * </array>
833 1.18 xtraeme */
834 1.18 xtraeme out:
835 1.18 xtraeme mutex_exit(&sme_mtx);
836 1.18 xtraeme prop_object_release(dict);
837 1.18 xtraeme return 0;
838 1.18 xtraeme }
839 1.18 xtraeme
840 1.18 xtraeme /*
841 1.18 xtraeme * sme_update_dictionary:
842 1.18 xtraeme *
843 1.18 xtraeme * + Update per-sensor dictionaries with new values if there were
844 1.18 xtraeme * changes, otherwise the object in dictionary is untouched.
845 1.18 xtraeme * + Send a critical event if any sensor is in a critical condition.
846 1.18 xtraeme */
847 1.18 xtraeme int
848 1.18 xtraeme sme_update_dictionary(struct sysmon_envsys *sme)
849 1.18 xtraeme {
850 1.18 xtraeme const struct sme_sensor_state *ess = sme_sensor_state;
851 1.18 xtraeme const struct sme_sensor_state *esds = sme_sensor_drive_state;
852 1.18 xtraeme envsys_data_t *edata = NULL;
853 1.18 xtraeme prop_object_t array, obj, dict = NULL;
854 1.18 xtraeme int i, j, error = 0;
855 1.18 xtraeme
856 1.18 xtraeme /* retrieve the array of dictionaries in device. */
857 1.18 xtraeme array = prop_dictionary_get(sme_propd, sme->sme_name);
858 1.24 xtraeme if (prop_object_type(array) != PROP_TYPE_ARRAY) {
859 1.24 xtraeme DPRINTF(("%s: not an array (%s)\n", __func__, sme->sme_name));
860 1.18 xtraeme return EINVAL;
861 1.24 xtraeme }
862 1.18 xtraeme
863 1.18 xtraeme /*
864 1.18 xtraeme * - iterate over all sensors.
865 1.18 xtraeme * - fetch new data.
866 1.18 xtraeme * - check if data in dictionary is different than new data.
867 1.18 xtraeme * - update dictionary if there were changes.
868 1.18 xtraeme */
869 1.18 xtraeme for (i = 0; i < sme->sme_nsensors; i++) {
870 1.18 xtraeme edata = &sme->sme_sensor_data[i];
871 1.18 xtraeme
872 1.23 xtraeme /* skip sensors with a duplicate description */
873 1.24 xtraeme if (edata->flags & ENVSYS_FDUPDESC) {
874 1.24 xtraeme DPRINTF(("%s: dupdesc=%s sensor=%d dev=%s\n",
875 1.24 xtraeme __func__, edata->desc, edata->sensor,
876 1.24 xtraeme sme->sme_name));
877 1.23 xtraeme continue;
878 1.24 xtraeme }
879 1.23 xtraeme
880 1.18 xtraeme /*
881 1.18 xtraeme * refresh sensor data via sme_gtredata only if the
882 1.18 xtraeme * flag is not set.
883 1.18 xtraeme */
884 1.18 xtraeme if ((sme->sme_flags & SME_DISABLE_GTREDATA) == 0) {
885 1.18 xtraeme error = (*sme->sme_gtredata)(sme, edata);
886 1.18 xtraeme if (error) {
887 1.18 xtraeme DPRINTF(("%s: gtredata[%d] failed\n",
888 1.18 xtraeme __func__, i));
889 1.18 xtraeme return error;
890 1.18 xtraeme }
891 1.18 xtraeme }
892 1.18 xtraeme
893 1.18 xtraeme /* retrieve sensor's dictionary. */
894 1.18 xtraeme dict = prop_array_get(array, i);
895 1.24 xtraeme if (prop_object_type(dict) != PROP_TYPE_DICTIONARY) {
896 1.24 xtraeme DPRINTF(("%s: not a dictionary (%d:%s)\n",
897 1.24 xtraeme __func__, edata->sensor, sme->sme_name));
898 1.18 xtraeme return EINVAL;
899 1.24 xtraeme }
900 1.18 xtraeme
901 1.18 xtraeme /* update state sensor. */
902 1.18 xtraeme for (j = 0; ess[j].type != -1; j++)
903 1.18 xtraeme if (ess[j].type == edata->state)
904 1.18 xtraeme break;
905 1.18 xtraeme
906 1.18 xtraeme DPRINTFOBJ(("%s: state=%s type=%d flags=%d "
907 1.18 xtraeme "units=%d sensor=%d\n", __func__, ess[j].desc,
908 1.18 xtraeme ess[j].type, edata->flags, edata->units, edata->sensor));
909 1.18 xtraeme
910 1.18 xtraeme /* update sensor state */
911 1.18 xtraeme SENSOR_UPSTRING(dict, "state", ess[j].desc);
912 1.18 xtraeme
913 1.18 xtraeme /* update sensor current value */
914 1.18 xtraeme SENSOR_UPINT32(dict, "cur-value", edata->value_cur);
915 1.18 xtraeme
916 1.18 xtraeme /*
917 1.18 xtraeme * Integer and Indicator types do not the following
918 1.18 xtraeme * values, so skip them.
919 1.18 xtraeme */
920 1.18 xtraeme if (edata->units == ENVSYS_INTEGER ||
921 1.18 xtraeme edata->units == ENVSYS_INDICATOR)
922 1.18 xtraeme continue;
923 1.18 xtraeme
924 1.18 xtraeme /* update sensor flags */
925 1.18 xtraeme if (edata->flags & ENVSYS_FPERCENT)
926 1.18 xtraeme SENSOR_SBOOL(dict, "want-percentage", true);
927 1.18 xtraeme else {
928 1.18 xtraeme obj = prop_dictionary_get(dict, "want-percentage");
929 1.18 xtraeme if (obj)
930 1.18 xtraeme SENSOR_SBOOL(dict, "want-percentage", false);
931 1.18 xtraeme }
932 1.18 xtraeme
933 1.18 xtraeme if (edata->flags & ENVSYS_FVALID_MAX)
934 1.18 xtraeme SENSOR_UPINT32(dict, "max-value", edata->value_max);
935 1.18 xtraeme
936 1.18 xtraeme if (edata->flags & ENVSYS_FVALID_MIN)
937 1.18 xtraeme SENSOR_UPINT32(dict, "min-value", edata->value_min);
938 1.18 xtraeme
939 1.18 xtraeme if (edata->flags & ENVSYS_FVALID_AVG)
940 1.18 xtraeme SENSOR_UPINT32(dict, "avg-value", edata->value_avg);
941 1.18 xtraeme
942 1.18 xtraeme /* update 'rpms' only in ENVSYS_SFANRPM. */
943 1.18 xtraeme if (edata->units == ENVSYS_SFANRPM)
944 1.18 xtraeme SENSOR_UPUINT32(dict, "rpms", edata->rpms);
945 1.18 xtraeme
946 1.18 xtraeme /* update 'rfact' only in ENVSYS_SVOLTS_[AD]C. */
947 1.18 xtraeme if (edata->units == ENVSYS_SVOLTS_AC ||
948 1.18 xtraeme edata->units == ENVSYS_SVOLTS_DC) {
949 1.18 xtraeme SENSOR_UPINT32(dict, "rfact", edata->rfact);
950 1.18 xtraeme }
951 1.18 xtraeme
952 1.18 xtraeme /* update 'drive-state' only in ENVSYS_DRIVE. */
953 1.18 xtraeme if (edata->units == ENVSYS_DRIVE) {
954 1.18 xtraeme for (j = 0; esds[j].type != -1; j++)
955 1.18 xtraeme if (esds[j].type == edata->value_cur)
956 1.18 xtraeme break;
957 1.18 xtraeme
958 1.18 xtraeme SENSOR_UPSTRING(dict, "drive-state", esds[j].desc);
959 1.7 yamt }
960 1.1 thorpej }
961 1.1 thorpej
962 1.18 xtraeme out:
963 1.18 xtraeme return error;
964 1.1 thorpej }
965 1.1 thorpej
966 1.1 thorpej /*
967 1.18 xtraeme * sme_userset_dictionary:
968 1.1 thorpej *
969 1.18 xtraeme * + Parses the userland dictionary and run the appropiate
970 1.18 xtraeme * tasks that were requested.
971 1.1 thorpej */
972 1.18 xtraeme int
973 1.18 xtraeme sme_userset_dictionary(struct sysmon_envsys *sme, prop_dictionary_t udict,
974 1.18 xtraeme prop_array_t array)
975 1.1 thorpej {
976 1.18 xtraeme const struct sme_sensor_type *sst = sme_sensor_type;
977 1.23 xtraeme envsys_data_t *edata, *nedata;
978 1.18 xtraeme prop_dictionary_t dict;
979 1.18 xtraeme prop_object_t obj, obj1, obj2;
980 1.18 xtraeme int32_t critval;
981 1.18 xtraeme int i, error = 0;
982 1.18 xtraeme const char *blah, *sname;
983 1.18 xtraeme bool targetfound = false;
984 1.18 xtraeme
985 1.18 xtraeme blah = sname = NULL;
986 1.18 xtraeme
987 1.18 xtraeme /* get sensor's name from userland dictionary. */
988 1.18 xtraeme obj = prop_dictionary_get(udict, "sensor-name");
989 1.18 xtraeme if (prop_object_type(obj) != PROP_TYPE_STRING) {
990 1.18 xtraeme DPRINTF(("%s: sensor-name failed\n", __func__));
991 1.18 xtraeme return EINVAL;
992 1.18 xtraeme }
993 1.1 thorpej
994 1.18 xtraeme /* iterate over the sensors to find the right one */
995 1.18 xtraeme for (i = 0; i < sme->sme_nsensors; i++) {
996 1.18 xtraeme edata = &sme->sme_sensor_data[i];
997 1.18 xtraeme dict = prop_array_get(array, i);
998 1.18 xtraeme obj1 = prop_dictionary_get(dict, "description");
999 1.18 xtraeme
1000 1.18 xtraeme /* is it our sensor? */
1001 1.18 xtraeme if (!prop_string_equals(obj1, obj))
1002 1.18 xtraeme continue;
1003 1.18 xtraeme
1004 1.18 xtraeme /*
1005 1.18 xtraeme * Check if a new description operation was
1006 1.18 xtraeme * requested by the user and set new description.
1007 1.18 xtraeme */
1008 1.18 xtraeme if ((obj2 = prop_dictionary_get(udict, "new-description"))) {
1009 1.18 xtraeme targetfound = true;
1010 1.18 xtraeme blah = prop_string_cstring_nocopy(obj2);
1011 1.23 xtraeme
1012 1.23 xtraeme for (i = 0; i < sme->sme_nsensors; i++) {
1013 1.23 xtraeme if (i == edata->sensor)
1014 1.23 xtraeme continue;
1015 1.23 xtraeme
1016 1.23 xtraeme nedata = &sme->sme_sensor_data[i];
1017 1.23 xtraeme if (strcmp(blah, nedata->desc) == 0) {
1018 1.23 xtraeme error = EEXIST;
1019 1.24 xtraeme goto out;
1020 1.23 xtraeme }
1021 1.23 xtraeme }
1022 1.23 xtraeme
1023 1.18 xtraeme SENSOR_UPSTRING(dict, "description", blah);
1024 1.23 xtraeme (void)strlcpy(edata->desc, blah, sizeof(edata->desc));
1025 1.23 xtraeme
1026 1.18 xtraeme break;
1027 1.18 xtraeme }
1028 1.18 xtraeme
1029 1.18 xtraeme /* did the user want to remove a critical capacity limit? */
1030 1.18 xtraeme obj2 = prop_dictionary_get(udict, "remove-critical-cap");
1031 1.18 xtraeme if (obj2 != NULL) {
1032 1.18 xtraeme targetfound = true;
1033 1.18 xtraeme if ((edata->flags & ENVSYS_FMONNOTSUPP) ||
1034 1.18 xtraeme (edata->flags & ENVSYS_FPERCENT) == 0) {
1035 1.18 xtraeme error = ENOTSUP;
1036 1.18 xtraeme break;
1037 1.18 xtraeme }
1038 1.18 xtraeme
1039 1.18 xtraeme sname = prop_string_cstring_nocopy(obj);
1040 1.18 xtraeme error = sme_event_unregister(sname,
1041 1.18 xtraeme PENVSYS_EVENT_BATT_USERCAP);
1042 1.18 xtraeme if (error)
1043 1.18 xtraeme break;
1044 1.18 xtraeme
1045 1.18 xtraeme prop_dictionary_remove(dict, "critical-capacity");
1046 1.18 xtraeme break;
1047 1.18 xtraeme }
1048 1.18 xtraeme
1049 1.18 xtraeme /* did the user want to remove a critical min limit? */
1050 1.18 xtraeme obj2 = prop_dictionary_get(udict, "remove-cmin-limit");
1051 1.18 xtraeme if (obj2 != NULL) {
1052 1.18 xtraeme targetfound = true;
1053 1.18 xtraeme sname = prop_string_cstring_nocopy(obj);
1054 1.18 xtraeme error = sme_event_unregister(sname,
1055 1.18 xtraeme PENVSYS_EVENT_USER_CRITMIN);
1056 1.18 xtraeme if (error)
1057 1.18 xtraeme break;
1058 1.18 xtraeme
1059 1.18 xtraeme prop_dictionary_remove(dict, "critical-min-limit");
1060 1.18 xtraeme break;
1061 1.18 xtraeme }
1062 1.18 xtraeme
1063 1.18 xtraeme /* did the user want to remove a critical max limit? */
1064 1.18 xtraeme obj2 = prop_dictionary_get(udict, "remove-cmax-limit");
1065 1.18 xtraeme if (obj2 != NULL) {
1066 1.18 xtraeme targetfound = true;
1067 1.18 xtraeme sname = prop_string_cstring_nocopy(obj);
1068 1.18 xtraeme error = sme_event_unregister(sname,
1069 1.18 xtraeme PENVSYS_EVENT_USER_CRITMAX);
1070 1.18 xtraeme if (error)
1071 1.18 xtraeme break;
1072 1.7 yamt
1073 1.18 xtraeme prop_dictionary_remove(dict, "critical-max-limit");
1074 1.18 xtraeme break;
1075 1.18 xtraeme }
1076 1.18 xtraeme
1077 1.18 xtraeme /* did the user want to change rfact? */
1078 1.18 xtraeme obj2 = prop_dictionary_get(udict, "new-rfact");
1079 1.18 xtraeme if (obj2 != NULL) {
1080 1.18 xtraeme targetfound = true;
1081 1.18 xtraeme if (edata->flags & ENVSYS_FCHANGERFACT)
1082 1.18 xtraeme edata->rfact = prop_number_integer_value(obj2);
1083 1.18 xtraeme else
1084 1.18 xtraeme error = ENOTSUP;
1085 1.18 xtraeme
1086 1.18 xtraeme break;
1087 1.18 xtraeme }
1088 1.18 xtraeme
1089 1.18 xtraeme for (i = 0; sst[i].type != -1; i++)
1090 1.18 xtraeme if (sst[i].type == edata->units)
1091 1.18 xtraeme break;
1092 1.18 xtraeme
1093 1.18 xtraeme /* did the user want to set a critical capacity event? */
1094 1.18 xtraeme obj2 = prop_dictionary_get(udict, "critical-capacity");
1095 1.18 xtraeme if (obj2 != NULL) {
1096 1.18 xtraeme targetfound = true;
1097 1.18 xtraeme if ((edata->flags & ENVSYS_FMONNOTSUPP) ||
1098 1.18 xtraeme (edata->flags & ENVSYS_FPERCENT) == 0) {
1099 1.18 xtraeme error = ENOTSUP;
1100 1.18 xtraeme break;
1101 1.18 xtraeme }
1102 1.18 xtraeme
1103 1.18 xtraeme critval = prop_number_integer_value(obj2);
1104 1.18 xtraeme error = sme_event_add(dict,
1105 1.18 xtraeme edata,
1106 1.18 xtraeme sme->sme_name,
1107 1.18 xtraeme "critical-capacity",
1108 1.18 xtraeme critval,
1109 1.18 xtraeme PENVSYS_EVENT_BATT_USERCAP,
1110 1.18 xtraeme sst[i].crittype);
1111 1.18 xtraeme break;
1112 1.18 xtraeme }
1113 1.18 xtraeme
1114 1.18 xtraeme /* did the user want to set a critical max event? */
1115 1.18 xtraeme obj2 = prop_dictionary_get(udict, "critical-max-limit");
1116 1.18 xtraeme if (obj2 != NULL) {
1117 1.18 xtraeme targetfound = true;
1118 1.18 xtraeme if (edata->units == ENVSYS_INDICATOR ||
1119 1.18 xtraeme edata->flags & ENVSYS_FMONNOTSUPP) {
1120 1.18 xtraeme error = ENOTSUP;
1121 1.18 xtraeme break;
1122 1.18 xtraeme }
1123 1.18 xtraeme
1124 1.18 xtraeme critval = prop_number_integer_value(obj2);
1125 1.18 xtraeme error = sme_event_add(dict,
1126 1.18 xtraeme edata,
1127 1.18 xtraeme sme->sme_name,
1128 1.18 xtraeme "critical-max-limit",
1129 1.18 xtraeme critval,
1130 1.18 xtraeme PENVSYS_EVENT_USER_CRITMAX,
1131 1.18 xtraeme sst[i].crittype);
1132 1.18 xtraeme break;
1133 1.18 xtraeme }
1134 1.18 xtraeme
1135 1.18 xtraeme /* did the user want to set a critical min event? */
1136 1.18 xtraeme obj2 = prop_dictionary_get(udict, "critical-min-limit");
1137 1.18 xtraeme if (obj2 != NULL) {
1138 1.18 xtraeme targetfound = true;
1139 1.18 xtraeme if (edata->units == ENVSYS_INDICATOR ||
1140 1.18 xtraeme edata->flags & ENVSYS_FMONNOTSUPP) {
1141 1.18 xtraeme error = ENOTSUP;
1142 1.18 xtraeme break;
1143 1.18 xtraeme }
1144 1.18 xtraeme
1145 1.18 xtraeme critval = prop_number_integer_value(obj2);
1146 1.18 xtraeme error = sme_event_add(dict,
1147 1.18 xtraeme edata,
1148 1.18 xtraeme sme->sme_name,
1149 1.18 xtraeme "critical-min-limit",
1150 1.18 xtraeme critval,
1151 1.18 xtraeme PENVSYS_EVENT_USER_CRITMIN,
1152 1.18 xtraeme sst[i].crittype);
1153 1.18 xtraeme break;
1154 1.18 xtraeme }
1155 1.18 xtraeme }
1156 1.18 xtraeme
1157 1.18 xtraeme /* invalid target? return the error */
1158 1.18 xtraeme if (!targetfound)
1159 1.18 xtraeme error = EINVAL;
1160 1.18 xtraeme
1161 1.18 xtraeme out:
1162 1.18 xtraeme return error;
1163 1.1 thorpej }
1164