Annotation of 43BSDTahoe/etc/routed/trace.c, revision 1.1.1.1

1.1       root        1: /*
                      2:  * Copyright (c) 1983, 1988 Regents of the University of California.
                      3:  * All rights reserved.
                      4:  *
                      5:  * Redistribution and use in source and binary forms are permitted
                      6:  * provided that the above copyright notice and this paragraph are
                      7:  * duplicated in all such forms and that any documentation,
                      8:  * advertising materials, and other materials related to such
                      9:  * distribution and use acknowledge that the software was developed
                     10:  * by the University of California, Berkeley.  The name of the
                     11:  * University may not be used to endorse or promote products derived
                     12:  * from this software without specific prior written permission.
                     13:  * THIS SOFTWARE IS PROVIDED ``AS IS'' AND WITHOUT ANY EXPRESS OR
                     14:  * IMPLIED WARRANTIES, INCLUDING, WITHOUT LIMITATION, THE IMPLIED
                     15:  * WARRANTIES OF MERCHANTIBILITY AND FITNESS FOR A PARTICULAR PURPOSE.
                     16:  */
                     17: 
                     18: #ifndef lint
                     19: static char sccsid[] = "@(#)trace.c    5.7 (Berkeley) 6/18/88";
                     20: #endif /* not lint */
                     21: 
                     22: /*
                     23:  * Routing Table Management Daemon
                     24:  */
                     25: #define        RIPCMDS
                     26: #include "defs.h"
                     27: #include <sys/file.h>
                     28: #include <sys/stat.h>
                     29: #include <sys/signal.h>
                     30: 
                     31: #define        NRECORDS        50              /* size of circular trace buffer */
                     32: #ifdef DEBUG
                     33: FILE   *ftrace = stdout;
                     34: int    traceactions = 1;
                     35: #endif
                     36: 
                     37: traceinit(ifp)
                     38:        register struct interface *ifp;
                     39: {
                     40: 
                     41:        if (iftraceinit(ifp, &ifp->int_input) &&
                     42:            iftraceinit(ifp, &ifp->int_output))
                     43:                return;
                     44:        tracehistory = 0;
                     45:        fprintf(stderr, "traceinit: can't init %s\n", ifp->int_name);
                     46: }
                     47: 
                     48: static
                     49: iftraceinit(ifp, ifd)
                     50:        struct interface *ifp;
                     51:        register struct ifdebug *ifd;
                     52: {
                     53:        register struct iftrace *t;
                     54: 
                     55:        ifd->ifd_records =
                     56:          (struct iftrace *)malloc(NRECORDS * sizeof (struct iftrace));
                     57:        if (ifd->ifd_records == 0)
                     58:                return (0);
                     59:        ifd->ifd_front = ifd->ifd_records;
                     60:        ifd->ifd_count = 0;
                     61:        for (t = ifd->ifd_records; t < ifd->ifd_records + NRECORDS; t++) {
                     62:                t->ift_size = 0;
                     63:                t->ift_packet = 0;
                     64:        }
                     65:        ifd->ifd_if = ifp;
                     66:        return (1);
                     67: }
                     68: 
                     69: traceon(file)
                     70:        char *file;
                     71: {
                     72:        struct stat stbuf;
                     73: 
                     74:        if (ftrace != NULL)
                     75:                return;
                     76:        if (stat(file, &stbuf) >= 0 && (stbuf.st_mode & S_IFMT) != S_IFREG)
                     77:                return;
                     78:        ftrace = fopen(file, "a");
                     79:        if (ftrace == NULL)
                     80:                return;
                     81:        dup2(fileno(ftrace), 1);
                     82:        dup2(fileno(ftrace), 2);
                     83:        traceactions = 1;
                     84: }
                     85: 
                     86: traceoff()
                     87: {
                     88:        if (!traceactions)
                     89:                return;
                     90:        if (ftrace != NULL) {
                     91:                int fd = open("/dev/null", O_RDWR);
                     92: 
                     93:                fprintf(ftrace, "Tracing disabled\n");
                     94:                (void) dup2(fd, 1);
                     95:                (void) dup2(fd, 2);
                     96:                (void) close(fd);
                     97:                fclose(ftrace);
                     98:                ftrace = NULL;
                     99:        }
                    100:        traceactions = 0;
                    101:        tracehistory = 0;
                    102: }
                    103: 
                    104: sigtrace(s)
                    105:        int s;
                    106: {
                    107:        if (s == SIGUSR2) {
                    108:                traceoff();
                    109:                tracepackets = 0;
                    110:        } else if (traceactions == 0)
                    111:                traceactions++;
                    112:        else if (tracehistory == 0)
                    113:                tracehistory++;
                    114:        else {
                    115:                tracepackets++;
                    116:                tracehistory = 0;
                    117:        }
                    118: }
                    119: 
                    120: trace(ifd, who, p, len, m)
                    121:        register struct ifdebug *ifd;
                    122:        struct sockaddr *who;
                    123:        char *p;
                    124:        int len, m;
                    125: {
                    126:        register struct iftrace *t;
                    127: 
                    128:        if (ifd->ifd_records == 0)
                    129:                return;
                    130:        t = ifd->ifd_front++;
                    131:        if (ifd->ifd_front >= ifd->ifd_records + NRECORDS)
                    132:                ifd->ifd_front = ifd->ifd_records;
                    133:        if (ifd->ifd_count < NRECORDS)
                    134:                ifd->ifd_count++;
                    135:        if (t->ift_size > 0 && t->ift_size < len && t->ift_packet) {
                    136:                free(t->ift_packet);
                    137:                t->ift_packet = 0;
                    138:        }
                    139:        t->ift_stamp = time(0);
                    140:        t->ift_who = *who;
                    141:        if (len > 0 && t->ift_packet == 0) {
                    142:                t->ift_packet = malloc(len);
                    143:                if (t->ift_packet == 0)
                    144:                        len = 0;
                    145:        }
                    146:        if (len > 0)
                    147:                bcopy(p, t->ift_packet, len);
                    148:        t->ift_size = len;
                    149:        t->ift_metric = m;
                    150: }
                    151: 
                    152: traceaction(fd, action, rt)
                    153:        FILE *fd;
                    154:        char *action;
                    155:        struct rt_entry *rt;
                    156: {
                    157:        struct sockaddr_in *dst, *gate;
                    158:        static struct bits {
                    159:                int     t_bits;
                    160:                char    *t_name;
                    161:        } flagbits[] = {
                    162:                { RTF_UP,       "UP" },
                    163:                { RTF_GATEWAY,  "GATEWAY" },
                    164:                { RTF_HOST,     "HOST" },
                    165:                { 0 }
                    166:        }, statebits[] = {
                    167:                { RTS_PASSIVE,  "PASSIVE" },
                    168:                { RTS_REMOTE,   "REMOTE" },
                    169:                { RTS_INTERFACE,"INTERFACE" },
                    170:                { RTS_CHANGED,  "CHANGED" },
                    171:                { RTS_INTERNAL, "INTERNAL" },
                    172:                { RTS_EXTERNAL, "EXTERNAL" },
                    173:                { RTS_SUBNET,   "SUBNET" },
                    174:                { 0 }
                    175:        };
                    176:        register struct bits *p;
                    177:        register int first;
                    178:        char *cp;
                    179:        struct interface *ifp;
                    180: 
                    181:        if (fd == NULL)
                    182:                return;
                    183:        if (curtime) {
                    184:                fprintf(fd, "\n%s", curtime);
                    185:                curtime = NULL;
                    186:        }
                    187:        fprintf(fd, "%s ", action);
                    188:        dst = (struct sockaddr_in *)&rt->rt_dst;
                    189:        gate = (struct sockaddr_in *)&rt->rt_router;
                    190:        fprintf(fd, "dst %s, ", inet_ntoa(dst->sin_addr));
                    191:        fprintf(fd, "router %s, metric %d, flags",
                    192:             inet_ntoa(gate->sin_addr), rt->rt_metric);
                    193:        cp = " %s";
                    194:        for (first = 1, p = flagbits; p->t_bits > 0; p++) {
                    195:                if ((rt->rt_flags & p->t_bits) == 0)
                    196:                        continue;
                    197:                fprintf(fd, cp, p->t_name);
                    198:                if (first) {
                    199:                        cp = "|%s";
                    200:                        first = 0;
                    201:                }
                    202:        }
                    203:        fprintf(fd, " state");
                    204:        cp = " %s";
                    205:        for (first = 1, p = statebits; p->t_bits > 0; p++) {
                    206:                if ((rt->rt_state & p->t_bits) == 0)
                    207:                        continue;
                    208:                fprintf(fd, cp, p->t_name);
                    209:                if (first) {
                    210:                        cp = "|%s";
                    211:                        first = 0;
                    212:                }
                    213:        }
                    214:        fprintf(fd, " timer %d\n", rt->rt_timer);
                    215:        if (!tracepackets && (rt->rt_state & RTS_PASSIVE) == 0 && rt->rt_ifp)
                    216:                dumpif(fd, rt->rt_ifp);
                    217:        fflush(fd);
                    218: }
                    219: 
                    220: tracenewmetric(fd, rt, newmetric)
                    221:        FILE *fd;
                    222:        struct rt_entry *rt;
                    223:        int newmetric;
                    224: {
                    225:        struct sockaddr_in *dst, *gate;
                    226: 
                    227:        if (fd == NULL)
                    228:                return;
                    229:        dst = (struct sockaddr_in *)&rt->rt_dst;
                    230:        gate = (struct sockaddr_in *)&rt->rt_router;
                    231:        fprintf(fd, "CHANGE metric dst %s, ", inet_ntoa(dst->sin_addr));
                    232:        fprintf(fd, "router %s, from %d to %d\n",
                    233:             inet_ntoa(gate->sin_addr), rt->rt_metric, newmetric);
                    234:        fflush(fd);
                    235: }
                    236: 
                    237: dumpif(fd, ifp)
                    238:        register struct interface *ifp;
                    239: {
                    240:        if (ifp->int_input.ifd_count || ifp->int_output.ifd_count) {
                    241:                fprintf(fd, "*** Packet history for interface %s ***\n",
                    242:                        ifp->int_name);
                    243: #ifdef notneeded
                    244:                dumptrace(fd, "to", &ifp->int_output);
                    245: #endif
                    246:                dumptrace(fd, "from", &ifp->int_input);
                    247:                fprintf(fd, "*** end packet history ***\n");
                    248:        }
                    249:        fflush(fd);
                    250: }
                    251: 
                    252: dumptrace(fd, dir, ifd)
                    253:        FILE *fd;
                    254:        char *dir;
                    255:        register struct ifdebug *ifd;
                    256: {
                    257:        register struct iftrace *t;
                    258:        char *cp = !strcmp(dir, "to") ? "Output" : "Input";
                    259: 
                    260:        if (ifd->ifd_front == ifd->ifd_records &&
                    261:            ifd->ifd_front->ift_size == 0) {
                    262:                fprintf(fd, "%s: no packets.\n", cp);
                    263:                fflush(fd);
                    264:                return;
                    265:        }
                    266:        fprintf(fd, "%s trace:\n", cp);
                    267:        t = ifd->ifd_front - ifd->ifd_count;
                    268:        if (t < ifd->ifd_records)
                    269:                t += NRECORDS;
                    270:        for ( ; ifd->ifd_count; ifd->ifd_count--, t++) {
                    271:                if (t >= ifd->ifd_records + NRECORDS)
                    272:                        t = ifd->ifd_records;
                    273:                if (t->ift_size == 0)
                    274:                        continue;
                    275:                dumppacket(fd, dir, &t->ift_who, t->ift_packet, t->ift_size,
                    276:                    &t->ift_stamp);
                    277:        }
                    278: }
                    279: 
                    280: dumppacket(fd, dir, who, cp, size, tstamp)
                    281:        FILE *fd;
                    282:        struct sockaddr_in *who;                /* should be sockaddr */
                    283:        char *dir, *cp;
                    284:        register int size;
                    285:        time_t *tstamp;
                    286: {
                    287:        register struct rip *msg = (struct rip *)cp;
                    288:        register struct netinfo *n;
                    289: 
                    290:        if (msg->rip_cmd && msg->rip_cmd < RIPCMD_MAX)
                    291:                fprintf(fd, "%s %s %s.%d", ripcmds[msg->rip_cmd],
                    292:                    dir, inet_ntoa(who->sin_addr), ntohs(who->sin_port));
                    293:        else {
                    294:                fprintf(fd, "Bad cmd 0x%x %s %x.%d %.24s\n", msg->rip_cmd,
                    295:                    dir, inet_ntoa(who->sin_addr), ntohs(who->sin_port),
                    296:                    ctime(tstamp));
                    297:                fprintf(fd, "size=%d cp=%x packet=%x\n", size, cp, packet);
                    298:                fflush(fd);
                    299:                return;
                    300:        }
                    301:        fprintf(fd, " %.24s:\n", ctime(tstamp));
                    302:        switch (msg->rip_cmd) {
                    303: 
                    304:        case RIPCMD_REQUEST:
                    305:        case RIPCMD_RESPONSE:
                    306:                size -= 4 * sizeof (char);
                    307:                n = msg->rip_nets;
                    308:                for (; size > 0; n++, size -= sizeof (struct netinfo)) {
                    309:                        if (size < sizeof (struct netinfo))
                    310:                                break;
                    311:                        fprintf(fd, "\tdst %s metric %d\n",
                    312: #define        satosin(sa)     ((struct sockaddr_in *)&sa)
                    313:                             inet_ntoa(satosin(n->rip_dst)->sin_addr),
                    314:                             ntohl(n->rip_metric));
                    315:                }
                    316:                break;
                    317: 
                    318:        case RIPCMD_TRACEON:
                    319:                fprintf(fd, "\tfile=%*s\n", size, msg->rip_tracefile);
                    320:                break;
                    321: 
                    322:        case RIPCMD_TRACEOFF:
                    323:                break;
                    324:        }
                    325:        fflush(fd);
                    326: }

unix.superglobalmegacorp.com

This archive runs on limited infrastructure. Preserving old code on modern bandwidth. Automated agents are requested to crawl responsibly.