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 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 * 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