+/*
+ * Copyright (c) 1983, 1988 Regents of the University of California.
+ * All rights reserved.
+ *
+ * Redistribution and use in source and binary forms are permitted
+ * provided that the above copyright notice and this paragraph are
+ * duplicated in all such forms and that any documentation,
+ * advertising materials, and other materials related to such
+ * distribution and use acknowledge that the software was developed
+ * by the University of California, Berkeley. The name of the
+ * University may not be used to endorse or promote products derived
+ * from this software without specific prior written permission.
+ * THIS SOFTWARE IS PROVIDED ``AS IS'' AND WITHOUT ANY EXPRESS OR
+ * IMPLIED WARRANTIES, INCLUDING, WITHOUT LIMITATION, THE IMPLIED
+ * WARRANTIES OF MERCHANTIBILITY AND FITNESS FOR A PARTICULAR PURPOSE.
+ */
+
#ifndef lint
-static char sccsid[] = "@(#)trace.c 4.1 %G%";
-#endif
+static char sccsid[] = "@(#)trace.c 5.9 (Berkeley) %G%";
+#endif /* not lint */
/*
* Routing Table Management Daemon
*/
#define RIPCMDS
-#include "router.h"
+#include "defs.h"
+#include <sys/file.h>
+#include <sys/stat.h>
+#include <sys/signal.h>
+#include "pathnames.h"
#define NRECORDS 50 /* size of circular trace buffer */
#ifdef DEBUG
FILE *ftrace = stdout;
-int tracing = 1;
+int traceactions = 0;
#endif
+static struct timeval lastlog;
+static char *savetracename;
traceinit(ifp)
register struct interface *ifp;
if (iftraceinit(ifp, &ifp->int_input) &&
iftraceinit(ifp, &ifp->int_output))
return;
- tracing = 0;
+ tracehistory = 0;
fprintf(stderr, "traceinit: can't init %s\n", ifp->int_name);
}
if (ifd->ifd_records == 0)
return (0);
ifd->ifd_front = ifd->ifd_records;
+ ifd->ifd_count = 0;
for (t = ifd->ifd_records; t < ifd->ifd_records + NRECORDS; t++) {
t->ift_size = 0;
t->ift_packet = 0;
traceon(file)
char *file;
{
+ struct stat stbuf;
if (ftrace != NULL)
return;
+ if (stat(file, &stbuf) >= 0 && (stbuf.st_mode & S_IFMT) != S_IFREG)
+ return;
+ savetracename = file;
+ (void) gettimeofday(&now, (struct timezone *)NULL);
ftrace = fopen(file, "a");
if (ftrace == NULL)
return;
dup2(fileno(ftrace), 1);
dup2(fileno(ftrace), 2);
- tracing = 1;
+ traceactions = 1;
+ fprintf(ftrace, "Tracing enabled %s\n", ctime((time_t *)&now.tv_sec));
}
traceoff()
{
- if (!tracing)
+ if (!traceactions)
return;
- if (ftrace != NULL)
+ if (ftrace != NULL) {
+ int fd = open(_PATH_DEVNULL, O_RDWR);
+
+ fprintf(ftrace, "Tracing disabled %s\n",
+ ctime((time_t *)&now.tv_sec));
+ fflush(ftrace);
+ (void) dup2(fd, 1);
+ (void) dup2(fd, 2);
+ (void) close(fd);
fclose(ftrace);
- ftrace = NULL;
- tracing = 0;
+ ftrace = NULL;
+ }
+ traceactions = 0;
+ tracehistory = 0;
+ tracepackets = 0;
+ tracecontents = 0;
+}
+
+sigtrace(s)
+ int s;
+{
+
+ if (s == SIGUSR2)
+ traceoff();
+ else if (ftrace == NULL && savetracename)
+ traceon(savetracename);
+ else
+ bumploglevel();
+}
+
+/*
+ * Move to next higher level of tracing when -t option processed or
+ * SIGUSR1 is received. Successive levels are:
+ * traceactions
+ * traceactions + tracepackets
+ * traceactions + tracehistory (packets and contents after change)
+ * traceactions + tracepackets + tracecontents
+ */
+bumploglevel()
+{
+
+ (void) gettimeofday(&now, (struct timezone *)NULL);
+ if (traceactions == 0) {
+ traceactions++;
+ if (ftrace)
+ fprintf(ftrace, "Tracing actions started %s\n",
+ ctime((time_t *)&now.tv_sec));
+ } else if (tracepackets == 0) {
+ tracepackets++;
+ tracehistory = 0;
+ tracecontents = 0;
+ if (ftrace)
+ fprintf(ftrace, "Tracing packets started %s\n",
+ ctime((time_t *)&now.tv_sec));
+ } else if (tracehistory == 0) {
+ tracehistory++;
+ if (ftrace)
+ fprintf(ftrace, "Tracing history started %s\n",
+ ctime((time_t *)&now.tv_sec));
+ } else {
+ tracepackets++;
+ tracecontents++;
+ tracehistory = 0;
+ if (ftrace)
+ fprintf(ftrace, "Tracing packet contents started %s\n",
+ ctime((time_t *)&now.tv_sec));
+ }
+ if (ftrace)
+ fflush(ftrace);
}
trace(ifd, who, p, len, m)
t = ifd->ifd_front++;
if (ifd->ifd_front >= ifd->ifd_records + NRECORDS)
ifd->ifd_front = ifd->ifd_records;
- if (t->ift_size > 0 && t->ift_packet)
+ if (ifd->ifd_count < NRECORDS)
+ ifd->ifd_count++;
+ if (t->ift_size > 0 && t->ift_size < len && t->ift_packet) {
free(t->ift_packet);
- t->ift_packet = 0;
- t->ift_stamp = time(0);
+ t->ift_packet = 0;
+ }
+ t->ift_stamp = now;
t->ift_who = *who;
- if (len > 0) {
+ if (len > 0 && t->ift_packet == 0) {
t->ift_packet = malloc(len);
- if (t->ift_packet)
- bcopy(p, t->ift_packet, len);
- else
+ if (t->ift_packet == 0)
len = 0;
}
+ if (len > 0)
+ bcopy(p, t->ift_packet, len);
t->ift_size = len;
t->ift_metric = m;
}
{ RTS_REMOTE, "REMOTE" },
{ RTS_INTERFACE,"INTERFACE" },
{ RTS_CHANGED, "CHANGED" },
+ { RTS_INTERNAL, "INTERNAL" },
+ { RTS_EXTERNAL, "EXTERNAL" },
+ { RTS_SUBNET, "SUBNET" },
{ 0 }
};
register struct bits *p;
if (fd == NULL)
return;
+ if (lastlog.tv_sec != now.tv_sec || lastlog.tv_usec != now.tv_usec) {
+ fprintf(fd, "\n%.19s:\n", ctime((time_t *)&now.tv_sec));
+ lastlog = now;
+ }
fprintf(fd, "%s ", action);
dst = (struct sockaddr_in *)&rt->rt_dst;
gate = (struct sockaddr_in *)&rt->rt_router;
- fprintf(fd, "dst %x, router %x, metric %d, flags", dst->sin_addr,
- gate->sin_addr, rt->rt_metric);
+ fprintf(fd, "dst %s, ", inet_ntoa(dst->sin_addr));
+ fprintf(fd, "router %s, metric %d, flags",
+ inet_ntoa(gate->sin_addr), rt->rt_metric);
cp = " %s";
for (first = 1, p = flagbits; p->t_bits > 0; p++) {
if ((rt->rt_flags & p->t_bits) == 0)
first = 0;
}
}
- putc('\n', fd);
- if ((rt->rt_state & RTS_PASSIVE) == 0 && rt->rt_ifp)
+ fprintf(fd, " timer %d\n", rt->rt_timer);
+ if (tracehistory && !tracepackets &&
+ (rt->rt_state & RTS_PASSIVE) == 0 && rt->rt_ifp)
dumpif(fd, rt->rt_ifp);
fflush(fd);
+ if (ferror(fd))
+ traceoff();
+}
+
+tracenewmetric(fd, rt, newmetric)
+ FILE *fd;
+ struct rt_entry *rt;
+ int newmetric;
+{
+ struct sockaddr_in *dst, *gate;
+
+ if (fd == NULL)
+ return;
+ if (lastlog.tv_sec != now.tv_sec || lastlog.tv_usec != now.tv_usec) {
+ fprintf(fd, "\n%.19s:\n", ctime((time_t *)&now.tv_sec));
+ lastlog = now;
+ }
+ dst = (struct sockaddr_in *)&rt->rt_dst;
+ gate = (struct sockaddr_in *)&rt->rt_router;
+ fprintf(fd, "CHANGE metric dst %s, ", inet_ntoa(dst->sin_addr));
+ fprintf(fd, "router %s, from %d to %d\n",
+ inet_ntoa(gate->sin_addr), rt->rt_metric, newmetric);
+ fflush(fd);
+ if (ferror(fd))
+ traceoff();
}
dumpif(fd, ifp)
+ FILE *fd;
register struct interface *ifp;
{
- register struct ifdebug *ifd;
-
- fprintf(fd, "*** Packet history for interface %s ***\n",
- ifp->int_name);
- dumptrace(fd, "to", &ifp->int_output);
- dumptrace(fd, "from", &ifp->int_output);
- fprintf(fd, "*** end packet history ***\n");
+ if (ifp->int_input.ifd_count || ifp->int_output.ifd_count) {
+ fprintf(fd, "*** Packet history for interface %s ***\n",
+ ifp->int_name);
+#ifdef notneeded
+ dumptrace(fd, "to", &ifp->int_output);
+#endif
+ dumptrace(fd, "from", &ifp->int_input);
+ fprintf(fd, "*** end packet history ***\n");
+ }
}
dumptrace(fd, dir, ifd)
if (ifd->ifd_front == ifd->ifd_records &&
ifd->ifd_front->ift_size == 0) {
fprintf(fd, "%s: no packets.\n", cp);
+ fflush(fd);
return;
}
fprintf(fd, "%s trace:\n", cp);
- for (t = ifd->ifd_front; t <= ifd->ifd_records + NRECORDS; t++) {
+ t = ifd->ifd_front - ifd->ifd_count;
+ if (t < ifd->ifd_records)
+ t += NRECORDS;
+ for ( ; ifd->ifd_count; ifd->ifd_count--, t++) {
+ if (t >= ifd->ifd_records + NRECORDS)
+ t = ifd->ifd_records;
if (t->ift_size == 0)
continue;
- fprintf(fd, "%.24s: metric=%d\n", ctime(&t->ift_stamp),
- t->ift_metric);
- dumppacket(fd, dir, &t->ift_who, t->ift_packet, t->ift_size);
- }
- for (t = ifd->ifd_records; t < ifd->ifd_front; t++) {
- if (t->ift_size == 0)
- continue;
- fprintf(fd, "%.24s: metric=%d\n", ctime(&t->ift_stamp),
- t->ift_metric);
- dumppacket(fd, dir, &t->ift_who, t->ift_packet, t->ift_size);
+ dumppacket(fd, dir, &t->ift_who, t->ift_packet, t->ift_size,
+ &t->ift_stamp);
}
}
-dumppacket(fd, dir, who, cp, size)
+dumppacket(fd, dir, who, cp, size, stamp)
FILE *fd;
struct sockaddr_in *who; /* should be sockaddr */
char *dir, *cp;
register int size;
+ struct timeval *stamp;
{
register struct rip *msg = (struct rip *)cp;
register struct netinfo *n;
+ if (fd == NULL)
+ return;
if (msg->rip_cmd && msg->rip_cmd < RIPCMD_MAX)
- fprintf(fd, "%s %s %x.%d", ripcmds[msg->rip_cmd],
- dir, who->sin_addr, ntohs(who->sin_port));
+ fprintf(fd, "%s %s %s.%d %.19s:\n", ripcmds[msg->rip_cmd],
+ dir, inet_ntoa(who->sin_addr), ntohs(who->sin_port),
+ ctime((time_t *)&stamp->tv_sec));
else {
- fprintf(fd, "Bad cmd 0x%x %s %x.%d\n", msg->rip_cmd,
- dir, who->sin_addr, ntohs(who->sin_port));
- fprintf(fd, "size=%d cp=%x packet=%x\n", size, cp, packet);
+ fprintf(fd, "Bad cmd 0x%x %s %x.%d %.19s\n", msg->rip_cmd,
+ dir, inet_ntoa(who->sin_addr), ntohs(who->sin_port));
+ fprintf(fd, "size=%d cp=%x packet=%x\n", size, cp, packet,
+ ctime((time_t *)&stamp->tv_sec));
+ fflush(fd);
+ return;
+ }
+ if (tracepackets && tracecontents == 0) {
+ fflush(fd);
return;
}
switch (msg->rip_cmd) {
case RIPCMD_REQUEST:
case RIPCMD_RESPONSE:
- fprintf(fd, ":\n");
size -= 4 * sizeof (char);
n = msg->rip_nets;
for (; size > 0; n++, size -= sizeof (struct netinfo)) {
- if (size < sizeof (struct netinfo))
+ if (size < sizeof (struct netinfo)) {
+ fprintf(fd, "(truncated record, len %d)\n",
+ size);
break;
- fprintf(fd, "\tdst %x metric %d\n",
- ((struct sockaddr_in *)&n->rip_dst)->sin_addr,
- n->rip_metric);
+ }
+ if (sizeof(n->rip_dst.sa_family) > 1)
+ n->rip_dst.sa_family = ntohs(n->rip_dst.sa_family);
+
+ switch ((int)n->rip_dst.sa_family) {
+
+ case AF_INET:
+ fprintf(fd, "\tdst %s metric %d\n",
+#define satosin(sa) ((struct sockaddr_in *)&sa)
+ inet_ntoa(satosin(n->rip_dst)->sin_addr),
+ ntohl(n->rip_metric));
+ break;
+
+ default:
+ fprintf(fd, "\taf %d? metric %d\n",
+ n->rip_dst.sa_family,
+ ntohl(n->rip_metric));
+ break;
+ }
}
break;
case RIPCMD_TRACEON:
- fprintf(fd, ", file=%*s\n", size, msg->rip_tracefile);
+ fprintf(fd, "\tfile=%*s\n", size, msg->rip_tracefile);
break;
case RIPCMD_TRACEOFF:
- fprintf(fd, "\n");
break;
}
+ fflush(fd);
+ if (ferror(fd))
+ traceoff();
}