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, Version 1.0 only
6 * (the "License"). You may not use this file except in compliance
7 * with the License.
8 *
9 * You can obtain a copy of the license at usr/src/OPENSOLARIS.LICENSE
10 * or http://www.opensolaris.org/os/licensing.
11 * See the License for the specific language governing permissions
12 * and limitations under the License.
13 *
14 * When distributing Covered Code, include this CDDL HEADER in each
15 * file and include the License file at usr/src/OPENSOLARIS.LICENSE.
16 * If applicable, add the following below this CDDL HEADER, with the
17 * fields enclosed by brackets "[]" replaced with your own identifying
18 * information: Portions Copyright [yyyy] [name of copyright owner]
19 *
20 * CDDL HEADER END
21 */
22 /*
23 * Copyright 2004 Sun Microsystems, Inc. All rights reserved.
24 * Use is subject to license terms.
25 */
26
27 #pragma ident "%Z%%M% %I% %E% SMI"
28
29 #include <strings.h>
30
31 #include <inj_event.h>
32 #include <inj_err.h>
33
34 #include <fm/fmd_log.h>
35
36 typedef struct inj_logfile {
37 uint64_t ilf_sec; /* timestamp seconds from previous record */
38 uint64_t ilf_nsec; /* timestamp nanoseconds from previous record */
39 int ilf_index; /* record index in log file for fake lineno */
40 } inj_logfile_t;
41
42 /*ARGSUSED*/
43 static int
inj_logfile_event(fmd_log_t * lp,const fmd_log_record_t * rp,void * data)44 inj_logfile_event(fmd_log_t *lp, const fmd_log_record_t *rp, void *data)
45 {
46 inj_cmd_t *cmd = inj_zalloc(sizeof (inj_cmd_t));
47 inj_defn_t *ev = inj_zalloc(sizeof (inj_defn_t));
48
49 hrtime_t rec_sec = rp->rec_sec + rp->rec_nsec / NANOSEC;
50 hrtime_t rec_nsec = rp->rec_nsec % NANOSEC;
51
52 inj_logfile_t *ilf = data;
53 hrtime_t delta;
54
55 if (ilf->ilf_index == 1)
56 goto add_event; /* do not try to adjust time for first record */
57
58 /*
59 * If the current record's time is before that of the previous record,
60 * advance it to the previous record time. This may occur when delays
61 * between capturing ENA and enqueuing a sysevent are observed.
62 */
63 if (rec_sec < ilf->ilf_sec ||
64 (rec_sec == ilf->ilf_sec && rec_nsec < ilf->ilf_nsec)) {
65 warn("record [%d] (%s) timestamp is out of order: "
66 "advancing event time to %llx.%llx\n",
67 ilf->ilf_index, rp->rec_class, ilf->ilf_sec, ilf->ilf_nsec);
68 rec_sec = ilf->ilf_sec;
69 rec_nsec = ilf->ilf_nsec;
70 }
71
72 /*
73 * For now, compute the delta between the previous record and this one
74 * as a number of nanoseconds and advance the clock. If a massively
75 * large delay is observed (>INT64_MAX ns), we abort. This could be
76 * improved if necessary by sending more than one cmd_addhrt in a loop.
77 */
78 delta = (rec_sec - ilf->ilf_sec) * NANOSEC;
79 delta += (hrtime_t)rec_nsec - (hrtime_t)ilf->ilf_nsec;
80
81 if (delta < 0)
82 die("record [%d] timestamp delta too large\n", ilf->ilf_index);
83
84 if (delta > 0)
85 inj_cmds_add(inj_cmd_addhrt(delta));
86
87 add_event:
88 ev->defn_name = inj_strdup(rp->rec_class);
89 ev->defn_lineno = ilf->ilf_index++;
90
91 if ((errno = nvlist_dup(rp->rec_nvl, &ev->defn_nvl, 0)) != 0)
92 die("failed to allocate nvl for %s event", rp->rec_class);
93
94 cmd->cmd_type = CMD_SEND_EVENT;
95 cmd->cmd_event = ev;
96
97 inj_cmds_add(cmd);
98
99 ilf->ilf_sec = rec_sec;
100 ilf->ilf_nsec = rec_nsec;
101
102 return (0);
103 }
104
105 inj_list_t *
inj_logfile_read(fmd_log_t * lp)106 inj_logfile_read(fmd_log_t *lp)
107 {
108 const char *label = fmd_log_label(lp);
109 inj_logfile_t ilf;
110
111 if (strcmp(label, "error") != 0)
112 die("cannot use '%s' log as injector input\n", label);
113
114 bzero(&ilf, sizeof (ilf));
115 ilf.ilf_index = 1;
116
117 if (fmd_log_iter(lp, inj_logfile_event, &ilf) != 0) {
118 die("failed to process log: %s\n",
119 fmd_log_errmsg(lp, fmd_log_errno(lp)));
120 }
121
122 return (inj_cmds_get());
123 }
124