1 /*
2 * CDDL HEADER START
3 *
4 * The contents of this file are subject to the terms of the
5 * Common Development and Distribution License (the "License").
6 * You may not use this file except in compliance with the License.
7 *
8 * You can obtain a copy of the license at usr/src/OPENSOLARIS.LICENSE
9 * or http://www.opensolaris.org/os/licensing.
10 * See the License for the specific language governing permissions
11 * and limitations under the License.
12 *
13 * When distributing Covered Code, include this CDDL HEADER in each
14 * file and include the License file at usr/src/OPENSOLARIS.LICENSE.
15 * If applicable, add the following below this CDDL HEADER, with the
16 * fields enclosed by brackets "[]" replaced with your own identifying
17 * information: Portions Copyright [yyyy] [name of copyright owner]
18 *
19 * CDDL HEADER END
20 */
21
22 /*
23 * Copyright (c) 2004, 2010, Oracle and/or its affiliates. All rights reserved.
24 */
25
26 #include <strings.h>
27 #include <limits.h>
28 #include <unistd.h>
29 #include <stdlib.h>
30 #include <alloca.h>
31
32 #include <fmd_rpc_adm.h>
33 #include <fmd_rpc.h>
34 #include <fmd_module.h>
35 #include <fmd_ustat.h>
36 #include <fmd_error.h>
37 #include <fmd_asru.h>
38 #include <fmd_ckpt.h>
39 #include <fmd_case.h>
40 #include <fmd_fmri.h>
41 #include <fmd_idspace.h>
42 #include <fmd_xprt.h>
43
44 #include <fmd.h>
45
46 bool_t
47 fmd_adm_modinfo_1_svc(struct fmd_rpc_modlist *rvp, struct svc_req *req)
48 {
49 struct fmd_rpc_modinfo *rmi;
50 fmd_module_t *mp;
51
52 rvp->rml_list = NULL;
53 rvp->rml_err = 0;
54 rvp->rml_len = 0;
55
56 if (fmd_rpc_deny(req)) {
57 rvp->rml_err = FMD_ADM_ERR_PERM;
58 return (TRUE);
59 }
60
61 (void) pthread_mutex_lock(&fmd.d_mod_lock);
62
63 for (mp = fmd_list_next(&fmd.d_mod_list);
64 mp != NULL; mp = fmd_list_next(mp)) {
65
66 if ((rmi = malloc(sizeof (struct fmd_rpc_modinfo))) == NULL) {
67 rvp->rml_err = FMD_ADM_ERR_NOMEM;
68 break;
69 }
70
71 fmd_module_lock(mp);
72
73 /*
74 * If mod_info is NULL, the module is in the middle of loading:
75 * do not report its presence to observability tools yet.
76 */
77 if (mp->mod_info == NULL) {
78 fmd_module_unlock(mp);
79 free(rmi);
80 continue;
81 }
82
83 rmi->rmi_name = strdup(mp->mod_name);
84 rmi->rmi_desc = strdup(mp->mod_info->fmdi_desc);
85 rmi->rmi_vers = strdup(mp->mod_info->fmdi_vers);
86 rmi->rmi_faulty = mp->mod_error != 0;
87 rmi->rmi_next = rvp->rml_list;
88
89 fmd_module_unlock(mp);
90 rvp->rml_list = rmi;
91 rvp->rml_len++;
92
93 if (rmi->rmi_desc == NULL || rmi->rmi_vers == NULL) {
94 rvp->rml_err = FMD_ADM_ERR_NOMEM;
95 break;
96 }
97 }
98
99 (void) pthread_mutex_unlock(&fmd.d_mod_lock);
100 return (TRUE);
101 }
102
103 bool_t
104 fmd_adm_modcstat_1_svc(char *name,
105 struct fmd_rpc_modstat *rms, struct svc_req *req)
106 {
107 fmd_ustat_snap_t snap;
108 fmd_module_t *mp;
109
110 rms->rms_buf.rms_buf_val = NULL;
111 rms->rms_buf.rms_buf_len = 0;
112 rms->rms_err = 0;
113
114 if (fmd_rpc_deny(req)) {
115 rms->rms_err = FMD_ADM_ERR_PERM;
116 return (TRUE);
117 }
118
119 if ((mp = fmd_modhash_lookup(fmd.d_mod_hash, name)) == NULL) {
120 rms->rms_err = FMD_ADM_ERR_MODSRCH;
121 return (TRUE);
122 }
123
124 if (fmd_modstat_snapshot(mp, &snap) == 0) {
125 rms->rms_buf.rms_buf_val = snap.uss_buf;
126 rms->rms_buf.rms_buf_len = snap.uss_len;
127 } else if (errno == EFMD_HDL_ABORT) {
128 rms->rms_err = FMD_ADM_ERR_MODFAIL;
129 } else
130 rms->rms_err = FMD_ADM_ERR_NOMEM;
131
132 fmd_module_rele(mp);
133 return (TRUE);
134 }
135
136 bool_t
137 fmd_adm_moddstat_1_svc(char *name,
138 struct fmd_rpc_modstat *rms, struct svc_req *req)
139 {
140 fmd_module_t *mp;
141
142 rms->rms_buf.rms_buf_val = NULL;
143 rms->rms_buf.rms_buf_len = 0;
144 rms->rms_err = 0;
145
146 if (fmd_rpc_deny(req)) {
147 rms->rms_err = FMD_ADM_ERR_PERM;
148 return (TRUE);
149 }
150
151 if ((mp = fmd_modhash_lookup(fmd.d_mod_hash, name)) == NULL) {
152 rms->rms_err = FMD_ADM_ERR_MODSRCH;
153 return (TRUE);
154 }
155
156 rms->rms_buf.rms_buf_val = malloc(sizeof (fmd_modstat_t));
157 rms->rms_buf.rms_buf_len = sizeof (fmd_modstat_t) / sizeof (fmd_stat_t);
158
159 if (rms->rms_buf.rms_buf_val == NULL) {
160 rms->rms_err = FMD_ADM_ERR_NOMEM;
161 rms->rms_buf.rms_buf_len = 0;
162 fmd_module_rele(mp);
163 return (TRUE);
164 }
165
166 /*
167 * Note: the bcopy() here is valid only if no FMD_TYPE_STRING stats
168 * are present in mp->mod_stats. We don't use any for the daemon-
169 * maintained stats and provide this function in order to reduce the
170 * overhead of the fmstat(1M) default view, where these minimal stats
171 * must be retrieved for all of the active modules.
172 */
173 (void) pthread_mutex_lock(&mp->mod_stats_lock);
174
175 if (mp->mod_stats != NULL) {
176 mp->mod_stats->ms_snaptime.fmds_value.ui64 = gethrtime();
177 bcopy(mp->mod_stats, rms->rms_buf.rms_buf_val,
178 sizeof (fmd_modstat_t));
179 } else {
180 free(rms->rms_buf.rms_buf_val);
181 rms->rms_buf.rms_buf_val = NULL;
182 rms->rms_buf.rms_buf_len = 0;
183 rms->rms_err = FMD_ADM_ERR_MODFAIL;
184 }
185
186 (void) pthread_mutex_unlock(&mp->mod_stats_lock);
187 fmd_module_rele(mp);
188 return (TRUE);
189 }
190
191 bool_t
192 fmd_adm_modgstat_1_svc(struct fmd_rpc_modstat *rms, struct svc_req *req)
193 {
194 const size_t size = sizeof (fmd_statistics_t);
195
196 if (fmd_rpc_deny(req)) {
197 rms->rms_buf.rms_buf_val = NULL;
198 rms->rms_buf.rms_buf_len = 0;
199 rms->rms_err = FMD_ADM_ERR_PERM;
200 } else if ((rms->rms_buf.rms_buf_val = malloc(size)) != NULL) {
201 /*
202 * Note: the bcopy() here is valid only if no FMD_TYPE_STRING
203 * stats are present in fmd.d_stats (see definition in fmd.c).
204 */
205 (void) pthread_mutex_lock(&fmd.d_stats_lock);
206 bcopy(fmd.d_stats, rms->rms_buf.rms_buf_val, size);
207 (void) pthread_mutex_unlock(&fmd.d_stats_lock);
208 rms->rms_buf.rms_buf_len = size / sizeof (fmd_stat_t);
209 rms->rms_err = 0;
210 } else {
211 rms->rms_buf.rms_buf_len = 0;
212 rms->rms_err = FMD_ADM_ERR_NOMEM;
213 }
214
215 return (TRUE);
216 }
217
218 bool_t
219 fmd_adm_modload_1_svc(char *path, int *rvp, struct svc_req *req)
220 {
221 fmd_module_t *mp;
222 const char *p;
223 int err = 0;
224
225 if (fmd_rpc_deny(req)) {
226 *rvp = FMD_ADM_ERR_PERM;
227 return (TRUE);
228 }
229
230 /*
231 * Before we endure the expense of constructing a module and attempting
232 * to load it, do a quick check to see if the pathname is valid.
233 */
234 if (access(path, F_OK) != 0) {
235 *rvp = FMD_ADM_ERR_MODNOENT;
236 return (TRUE);
237 }
238
239 if ((p = strrchr(path, '.')) != NULL && strcmp(p, ".so") == 0)
240 mp = fmd_modhash_load(fmd.d_mod_hash, path, &fmd_rtld_ops);
241 else
242 mp = fmd_modhash_load(fmd.d_mod_hash, path, &fmd_proc_ops);
243
244 if (mp == NULL) {
245 switch (errno) {
246 case EFMD_MOD_LOADED:
247 err = FMD_ADM_ERR_MODEXIST;
248 break;
249 case EFMD_MOD_INIT:
250 err = FMD_ADM_ERR_MODINIT;
251 break;
252 default:
253 err = FMD_ADM_ERR_MODLOAD;
254 break;
255 }
256 }
257
258 *rvp = err;
259 return (TRUE);
260 }
261
262 bool_t
263 fmd_adm_modunload_1_svc(char *name, int *rvp, struct svc_req *req)
264 {
265 fmd_module_t *mp = NULL;
266 int err = 0;
267
268 if (fmd_rpc_deny(req))
269 err = FMD_ADM_ERR_PERM;
270 else if ((mp = fmd_modhash_lookup(fmd.d_mod_hash, name)) == NULL)
271 err = FMD_ADM_ERR_MODSRCH;
272 else if (mp == fmd.d_self)
273 err = FMD_ADM_ERR_MODBUSY;
274 else if (fmd_modhash_unload(fmd.d_mod_hash, name) != 0)
275 err = FMD_ADM_ERR_MODSRCH;
276
277 if (mp != NULL)
278 fmd_module_rele(mp);
279
280 *rvp = err;
281 return (TRUE);
282 }
283
284 bool_t
285 fmd_adm_modreset_1_svc(char *name, int *rvp, struct svc_req *req)
286 {
287 fmd_module_t *mp = NULL;
288 int err = 0;
289
290 if (fmd_rpc_deny(req))
291 err = FMD_ADM_ERR_PERM;
292 else if ((mp = fmd_modhash_lookup(fmd.d_mod_hash, name)) == NULL)
293 err = FMD_ADM_ERR_MODSRCH;
294 else if (mp == fmd.d_self)
295 err = FMD_ADM_ERR_MODBUSY;
296 else if (fmd_modhash_unload(fmd.d_mod_hash, name) != 0)
297 err = FMD_ADM_ERR_MODSRCH;
298
299 if (err == 0)
300 fmd_ckpt_delete(mp); /* erase any saved checkpoints */
301
302 if (err == 0 && fmd_modhash_load(fmd.d_mod_hash,
303 mp->mod_path, mp->mod_ops) == NULL) {
304 if (errno == EFMD_MOD_INIT)
305 err = FMD_ADM_ERR_MODINIT;
306 else
307 err = FMD_ADM_ERR_MODLOAD;
308 }
309
310 if (mp != NULL)
311 fmd_module_rele(mp);
312
313 *rvp = err;
314 return (TRUE);
315 }
316
317 bool_t
318 fmd_adm_modgc_1_svc(char *name, int *rvp, struct svc_req *req)
319 {
320 fmd_module_t *mp;
321 int err = 0;
322
323 if (fmd_rpc_deny(req))
324 err = FMD_ADM_ERR_PERM;
325 else if ((mp = fmd_modhash_lookup(fmd.d_mod_hash, name)) == NULL)
326 err = FMD_ADM_ERR_MODSRCH;
327 else {
328 fmd_module_gc(mp);
329 fmd_module_rele(mp);
330 }
331
332 *rvp = err;
333 return (TRUE);
334 }
335
336 /*
337 * Unlike our other RPC callbacks, fmd_adm_rsrclist_1 can return large amounts
338 * of data that may exceed the underlying RPC transport buffer size if the
339 * resource cache is heavily populated and/or all resources are requested.
340 * To minimize the likelihood of running out of RPC buffer space and having to
341 * fail the client request, fmd_adm_rsrclist_1 returns a snapshot of the
342 * relevant FMRI strings only: the client can use fmd_adm_rsrcinfo_1 on an
343 * individual FMRI if more information is needed. To further reduce the XDR
344 * overhead, the string list is represented as XDR-opaque data where the
345 * entire list is returned as a string table (e.g. "fmriA\0fmriB\0...").
346 */
347 static void
348 fmd_adm_rsrclist_asru(fmd_asru_t *ap, void *arg)
349 {
350 struct fmd_rpc_rsrclist *rrl = arg;
351 size_t name_len, buf_len;
352 void *p;
353
354 /*
355 * Skip the ASRU if this fault is marked as invisible.
356 * If rrl_all is false, we take a quick look at asru_flags with no lock
357 * held to see if the ASRU is not faulty. If so,
358 * we don't want to report it by default and can just skip this ASRU.
359 * This helps keep overhead low in the common case, as the call to
360 * fmd_asru_getstate() can be expensive depending on the scheme.
361 */
362
363 if (ap->asru_flags & FMD_ASRU_INVISIBLE)
364 return;
365 if (rrl->rrl_all == B_FALSE && !(ap->asru_flags & FMD_ASRU_FAULTY))
366 return;
367
368 if (rrl->rrl_err != 0 || fmd_asru_getstate(ap) == 0)
369 return; /* error has occurred or resource is in 'ok' state */
370
371 /*
372 * Lock the ASRU and reallocate rrl_buf[] to be large enough to hold
373 * another string, doubling it as needed. Then copy the new string
374 * on to the end, and increment rrl_len to indicate the used space.
375 */
376 (void) pthread_mutex_lock(&ap->asru_lock);
377 name_len = strlen(ap->asru_name) + 1;
378
379 while (rrl->rrl_len + name_len > rrl->rrl_buf.rrl_buf_len) {
380 if (rrl->rrl_buf.rrl_buf_len != 0)
381 buf_len = rrl->rrl_buf.rrl_buf_len * 2;
382 else
383 buf_len = 1024; /* default buffer size */
384
385 if ((p = realloc(rrl->rrl_buf.rrl_buf_val, buf_len)) != NULL) {
386 bzero((char *)p + rrl->rrl_buf.rrl_buf_len,
387 buf_len - rrl->rrl_buf.rrl_buf_len);
388 rrl->rrl_buf.rrl_buf_val = p;
389 rrl->rrl_buf.rrl_buf_len = buf_len;
390 } else {
391 rrl->rrl_err = FMD_ADM_ERR_NOMEM;
392 break;
393 }
394 }
395
396 if (rrl->rrl_err == 0) {
397 bcopy(ap->asru_name, (char *)rrl->rrl_buf.rrl_buf_val +
398 rrl->rrl_len, name_len);
399 rrl->rrl_len += name_len;
400 rrl->rrl_cnt++;
401 }
402
403 (void) pthread_mutex_unlock(&ap->asru_lock);
404 }
405
406 bool_t
407 fmd_adm_rsrclist_1_svc(bool_t all,
408 struct fmd_rpc_rsrclist *rvp, struct svc_req *req)
409 {
410 rvp->rrl_buf.rrl_buf_len = 0;
411 rvp->rrl_buf.rrl_buf_val = NULL;
412 rvp->rrl_len = 0;
413 rvp->rrl_cnt = 0;
414 rvp->rrl_err = 0;
415 rvp->rrl_all = all;
416
417 if (fmd_rpc_deny(req))
418 rvp->rrl_err = FMD_ADM_ERR_PERM;
419 else
420 fmd_asru_hash_apply(fmd.d_asrus, fmd_adm_rsrclist_asru, rvp);
421
422 return (TRUE);
423 }
424
425 bool_t
426 fmd_adm_rsrcinfo_1_svc(char *fmri,
427 struct fmd_rpc_rsrcinfo *rvp, struct svc_req *req)
428 {
429 fmd_asru_t *ap;
430 fmd_case_impl_t *cip;
431 int state;
432
433 bzero(rvp, sizeof (struct fmd_rpc_rsrcinfo));
434
435 if (fmd_rpc_deny(req)) {
436 rvp->rri_err = FMD_ADM_ERR_PERM;
437 return (TRUE);
438 }
439
440 if ((ap = fmd_asru_hash_lookup_name(fmd.d_asrus, fmri)) == NULL) {
441 rvp->rri_err = FMD_ADM_ERR_RSRCSRCH;
442 return (TRUE);
443 }
444
445 state = fmd_asru_getstate(ap);
446 (void) pthread_mutex_lock(&ap->asru_lock);
447 cip = (fmd_case_impl_t *)ap->asru_case;
448
449 rvp->rri_fmri = strdup(ap->asru_name);
450 rvp->rri_uuid = strdup(ap->asru_uuid);
451 rvp->rri_case = cip ? strdup(cip->ci_uuid) : NULL;
452 rvp->rri_faulty = (state & FMD_ASRU_FAULTY) != 0;
453 rvp->rri_unusable = (state & FMD_ASRU_UNUSABLE) != 0;
454 rvp->rri_invisible = (ap->asru_flags & FMD_ASRU_INVISIBLE) != 0;
455
456 (void) pthread_mutex_unlock(&ap->asru_lock);
457 fmd_asru_hash_release(fmd.d_asrus, ap);
458
459 if (rvp->rri_fmri == NULL || rvp->rri_uuid == NULL)
460 rvp->rri_err = FMD_ADM_ERR_NOMEM;
461
462 return (TRUE);
463 }
464
465 static void
466 fmd_adm_do_repair(char *name, struct svc_req *req, int *errp, uint8_t reason,
467 char *uuid)
468 {
469 if (fmd_rpc_deny(req))
470 *errp = FMD_ADM_ERR_PERM;
471 else {
472 fmd_asru_rep_arg_t fara;
473 int err = FARA_ERR_RSRCNOTF;
474
475 fara.fara_reason = reason;
476 fara.fara_rval = &err;
477 fara.fara_uuid = uuid;
478 fara.fara_bywhat = FARA_BY_ASRU;
479 fmd_asru_hash_apply_by_asru(fmd.d_asrus, name,
480 fmd_asru_repaired, &fara);
481 fara.fara_bywhat = FARA_BY_LABEL;
482 fmd_asru_hash_apply_by_label(fmd.d_asrus, name,
483 fmd_asru_repaired, &fara);
484 fara.fara_bywhat = FARA_BY_FRU;
485 fmd_asru_hash_apply_by_fru(fmd.d_asrus, name,
486 fmd_asru_repaired, &fara);
487 fara.fara_bywhat = FARA_BY_RSRC;
488 fmd_asru_hash_apply_by_rsrc(fmd.d_asrus, name,
489 fmd_asru_repaired, &fara);
490 if (err == FARA_ERR_RSRCNOTR)
491 *errp = FMD_ADM_ERR_RSRCNOTR;
492 else if (err == FARA_OK)
493 *errp = 0;
494 }
495 }
496
497 bool_t
498 fmd_adm_rsrcflush_1_svc(char *name, int *rvp, struct svc_req *req)
499 {
500 int err = FMD_ADM_ERR_RSRCNOTF;
501
502 /*
503 * If anyone does an fmadm flush command, discard any resolved
504 * cases that were being retained for historic diagnosis.
505 */
506 if (fmd_rpc_deny(req))
507 err = FMD_ADM_ERR_PERM;
508 else {
509 fmd_asru_hash_apply_by_asru(fmd.d_asrus, name,
510 fmd_asru_flush, &err);
511 fmd_asru_hash_apply_by_label(fmd.d_asrus, name,
512 fmd_asru_flush, &err);
513 fmd_asru_hash_apply_by_fru(fmd.d_asrus, name,
514 fmd_asru_flush, &err);
515 fmd_asru_hash_apply_by_rsrc(fmd.d_asrus, name,
516 fmd_asru_flush, &err);
517 }
518 *rvp = err;
519 return (TRUE);
520 }
521
522 bool_t
523 fmd_adm_rsrcrepaired_1_svc(char *name, int *rvp, struct svc_req *req)
524 {
525 int err = FMD_ADM_ERR_RSRCNOTF;
526
527 fmd_adm_do_repair(name, req, &err, FMD_ASRU_REPAIRED, NULL);
528 *rvp = err;
529 return (TRUE);
530 }
531
532 bool_t
533 fmd_adm_rsrcreplaced_1_svc(char *name, int *rvp, struct svc_req *req)
534 {
535 int err = FMD_ADM_ERR_RSRCNOTF;
536
537 fmd_adm_do_repair(name, req, &err, FMD_ASRU_REPLACED, NULL);
538 *rvp = err;
539 return (TRUE);
540 }
541
542 bool_t
543 fmd_adm_rsrcacquit_1_svc(char *name, char *uuid, int *rvp, struct svc_req *req)
544 {
545 int err = FMD_ADM_ERR_RSRCNOTF;
546
547 fmd_adm_do_repair(name, req, &err, FMD_ASRU_ACQUITTED, uuid);
548 *rvp = err;
549 return (TRUE);
550 }
551
552 static void
553 fmd_adm_serdlist_measure(fmd_serd_eng_t *sgp, void *arg)
554 {
555 struct fmd_rpc_serdlist *rsl = arg;
556
557 rsl->rsl_len += strlen(sgp->sg_name) + 1;
558 rsl->rsl_cnt++;
559 }
560
561 static void
562 fmd_adm_serdlist_record(fmd_serd_eng_t *sgp, void *arg)
563 {
564 struct fmd_rpc_serdlist *rsl = arg;
565
566 bcopy(sgp->sg_name, rsl->rsl_buf.rsl_buf_val + rsl->rsl_len,
567 strlen(sgp->sg_name));
568 rsl->rsl_len += strlen(sgp->sg_name) + 1;
569 }
570
571 bool_t
572 fmd_adm_serdlist_1_svc(char *name, struct fmd_rpc_serdlist *rvp,
573 struct svc_req *req)
574 {
575 fmd_module_t *mp;
576 void *p;
577
578 rvp->rsl_buf.rsl_buf_len = 0;
579 rvp->rsl_buf.rsl_buf_val = NULL;
580 rvp->rsl_len = 0;
581 rvp->rsl_cnt = 0;
582 rvp->rsl_err = 0;
583
584 if (fmd_rpc_deny(req)) {
585 rvp->rsl_err = FMD_ADM_ERR_PERM;
586 return (TRUE);
587 }
588
589 if ((mp = fmd_modhash_lookup(fmd.d_mod_hash, name)) == NULL) {
590 rvp->rsl_err = FMD_ADM_ERR_MODSRCH;
591 return (TRUE);
592 }
593
594 fmd_module_lock(mp);
595 /* In the first pass, collect the overall length of the buffer. */
596 fmd_serd_hash_apply(&mp->mod_serds, fmd_adm_serdlist_measure, rvp);
597 if (rvp->rsl_len == 0) {
598 fmd_module_unlock(mp);
599 fmd_module_rele(mp);
600 return (TRUE);
601 }
602 p = malloc(rvp->rsl_len);
603 if (p) {
604 rvp->rsl_buf.rsl_buf_val = p;
605 rvp->rsl_buf.rsl_buf_len = rvp->rsl_len;
606 bzero(rvp->rsl_buf.rsl_buf_val, rvp->rsl_buf.rsl_buf_len);
607 rvp->rsl_len = 0;
608 /* In the second pass, populate the buffer with data. */
609 fmd_serd_hash_apply(&mp->mod_serds, fmd_adm_serdlist_record,
610 rvp);
611 } else {
612 rvp->rsl_err = FMD_ADM_ERR_NOMEM;
613 }
614 fmd_module_unlock(mp);
615
616 fmd_module_rele(mp);
617 return (TRUE);
618 }
619
620 static void
621 fmd_adm_serdinfo_record(fmd_serd_eng_t *sgp, struct fmd_rpc_serdinfo *rsi)
622 {
623 uint64_t old, now = fmd_time_gethrtime();
624 const fmd_serd_elem_t *oep;
625
626 if ((rsi->rsi_name = strdup(sgp->sg_name)) == NULL) {
627 rsi->rsi_err = FMD_ADM_ERR_NOMEM;
628 return;
629 }
630
631 if ((oep = fmd_list_next(&sgp->sg_list)) != NULL)
632 old = fmd_event_hrtime(oep->se_event);
633 else
634 old = now;
635
636 rsi->rsi_delta = now >= old ? now - old : (UINT64_MAX - old) + now + 1;
637 rsi->rsi_count = sgp->sg_count;
638 rsi->rsi_fired = fmd_serd_eng_fired(sgp) != 0;
639 rsi->rsi_n = sgp->sg_n;
640 rsi->rsi_t = sgp->sg_t;
641 }
642
643 bool_t
644 fmd_adm_serdinfo_1_svc(char *mname, char *sname, struct fmd_rpc_serdinfo *rvp,
645 struct svc_req *req)
646 {
647 fmd_module_t *mp;
648 fmd_serd_eng_t *sgp;
649
650 bzero(rvp, sizeof (struct fmd_rpc_serdinfo));
651
652 if (fmd_rpc_deny(req)) {
653 rvp->rsi_err = FMD_ADM_ERR_PERM;
654 return (TRUE);
655 }
656
657 if ((mp = fmd_modhash_lookup(fmd.d_mod_hash, mname)) == NULL) {
658 rvp->rsi_err = FMD_ADM_ERR_MODSRCH;
659 return (TRUE);
660 }
661
662 fmd_module_lock(mp);
663
664 if ((sgp = fmd_serd_eng_lookup(&mp->mod_serds, sname)) != NULL) {
665 fmd_adm_serdinfo_record(sgp, rvp);
666 } else
667 rvp->rsi_err = FMD_ADM_ERR_SERDSRCH;
668
669 fmd_module_unlock(mp);
670 fmd_module_rele(mp);
671
672 return (TRUE);
673 }
674
675 /*ARGSUSED*/
676 bool_t
677 fmd_adm_serdinfo_old_1_svc(char *name, struct fmd_rpc_serdlist *rvp,
678 struct svc_req *req)
679 {
680 return (FALSE);
681 }
682
683 bool_t
684 fmd_adm_serdreset_1_svc(char *mname, char *sname, int *rvp, struct svc_req *req)
685 {
686 fmd_module_t *mp;
687 fmd_serd_eng_t *sgp;
688 int err = 0;
689
690 if (fmd_rpc_deny(req)) {
691 *rvp = FMD_ADM_ERR_PERM;
692 return (TRUE);
693 }
694
695 if ((mp = fmd_modhash_lookup(fmd.d_mod_hash, mname)) == NULL) {
696 *rvp = FMD_ADM_ERR_MODSRCH;
697 return (TRUE);
698 }
699
700 fmd_module_lock(mp);
701
702 if ((sgp = fmd_serd_eng_lookup(&mp->mod_serds, sname)) != NULL) {
703 if (fmd_serd_eng_fired(sgp)) {
704 err = FMD_ADM_ERR_SERDFIRED;
705 } else {
706 fmd_serd_eng_reset(sgp);
707 fmd_module_setdirty(mp);
708 }
709 } else
710 err = FMD_ADM_ERR_SERDSRCH;
711
712 fmd_module_unlock(mp);
713 fmd_module_rele(mp);
714
715 *rvp = err;
716 return (TRUE);
717 }
718
719 bool_t
720 fmd_adm_logrotate_1_svc(char *name, int *rvp, struct svc_req *req)
721 {
722 fmd_log_t **lpp, *old, *new;
723 int try = 1, trylimit = 1;
724 pthread_rwlock_t *lockp;
725
726 hrtime_t nsec = 0;
727 timespec_t tv;
728
729 if (fmd_rpc_deny(req)) {
730 *rvp = FMD_ADM_ERR_PERM;
731 return (TRUE);
732 }
733
734 if (strcmp(name, "errlog") == 0) {
735 lpp = &fmd.d_errlog;
736 lockp = &fmd.d_log_lock;
737 } else if (strcmp(name, "fltlog") == 0) {
738 lpp = &fmd.d_fltlog;
739 lockp = &fmd.d_log_lock;
740 } else if (strcmp(name, "infolog") == 0) {
741 lpp = &fmd.d_ilog;
742 lockp = &fmd.d_ilog_lock;
743 } else if (strcmp(name, "infolog_hival") == 0) {
744 lpp = &fmd.d_hvilog;
745 lockp = &fmd.d_hvilog_lock;
746 } else {
747 *rvp = FMD_ADM_ERR_ROTSRCH;
748 return (TRUE);
749 }
750
751 (void) fmd_conf_getprop(fmd.d_conf, "log.tryrotate", &trylimit);
752 (void) fmd_conf_getprop(fmd.d_conf, "log.waitrotate", &nsec);
753
754 tv.tv_sec = nsec / NANOSEC;
755 tv.tv_nsec = nsec % NANOSEC;
756
757 /*
758 * To rotate a log file, grab d_log_lock as writer to make sure no
759 * one else can discover the current log pointer. Then try to rotate
760 * the log. If we're successful, release the old log pointer.
761 */
762 do {
763 if (try > 1)
764 (void) nanosleep(&tv, NULL); /* wait for checkpoints */
765
766 (void) pthread_rwlock_wrlock(lockp);
767 old = *lpp;
768
769 if ((new = fmd_log_rotate(old)) != NULL) {
770 fmd_log_rele(old);
771 *lpp = new;
772 }
773
774 (void) pthread_rwlock_unlock(lockp);
775
776 } while (new == NULL && errno == EFMD_LOG_ROTBUSY && try++ < trylimit);
777
778 if (new != NULL)
779 *rvp = 0;
780 else if (errno == EFMD_LOG_ROTBUSY)
781 *rvp = FMD_ADM_ERR_ROTBUSY;
782 else
783 *rvp = FMD_ADM_ERR_ROTFAIL;
784
785 return (TRUE);
786 }
787
788 bool_t
789 fmd_adm_caserepair_1_svc(char *uuid, int *rvp, struct svc_req *req)
790 {
791 fmd_case_t *cp = NULL;
792 int err = 0;
793
794 if (fmd_rpc_deny(req))
795 err = FMD_ADM_ERR_PERM;
796 else if ((cp = fmd_case_hash_lookup(fmd.d_cases, uuid)) == NULL)
797 err = FMD_ADM_ERR_CASESRCH;
798 else if (fmd_case_repair(cp) != 0) {
799 err = errno == EFMD_CASE_OWNER ?
800 FMD_ADM_ERR_CASEXPRT : FMD_ADM_ERR_CASEOPEN;
801 }
802
803 if (cp != NULL)
804 fmd_case_rele(cp);
805
806 *rvp = err;
807 return (TRUE);
808 }
809
810 bool_t
811 fmd_adm_caseacquit_1_svc(char *uuid, int *rvp, struct svc_req *req)
812 {
813 fmd_case_t *cp = NULL;
814 int err = 0;
815
816 if (fmd_rpc_deny(req))
817 err = FMD_ADM_ERR_PERM;
818 else if ((cp = fmd_case_hash_lookup(fmd.d_cases, uuid)) == NULL)
819 err = FMD_ADM_ERR_CASESRCH;
820 else if (fmd_case_acquit(cp) != 0) {
821 err = errno == EFMD_CASE_OWNER ?
822 FMD_ADM_ERR_CASEXPRT : FMD_ADM_ERR_CASEOPEN;
823 }
824
825 if (cp != NULL)
826 fmd_case_rele(cp);
827
828 *rvp = err;
829 return (TRUE);
830 }
831
832 void
833 fmd_adm_caselist_case(fmd_case_t *cp, void *arg)
834 {
835 fmd_case_impl_t *cip = (fmd_case_impl_t *)cp;
836 struct fmd_rpc_caselist *rcl = arg;
837 size_t uuid_len, buf_len;
838 void *p;
839
840 if (rcl->rcl_err != 0)
841 return;
842
843 /*
844 * skip invisible cases
845 */
846 if (cip->ci_flags & FMD_CF_INVISIBLE)
847 return;
848
849 /*
850 * Lock the case and reallocate rcl_buf[] to be large enough to hold
851 * another string, doubling it as needed. Then copy the new string
852 * on to the end, and increment rcl_len to indicate the used space.
853 */
854 if (!(cip->ci_flags & FMD_CF_SOLVED))
855 return;
856
857 (void) pthread_mutex_lock(&cip->ci_lock);
858
859 uuid_len = cip->ci_uuidlen + 1;
860
861 while (rcl->rcl_len + uuid_len > rcl->rcl_buf.rcl_buf_len) {
862 if (rcl->rcl_buf.rcl_buf_len != 0)
863 buf_len = rcl->rcl_buf.rcl_buf_len * 2;
864 else
865 buf_len = 1024; /* default buffer size */
866
867 if ((p = realloc(rcl->rcl_buf.rcl_buf_val, buf_len)) != NULL) {
868 bzero((char *)p + rcl->rcl_buf.rcl_buf_len,
869 buf_len - rcl->rcl_buf.rcl_buf_len);
870 rcl->rcl_buf.rcl_buf_val = p;
871 rcl->rcl_buf.rcl_buf_len = buf_len;
872 } else {
873 rcl->rcl_err = FMD_ADM_ERR_NOMEM;
874 break;
875 }
876 }
877
878 if (rcl->rcl_err == 0) {
879 bcopy(cip->ci_uuid, (char *)rcl->rcl_buf.rcl_buf_val +
880 rcl->rcl_len, uuid_len);
881 rcl->rcl_len += uuid_len;
882 rcl->rcl_cnt++;
883 }
884
885 (void) pthread_mutex_unlock(&cip->ci_lock);
886 }
887
888 bool_t
889 fmd_adm_caselist_1_svc(struct fmd_rpc_caselist *rvp, struct svc_req *req)
890 {
891 rvp->rcl_buf.rcl_buf_len = 0;
892 rvp->rcl_buf.rcl_buf_val = NULL;
893 rvp->rcl_len = 0;
894 rvp->rcl_cnt = 0;
895 rvp->rcl_err = 0;
896
897 if (fmd_rpc_deny(req))
898 rvp->rcl_err = FMD_ADM_ERR_PERM;
899 else
900 fmd_case_hash_apply(fmd.d_cases, fmd_adm_caselist_case, rvp);
901
902 return (TRUE);
903 }
904
905 bool_t
906 fmd_adm_caseinfo_1_svc(char *uuid, struct fmd_rpc_caseinfo *rvp,
907 struct svc_req *req)
908 {
909 fmd_case_t *cp;
910 nvlist_t *nvl;
911 int err = 0;
912
913 bzero(rvp, sizeof (struct fmd_rpc_caseinfo));
914
915 if (fmd_rpc_deny(req)) {
916 rvp->rci_err = FMD_ADM_ERR_PERM;
917 return (TRUE);
918 }
919
920 if ((cp = fmd_case_hash_lookup(fmd.d_cases, uuid)) == NULL) {
921 rvp->rci_err = FMD_ADM_ERR_CASESRCH;
922 return (TRUE);
923 }
924
925 if (!(((fmd_case_impl_t *)cp)->ci_flags & FMD_CF_SOLVED)) {
926 fmd_case_rele(cp);
927 rvp->rci_err = FMD_ADM_ERR_CASESRCH;
928 return (TRUE);
929 }
930
931 nvl = fmd_case_mkevent(cp, FM_LIST_SUSPECT_CLASS);
932
933 err = nvlist_pack(nvl, &rvp->rci_evbuf.rci_evbuf_val,
934 &rvp->rci_evbuf.rci_evbuf_len, NV_ENCODE_XDR, 0);
935
936 nvlist_free(nvl);
937
938 if (err != 0)
939 rvp->rci_err = FMD_ADM_ERR_NOMEM;
940
941 fmd_case_rele(cp);
942
943 return (TRUE);
944 }
945
946 /*ARGSUSED*/
947 static void
948 fmd_adm_xprtlist_one(fmd_idspace_t *ids, id_t id, void *arg)
949 {
950 struct fmd_rpc_xprtlist *rvp = arg;
951
952 if (rvp->rxl_len < rvp->rxl_buf.rxl_buf_len)
953 rvp->rxl_buf.rxl_buf_val[rvp->rxl_len++] = id;
954 }
955
956 bool_t
957 fmd_adm_xprtlist_1_svc(struct fmd_rpc_xprtlist *rvp, struct svc_req *req)
958 {
959 if (fmd_rpc_deny(req)) {
960 rvp->rxl_buf.rxl_buf_len = 0;
961 rvp->rxl_buf.rxl_buf_val = NULL;
962 rvp->rxl_len = 0;
963 rvp->rxl_err = FMD_ADM_ERR_PERM;
964 return (TRUE);
965 }
966
967 /*
968 * Since we're taking a snapshot of the transports, and these could
969 * change after we return our result, there's no need to hold any kind
970 * of lock between retrieving ids_count and taking the snapshot. We'll
971 * just capture up to a maximum of whatever ids_count value we sampled.
972 */
973 rvp->rxl_buf.rxl_buf_len = fmd.d_xprt_ids->ids_count;
974 rvp->rxl_buf.rxl_buf_val = malloc(sizeof (int32_t) *
975 rvp->rxl_buf.rxl_buf_len);
976 rvp->rxl_len = 0;
977 rvp->rxl_err = 0;
978
979 if (rvp->rxl_buf.rxl_buf_val == NULL) {
980 rvp->rxl_err = FMD_ADM_ERR_NOMEM;
981 return (TRUE);
982 }
983
984 fmd_idspace_apply(fmd.d_xprt_ids, fmd_adm_xprtlist_one, rvp);
985 return (TRUE);
986 }
987
988 bool_t
989 fmd_adm_xprtstat_1_svc(int32_t id,
990 struct fmd_rpc_modstat *rms, struct svc_req *req)
991 {
992 fmd_xprt_impl_t *xip;
993 fmd_stat_t *sp, *ep, *cp;
994
995 if (fmd_rpc_deny(req)) {
996 rms->rms_buf.rms_buf_val = NULL;
997 rms->rms_buf.rms_buf_len = 0;
998 rms->rms_err = FMD_ADM_ERR_PERM;
999 return (TRUE);
1000 }
1001
1002 rms->rms_buf.rms_buf_val = malloc(sizeof (fmd_xprt_stat_t));
1003 rms->rms_buf.rms_buf_len = sizeof (fmd_xprt_stat_t) /
1004 sizeof (fmd_stat_t);
1005 rms->rms_err = 0;
1006
1007 if (rms->rms_buf.rms_buf_val == NULL) {
1008 rms->rms_err = FMD_ADM_ERR_NOMEM;
1009 rms->rms_buf.rms_buf_len = 0;
1010 return (TRUE);
1011 }
1012
1013 if ((xip = fmd_idspace_hold(fmd.d_xprt_ids, id)) == NULL) {
1014 rms->rms_err = FMD_ADM_ERR_XPRTSRCH;
1015 return (TRUE);
1016 }
1017
1018 /*
1019 * Grab the stats lock and bcopy the entire transport stats array in
1020 * one shot. Then go back through and duplicate any string values.
1021 */
1022 (void) pthread_mutex_lock(&xip->xi_stats_lock);
1023
1024 sp = (fmd_stat_t *)xip->xi_stats;
1025 ep = sp + rms->rms_buf.rms_buf_len;
1026 cp = rms->rms_buf.rms_buf_val;
1027
1028 bcopy(sp, cp, sizeof (fmd_xprt_stat_t));
1029
1030 for (; sp < ep; sp++, cp++) {
1031 if (sp->fmds_type == FMD_TYPE_STRING &&
1032 sp->fmds_value.str != NULL)
1033 cp->fmds_value.str = strdup(sp->fmds_value.str);
1034 }
1035
1036 (void) pthread_mutex_unlock(&xip->xi_stats_lock);
1037 fmd_idspace_rele(fmd.d_xprt_ids, id);
1038
1039 return (TRUE);
1040 }
1041
1042 int
1043 fmd_adm_1_freeresult(SVCXPRT *xprt, xdrproc_t proc, caddr_t data)
1044 {
1045 xdr_free(proc, data);
1046 svc_done(xprt);
1047 return (TRUE);
1048 }
1049
1050 /*
1051 * Custom XDR routine for our API structure fmd_stat_t. This function must
1052 * match the definition of fmd_stat_t in <fmd_api.h> and must also match
1053 * the corresponding routine in usr/src/lib/fm/libfmd_adm/common/fmd_adm.c.
1054 */
1055 bool_t
1056 xdr_fmd_stat(XDR *xp, fmd_stat_t *sp)
1057 {
1058 bool_t rv = TRUE;
1059
1060 rv &= xdr_opaque(xp, sp->fmds_name, sizeof (sp->fmds_name));
1061 rv &= xdr_u_int(xp, &sp->fmds_type);
1062 rv &= xdr_opaque(xp, sp->fmds_desc, sizeof (sp->fmds_desc));
1063
1064 switch (sp->fmds_type) {
1065 case FMD_TYPE_BOOL:
1066 rv &= xdr_int(xp, &sp->fmds_value.bool);
1067 break;
1068 case FMD_TYPE_INT32:
1069 rv &= xdr_int32_t(xp, &sp->fmds_value.i32);
1070 break;
1071 case FMD_TYPE_UINT32:
1072 rv &= xdr_uint32_t(xp, &sp->fmds_value.ui32);
1073 break;
1074 case FMD_TYPE_INT64:
1075 rv &= xdr_int64_t(xp, &sp->fmds_value.i64);
1076 break;
1077 case FMD_TYPE_UINT64:
1078 case FMD_TYPE_TIME:
1079 case FMD_TYPE_SIZE:
1080 rv &= xdr_uint64_t(xp, &sp->fmds_value.ui64);
1081 break;
1082 case FMD_TYPE_STRING:
1083 rv &= xdr_string(xp, &sp->fmds_value.str, ~0);
1084 break;
1085 }
1086
1087 return (rv);
1088 }