/* $OpenBSD: trace.c,v 1.15 2005/04/12 15:26:47 cloder Exp $ */ /* $NetBSD: trace.c,v 1.13 1995/06/20 22:28:03 christos Exp $ */ /* * Copyright (c) 1983, 1988, 1993 * The Regents of the University of California. All rights reserved. * * Redistribution and use in source and binary forms, with or without * modification, are permitted provided that the following conditions * are met: * 1. Redistributions of source code must retain the above copyright * notice, this list of conditions and the following disclaimer. * 2. Redistributions in binary form must reproduce the above copyright * notice, this list of conditions and the following disclaimer in the * documentation and/or other materials provided with the distribution. * 3. Neither the name of the University nor the names of its contributors * may be used to endorse or promote products derived from this software * without specific prior written permission. * * THIS SOFTWARE IS PROVIDED BY THE REGENTS AND CONTRIBUTORS ``AS IS'' AND * ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE * IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE * ARE DISCLAIMED. IN NO EVENT SHALL THE REGENTS OR CONTRIBUTORS BE LIABLE * FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL * DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS * OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION) * HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT * LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY * OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF * SUCH DAMAGE. */ #if !defined(lint) static char sccsid[] = "@(#)trace.c 8.1 (Berkeley) 6/5/93"; #else static char rcsid[] = "$OpenBSD: trace.c,v 1.15 2005/04/12 15:26:47 cloder Exp $"; #endif #define RIPCMDS #include "defs.h" #include "pathnames.h" #include #include #include #ifdef sgi /* use *stat64 for files on large filesystems */ #define stat stat64 #endif #define NRECORDS 50 /* size of circular trace buffer */ u_int tracelevel, new_tracelevel; FILE *ftrace = stdout; /* output trace file */ static char *tracelevel_pat = "%s\n"; char savetracename[MAXPATHLEN]; static void trace_dump(void); /* convert IP address to a string, but not into a single buffer */ char * naddr_ntoa(naddr a) { #define NUM_BUFS 4 static int bufno; static struct { char str[16]; /* xxx.xxx.xxx.xxx\0 */ } bufs[NUM_BUFS]; struct in_addr addr; addr.s_addr = a; strlcpy(bufs[bufno].str, inet_ntoa(addr), sizeof bufs[bufno].str); bufno = (bufno+1) % NUM_BUFS; return bufs[bufno].str; #undef NUM_BUFS } char * saddr_ntoa(struct sockaddr *sa) { return (sa == 0) ? "?" : naddr_ntoa(S_ADDR(sa)); } static char * ts(time_t secs) { static char s[20]; secs += epoch.tv_sec; #ifdef sgi (void)cftime(s, "%T", &secs); #else bcopy(ctime(&secs)+11, s, 8); s[8] = '\0'; #endif return s; } /* On each event, display a time stamp. * This assumes that 'now' is update once for each event, and * that at least now.tv_usec changes. */ void lastlog(void) { static struct timeval last; if (last.tv_sec != now.tv_sec || last.tv_usec != now.tv_usec) { (void)fprintf(ftrace, "-- %s --\n", ts(now.tv_sec)); last = now; } } static void tmsg(char *p, ...) { va_list args; if (ftrace != 0) { lastlog(); va_start(args, p); vfprintf(ftrace, p, args); fflush(ftrace); va_end(args); } } static void trace_close(void) { int fd; fflush(stdout); fflush(stderr); if (ftrace != 0 && savetracename[0] != '\0') { fd = open(_PATH_DEVNULL, O_RDWR); (void)dup2(fd, STDOUT_FILENO); (void)dup2(fd, STDERR_FILENO); (void)close(fd); fclose(ftrace); ftrace = 0; } } void trace_flush(void) { if (ftrace != 0) { fflush(ftrace); if (ferror(ftrace)) trace_off("tracing off: %s", strerror(ferror(ftrace))); } } void trace_off(char *p, ...) { va_list args; if (ftrace != 0) { lastlog(); va_start(args, p); vfprintf(ftrace, p, args); fflush(ftrace); va_end(args); } trace_close(); new_tracelevel = tracelevel = 0; } void trace_on(char *filename, int trusted) { struct stat stbuf; FILE *n_ftrace; /* Given a null filename when tracing is already on, increase the * debugging level and re-open the file in case it has been unlinked. */ if (filename[0] == '\0') { if (tracelevel != 0) { new_tracelevel++; tracelevel_pat = "trace command: %s\n"; } else if (savetracename[0] == '\0') { msglog("missing trace file name"); return; } filename = savetracename; } else if (!strcmp(filename,"dump/../table")) { trace_dump(); return; } else { if (stat(filename, &stbuf) >= 0 && (stbuf.st_mode & S_IFMT) != S_IFREG) { msglog("wrong type (%#x) of trace file \"%s\"", stbuf.st_mode, filename); return; } if (!trusted #ifdef _PATH_TRACE && (strncmp(filename, _PATH_TRACE, sizeof(_PATH_TRACE)-1) || strstr(filename,"../") || 0 > stat(_PATH_TRACE, &stbuf)) #endif && strcmp(filename, savetracename)) { msglog("wrong directory for trace file \"%s\"", filename); return; } } n_ftrace = fopen(filename, "a"); if (n_ftrace == 0) { msglog("failed to open trace file \"%s\" %s", filename, strerror(errno)); return; } tmsg("switch to trace file %s\n", filename); trace_close(); if (filename != savetracename) strlcpy(savetracename, filename, sizeof(savetracename)); ftrace = n_ftrace; fflush(stdout); fflush(stderr); dup2(fileno(ftrace), STDOUT_FILENO); dup2(fileno(ftrace), STDERR_FILENO); if (new_tracelevel == 0) new_tracelevel = 1; set_tracelevel(); } /* ARGSUSED */ void sigtrace_on(int s) { new_tracelevel++; tracelevel_pat = "SIGUSR1: %s\n"; } /* ARGSUSED */ void sigtrace_off(int s) { new_tracelevel--; tracelevel_pat = "SIGUSR2: %s\n"; } /* Move to next higher level of tracing when -t option processed or * SIGUSR1 is received. Successive levels are: * actions * actions + packets * actions + packets + contents */ void set_tracelevel(void) { static char *off_msgs[MAX_TRACELEVEL] = { "Tracing actions stopped", "Tracing packets stopped", "Tracing packet contents stopped", "Tracing kernel changes stopped", }; static char *on_msgs[MAX_TRACELEVEL] = { "Tracing actions started", "Tracing packets started", "Tracing packet contents started", "Tracing kernel changes started", }; if (new_tracelevel > MAX_TRACELEVEL) { new_tracelevel = MAX_TRACELEVEL; if (new_tracelevel == tracelevel) { tmsg(tracelevel_pat, on_msgs[tracelevel-1]); return; } } while (new_tracelevel != tracelevel) { if (new_tracelevel < tracelevel) { if (--tracelevel == 0) trace_off(tracelevel_pat, off_msgs[0]); else tmsg(tracelevel_pat, off_msgs[tracelevel]); } else { if (ftrace == 0) { if (savetracename[0] != '\0') trace_on(savetracename, 1); else ftrace = stdout; } tmsg(tracelevel_pat, on_msgs[tracelevel++]); } } tracelevel_pat = "%s\n"; } /* display an address */ char * addrname(naddr addr, /* in network byte order */ naddr mask, int force) /* 0=show mask if nonstandard, */ { /* 1=always show mask, 2=never */ #define NUM_BUFS 4 static int bufno; static struct { char str[15+20]; } bufs[NUM_BUFS]; char *s, *sp; naddr dmask; size_t l; int i; strlcpy(bufs[bufno].str, naddr_ntoa(addr), sizeof bufs[bufno].str); bufno = (bufno+1) % NUM_BUFS; s = bufs[bufno].str; l = sizeof(bufs[bufno].str); if (force == 1 || (force == 0 && mask != std_mask(addr))) { sp = &s[strlen(s)]; dmask = mask & -mask; if (mask + dmask == 0) { for (i = 0; i != 32 && ((1<bits_mask) != 0) { if ((b & field) == b) { if (tbl->bits_name[0] != '\0') { if (c) (void)putc(c, ftrace); (void)fprintf(ftrace, "%s", tbl->bits_name); c = '|'; } if (0 == (field &= ~(b | tbl->bits_clear))) break; } tbl++; } if (field != 0 && tbl->bits_name != 0) { if (c) (void)putc(c, ftrace); (void)fprintf(ftrace, tbl->bits_name, field); c = '|'; } if (c != '<' || force) (void)fputs("> ", ftrace); } static char * trace_pair(naddr dst, naddr mask, char *gate) { static char buf[3*4+3+1+2+3 /* "xxx.xxx.xxx.xxx/xx-->" */ +3*4+3+1]; /* "xxx.xxx.xxx.xxx" */ int i; i = snprintf(buf, sizeof buf, "%-16s-->", addrname(dst, mask, 0)); if (i >= sizeof buf || i == -1) return buf; (void)snprintf(&buf[i], sizeof buf - i, "%-*s", 15+20-MAX(20,i), gate); return buf; } void trace_if(char *act, struct interface *ifp) { if (!TRACEACTIONS || ftrace == 0) return; lastlog(); (void)fprintf(ftrace, "%s interface %-4s ", act, ifp->int_name); (void)fprintf(ftrace, "%-15s-->%-15s ", naddr_ntoa(ifp->int_addr), addrname(htonl((ifp->int_if_flags & IFF_POINTOPOINT) ? ifp->int_dstaddr : ifp->int_net), ifp->int_mask, 1)); if (ifp->int_metric != 0) (void)fprintf(ftrace, "metric=%d ", ifp->int_metric); trace_bits(if_bits, ifp->int_if_flags, 0); trace_bits(is_bits, ifp->int_state, 0); (void)fputc('\n',ftrace); } void trace_upslot(struct rt_entry *rt, struct rt_spare *rts, naddr gate, naddr router, struct interface *ifp, int metric, u_short tag, time_t new_time) { if (!TRACEACTIONS || ftrace == 0) return; if (rts->rts_gate == gate && rts->rts_router == router && rts->rts_metric == metric && rts->rts_tag == tag) return; lastlog(); if (rts->rts_gate != RIP_DEFAULT) { (void)fprintf(ftrace, "Chg #%d %-35s ", rts - rt->rt_spares, trace_pair(rt->rt_dst, rt->rt_mask, naddr_ntoa(rts->rts_gate))); if (rts->rts_gate != rts->rts_gate) (void)fprintf(ftrace, "router=%s ", naddr_ntoa(rts->rts_gate)); if (rts->rts_tag != 0) (void)fprintf(ftrace, "tag=%#x ", ntohs(rts->rts_tag)); (void)fprintf(ftrace, "metric=%-2d ", rts->rts_metric); if (rts->rts_ifp != 0) (void)fprintf(ftrace, "%s ", rts->rts_ifp->int_name); (void)fprintf(ftrace, "%s\n", ts(rts->rts_time)); (void)fprintf(ftrace, " %19s%-16s ", "", gate != rts->rts_gate ? naddr_ntoa(gate) : ""); if (gate != router) (void)fprintf(ftrace,"router=%s ",naddr_ntoa(router)); if (tag != rts->rts_tag) (void)fprintf(ftrace, "tag=%#x ", ntohs(tag)); if (metric != rts->rts_metric) (void)fprintf(ftrace, "metric=%-2d ", metric); if (ifp != rts->rts_ifp && ifp != 0 ) (void)fprintf(ftrace, "%s ", ifp->int_name); (void)fprintf(ftrace, "%s\n", new_time != rts->rts_time ? ts(new_time) : ""); } else { (void)fprintf(ftrace, "Add #%d %-35s ", rts - rt->rt_spares, trace_pair(rt->rt_dst, rt->rt_mask, naddr_ntoa(gate))); if (gate != router) (void)fprintf(ftrace, "router=%s ", naddr_ntoa(gate)); if (tag != 0) (void)fprintf(ftrace, "tag=%#x ", ntohs(tag)); (void)fprintf(ftrace, "metric=%-2d ", metric); if (ifp != 0) (void)fprintf(ftrace, "%s ", ifp->int_name); (void)fprintf(ftrace, "%s\n", ts(new_time)); } } /* talk about a change made to the kernel table */ void trace_kernel(char *p, ...) { va_list args; if (!TRACEKERNEL || ftrace == 0) return; lastlog(); va_start(args, p); vfprintf(ftrace, p, args); va_end(args); } /* display a message if tracing actions */ void trace_act(char *p, ...) { va_list args; if (!TRACEACTIONS || ftrace == 0) return; lastlog(); va_start(args, p); vfprintf(ftrace, p, args); va_end(args); } /* display a message if tracing packets */ void trace_pkt(char *p, ...) { va_list args; if (!TRACEPACKETS || ftrace == 0) return; lastlog(); va_start(args, p); vfprintf(ftrace, p, args); va_end(args); } void trace_change(struct rt_entry *rt, u_int state, naddr gate, /* forward packets here */ naddr router, /* on the authority of this router */ int metric, u_short tag, struct interface *ifp, time_t new_time, char *label) { if (ftrace == 0) return; if (rt->rt_metric == metric && rt->rt_gate == gate && rt->rt_router == router && rt->rt_state == state && rt->rt_tag == tag) return; lastlog(); (void)fprintf(ftrace, "%s %-35s metric=%-2d ", label, trace_pair(rt->rt_dst, rt->rt_mask, naddr_ntoa(rt->rt_gate)), rt->rt_metric); if (rt->rt_router != rt->rt_gate) (void)fprintf(ftrace, "router=%s ", naddr_ntoa(rt->rt_router)); if (rt->rt_tag != 0) (void)fprintf(ftrace, "tag=%#x ", ntohs(rt->rt_tag)); trace_bits(rs_bits, rt->rt_state, rt->rt_state != state); (void)fprintf(ftrace, "%s ", rt->rt_ifp == 0 ? "?" : rt->rt_ifp->int_name); (void)fprintf(ftrace, "%s\n", AGE_RT(rt->rt_state, rt->rt_ifp) ? ts(rt->rt_time) : ""); (void)fprintf(ftrace, "%*s %19s%-16s ", strlen(label), "", "", rt->rt_gate != gate ? naddr_ntoa(gate) : ""); if (rt->rt_metric != metric) (void)fprintf(ftrace, "metric=%-2d ", metric); if (router != gate) (void)fprintf(ftrace, "router=%s ", naddr_ntoa(router)); if (rt->rt_tag != tag) (void)fprintf(ftrace, "tag=%#x ", ntohs(tag)); if (rt->rt_state != state) trace_bits(rs_bits, state, 1); if (rt->rt_ifp != ifp) (void)fprintf(ftrace, "%s ", ifp != 0 ? ifp->int_name : "?"); (void)fprintf(ftrace, "%s\n", ((rt->rt_time == new_time || !AGE_RT(rt->rt_state, ifp)) ? "" : ts(new_time))); } void trace_add_del(char * action, struct rt_entry *rt) { u_int state = rt->rt_state; if (ftrace == 0) return; lastlog(); (void)fprintf(ftrace, "%s %-35s metric=%-2d ", action, trace_pair(rt->rt_dst, rt->rt_mask, naddr_ntoa(rt->rt_gate)), rt->rt_metric); if (rt->rt_router != rt->rt_gate) (void)fprintf(ftrace, "router=%s ", naddr_ntoa(rt->rt_router)); if (rt->rt_tag != 0) (void)fprintf(ftrace, "tag=%#x ", ntohs(rt->rt_tag)); trace_bits(rs_bits, state, 0); (void)fprintf(ftrace, "%s ", rt->rt_ifp != 0 ? rt->rt_ifp->int_name : "?"); (void)fprintf(ftrace, "%s\n", ts(rt->rt_time)); } /* ARGSUSED */ static int walk_trace(struct radix_node *rn, void *w) { #define RT ((struct rt_entry *)rn) struct rt_spare *rts; int i, age; (void)fprintf(ftrace, " %-35s metric=%-2d ", trace_pair(RT->rt_dst, RT->rt_mask, naddr_ntoa(RT->rt_gate)), RT->rt_metric); if (RT->rt_router != RT->rt_gate) (void)fprintf(ftrace, "router=%s ", naddr_ntoa(RT->rt_router)); if (RT->rt_tag != 0) (void)fprintf(ftrace, "tag=%#x ", ntohs(RT->rt_tag)); trace_bits(rs_bits, RT->rt_state, 0); (void)fprintf(ftrace, "%s ", RT->rt_ifp == 0 ? "?" : RT->rt_ifp->int_name); age = AGE_RT(RT->rt_state, RT->rt_ifp); if (age) (void)fprintf(ftrace, "%s", ts(RT->rt_time)); rts = &RT->rt_spares[1]; for (i = 1; i < NUM_SPARES; i++, rts++) { if (rts->rts_metric != HOPCNT_INFINITY) { (void)fprintf(ftrace,"\n #%d%15s%-16s metric=%-2d ", i, "", naddr_ntoa(rts->rts_gate), rts->rts_metric); if (rts->rts_router != rts->rts_gate) (void)fprintf(ftrace, "router=%s ", naddr_ntoa(rts->rts_router)); if (rts->rts_tag != 0) (void)fprintf(ftrace, "tag=%#x ", ntohs(rts->rts_tag)); (void)fprintf(ftrace, "%s ", (rts->rts_ifp == 0 ? "?" : rts->rts_ifp->int_name)); if (age) (void)fprintf(ftrace, "%s", ts(rts->rts_time)); } } (void)fputc('\n',ftrace); return 0; } static void trace_dump(void) { if (ftrace == 0) return; lastlog(); (void)rn_walktree(rhead, walk_trace, 0); } void trace_rip(char *dir1, char *dir2, struct sockaddr_in *who, struct interface *ifp, struct rip *msg, int size) /* total size of message */ { struct netinfo *n, *lim; struct netauth *a; int i; if (!TRACEPACKETS || ftrace == 0) return; lastlog(); if (msg->rip_cmd >= RIPCMD_MAX || msg->rip_vers == 0) { (void)fprintf(ftrace, "%s bad RIPv%d cmd=%d %s" " %s.%d size=%d\n", dir1, msg->rip_vers, msg->rip_cmd, dir2, naddr_ntoa(who->sin_addr.s_addr), ntohs(who->sin_port), size); return; } (void)fprintf(ftrace, "%s RIPv%d %s %s %s.%d%s%s\n", dir1, msg->rip_vers, ripcmds[msg->rip_cmd], dir2, naddr_ntoa(who->sin_addr.s_addr), ntohs(who->sin_port), ifp ? " via " : "", ifp ? ifp->int_name : ""); if (!TRACECONTENTS) return; switch (msg->rip_cmd) { case RIPCMD_REQUEST: case RIPCMD_RESPONSE: n = msg->rip_nets; lim = (struct netinfo *)((char*)msg + size); for (; n < lim; n++) { if (n->n_family == RIP_AF_UNSPEC && ntohl(n->n_metric) == HOPCNT_INFINITY && n+1 == lim && n == msg->rip_nets && msg->rip_cmd == RIPCMD_REQUEST) { (void)fputs("\tQUERY ", ftrace); if (n->n_dst != 0) (void)fprintf(ftrace, "%s ", naddr_ntoa(n->n_dst)); if (n->n_mask != 0) (void)fprintf(ftrace, "mask=%#x ", (u_int)ntohl(n->n_mask)); if (n->n_nhop != 0) (void)fprintf(ftrace, " nhop=%s ", naddr_ntoa(n->n_nhop)); if (n->n_tag != 0) (void)fprintf(ftrace, "tag=%#x", ntohs(n->n_tag)); (void)fputc('\n',ftrace); continue; } if (n->n_family == RIP_AF_AUTH) { a = (struct netauth*)n; (void)fprintf(ftrace, "\tAuthentication type %d: ", ntohs(a->a_type)); for (i = 0; i < sizeof(a->au.au_pw); i++) (void)fprintf(ftrace, "%02x ", a->au.au_pw[i]); (void)fputc('\n',ftrace); continue; } if (n->n_family != RIP_AF_INET) { (void)fprintf(ftrace, "\t(af %d) %-18s mask=%#x", ntohs(n->n_family), naddr_ntoa(n->n_dst), (u_int)ntohl(n->n_mask)); } else if (msg->rip_vers == RIPv1) { (void)fprintf(ftrace, "\t%-18s ", addrname(n->n_dst, ntohl(n->n_mask), n->n_mask==0 ? 2 : 1)); } else { (void)fprintf(ftrace, "\t%-18s ", addrname(n->n_dst, ntohl(n->n_mask), n->n_mask==0 ? 2 : 0)); } (void)fprintf(ftrace, "metric=%-2d ", (u_int)ntohl(n->n_metric)); if (n->n_nhop != 0) (void)fprintf(ftrace, " nhop=%s ", naddr_ntoa(n->n_nhop)); if (n->n_tag != 0) (void)fprintf(ftrace, "tag=%#x", ntohs(n->n_tag)); (void)fputc('\n',ftrace); } if (size != (char *)n - (char *)msg) (void)fprintf(ftrace, "truncated record, len %d\n", size); break; case RIPCMD_TRACEON: fprintf(ftrace, "\tfile=%*s\n", size-4, msg->rip_tracefile); break; case RIPCMD_TRACEOFF: break; } }