diff options
Diffstat (limited to 'tcpip/rip98d.c')
| -rw-r--r-- | tcpip/rip98d.c | 360 |
1 files changed, 360 insertions, 0 deletions
diff --git a/tcpip/rip98d.c b/tcpip/rip98d.c new file mode 100644 index 0000000..78851cd --- /dev/null +++ b/tcpip/rip98d.c @@ -0,0 +1,360 @@ +#include <stdio.h> +#include <stdlib.h> +#include <string.h> +#include <unistd.h> +#include <netdb.h> +#include <syslog.h> +#include <signal.h> + +#include <sys/types.h> +#include <sys/ioctl.h> +#include <sys/time.h> + +#include <sys/socket.h> +#include <netinet/in.h> +#include <arpa/inet.h> +#include <net/if.h> +#include <net/route.h> + +#include <netax25/daemon.h> + +#include <config.h> + +#include "../pathnames.h" +#include "rip98d.h" + +struct dest_struct dest_list[50]; + +int dest_count = 0; + +int debug = FALSE; +int restrict = FALSE; +int logging = FALSE; + +struct route_struct *first_route = NULL; + +static struct mask_struct { + unsigned long int mask; + unsigned int bits; +} mask_table[] = { + {0xFFFFFFFF, 32}, + {0xFFFFFFFE, 31}, + {0xFFFFFFFC, 30}, + {0xFFFFFFF8, 29}, + {0xFFFFFFF0, 28}, + {0xFFFFFFE0, 27}, + {0xFFFFFFC0, 26}, + {0xFFFFFF80, 25}, + {0xFFFFFF00, 24}, + {0xFFFFFE00, 23}, + {0xFFFFFC00, 22}, + {0xFFFFF800, 21}, + {0xFFFFF000, 20}, + {0xFFFFE000, 19}, + {0xFFFFC000, 18}, + {0xFFFF8000, 17}, + {0xFFFF0000, 16}, + {0xFFFE0000, 15}, + {0xFFFC0000, 14}, + {0xFFF80000, 13}, + {0xFFF00000, 12}, + {0xFFE00000, 11}, + {0xFFC00000, 10}, + {0xFF800000, 9}, + {0xFF000000, 8}, + {0xFE000000, 7}, + {0xFC000000, 6}, + {0xF8000000, 5}, + {0xF0000000, 4}, + {0xE0000000, 3}, + {0xC0000000, 2}, + {0x80000000, 1}, + {0x00000000, 0}, +}; + +static void terminate(int sig) +{ + if (logging) { + syslog(LOG_INFO, "terminating on SIGTERM\n"); + closelog(); + } + + exit(0); +} + +unsigned int mask2bits(unsigned long int mask) +{ + struct mask_struct *t; + + for (t = mask_table; t->mask != 0; t++) + if (mask == t->mask) + return t->bits; + + return 0; +} + +unsigned long int bits2mask(unsigned int bits) +{ + struct mask_struct *t; + + for (t = mask_table; t->mask != 0; t++) + if (bits == t->bits) + return htonl(t->mask); + + return 0; +} + +static unsigned long int hex2intrev(char *buffer) +{ + unsigned long int result = 0L; + + if (buffer[0] >= 'A') + result += (buffer[0] - 'A' + 10) * 16; + else + result += (buffer[0] - '0') * 16; + + if (buffer[1] >= 'A') + result += buffer[1] - 'A' + 10; + else + result += buffer[1] - '0'; + + if (buffer[2] >= 'A') + result += (buffer[2] - 'A' + 10) * 16 * 16 * 16; + else + result += (buffer[2] - '0') * 16 * 16 * 16; + + if (buffer[3] >= 'A') + result += (buffer[3] - 'A' + 10) * 16 * 16; + else + result += (buffer[3] - '0') * 16 * 16; + + if (buffer[4] >= 'A') + result += (buffer[4] - 'A' + 10) * 16 * 16 * 16 * 16 * 16; + else + result += (buffer[4] - '0') * 16 * 16 * 16 * 16 * 16; + + if (buffer[5] >= 'A') + result += (buffer[5] - 'A' + 10) * 16 * 16 * 16 * 16; + else + result += (buffer[5] - '0') * 16 * 16 * 16 * 16; + + if (buffer[6] >= 'A') + result += (buffer[6] - 'A' + 10) * 16 * 16 * 16 * 16 * 16 * 16 * 16; + else + result += (buffer[6] - '0') * 16 * 16 * 16 * 16 * 16 * 16 * 16; + + if (buffer[7] >= 'A') + result += (buffer[7] - 'A' + 10) * 16 * 16 * 16 * 16 * 16 * 16; + else + result += (buffer[7] - '0') * 16 * 16 * 16 * 16 * 16 * 16; + + return result; +} + +static int read_routes(void) +{ + struct route_struct *route, *temp; + char buffer[1023], iface[16], net_addr[64], gate_addr[64], mask_addr[64]; + int n, iflags, refcnt, use, metric, mss, window; + struct in_addr address; + unsigned long int netmask; + unsigned long int network; + FILE *fp; + + if (first_route != NULL) { + route = first_route; + + while (route != NULL) { + temp = route->next; + free(route); + route = temp; + } + + first_route = NULL; + } + + if ((fp = fopen(PROC_IP_ROUTE_FILE, "r")) == NULL) { + if (logging) + syslog(LOG_ERR, "error cannot open %s\n", PROC_IP_ROUTE_FILE); + return FALSE; + } + + while (fgets(buffer, 1023, fp) != NULL) { + n = sscanf(buffer, "%s %s %s %X %d %d %d %s %d %d\n", + iface, net_addr, gate_addr, &iflags, &refcnt, &use, + &metric, mask_addr, &mss, &window); + + if (n != 10) + continue; + + address.s_addr = htonl(hex2intrev(net_addr)); + netmask = mask2bits(hex2intrev(mask_addr)); + + network = inet_netof(address); + + if (network == 0 || network == 127) { + if (debug && logging) + syslog(LOG_DEBUG, "rejecting route to %s/%ld - should not be propogated\n", inet_ntoa(address), netmask); + continue; + } + + if (restrict) { + if (inet_netof(address) != 44) { + if (debug && logging) + syslog(LOG_DEBUG, "rejecting route to %s/%ld - not ampr.org\n", inet_ntoa(address), netmask); + continue; + } + } + + if ((route = malloc(sizeof(struct route_struct))) == NULL) { + if (logging) + syslog(LOG_ERR, "out of memory !\n"); + return FALSE; + } + + route->addr = address; + route->bits = netmask; + route->metric = metric; + route->action = (iflags & RTF_DYNAMIC) ? ORIG_ROUTE : FIXED_ROUTE; + + route->next = first_route; + first_route = route; + } + + fclose(fp); + + return TRUE; +} + +static int load_dests(void) +{ + struct hostent *host; + char buffer[255], *s; + FILE *fp; + + if ((fp = fopen(CONF_RIP98D_FILE, "r")) == NULL) { + fprintf(stderr, "rip98d: cannot open config file\n"); + return FALSE; + } + + while (fgets(buffer, 255, fp) != NULL) { + if ((s = strchr(buffer, '\n')) != NULL) *s = '\0'; + + if ((host = gethostbyname(buffer)) == NULL) { + fprintf(stderr, "rip98d: cannot resolve name %s\n", buffer); + fclose(fp); + return FALSE; + } + + bcopy(host->h_addr, (char *)&dest_list[dest_count].dest_addr, host->h_length); + dest_count++; + } + + fclose(fp); + + if (dest_count == 0) + return FALSE; + + return TRUE; +} + +int main(int argc, char **argv) +{ + int s, i; + struct sockaddr_in loc_addr; + struct timeval timeout; + time_t timenow, timelast = 0; + int interval = 3600; + fd_set fdset; + + if (!load_dests()) { + fprintf(stderr, "rip98d: no destination routers defined\n"); + return 1; + } + + while ((i = getopt(argc, argv, "dlrt:v")) != -1) { + switch (i) { + case 'd': + debug = TRUE; + break; + case 'l': + logging = TRUE; + break; + case 'r': + restrict = TRUE; + break; + case 't': + interval = atoi(optarg) * 60; + if (interval < 60 || interval > 7200) { + fprintf(stderr, "rip98d: invalid time interval\n"); + return 1; + } + break; + case 'v': + printf("rip98d: %s\n", VERSION); + return 0; + case ':': + fprintf(stderr, "rip98d: invalid time interval\n"); + return 1; + case '?': + fprintf(stderr, "usage: rip98d [-d] [-l] [-r] [-t interval] [-v]\n"); + return 1; + } + } + + signal(SIGTERM, terminate); + + if ((s = socket(AF_INET, SOCK_DGRAM, 0)) < 0) { + perror("rip98d: socket"); + return 1; + } + + bzero((char *)&loc_addr, sizeof(loc_addr)); + loc_addr.sin_family = AF_INET; + loc_addr.sin_addr.s_addr = htonl(INADDR_ANY); + loc_addr.sin_port = htons(RIP_PORT); + + if (bind(s, (struct sockaddr *)&loc_addr, sizeof(loc_addr)) < 0) { + perror("rip98d: bind"); + close(s); + return 1; + } + + if (!daemon_start(FALSE)) { + fprintf(stderr, "rip98d: cannot become a daemon\n"); + close(s); + return 1; + } + + if (logging) { + openlog("rip98d", LOG_PID, LOG_DAEMON); + syslog(LOG_INFO, "starting"); + } + + for (;;) { + FD_ZERO(&fdset); + FD_SET(s, &fdset); + + timeout.tv_sec = 60; + timeout.tv_usec = 0; + + select(s + 1, &fdset, NULL, NULL, &timeout); + + if (!read_routes()) { + if (logging) + closelog(); + return 1; + } + + if (FD_ISSET(s, &fdset)) + receive_routes(s); + + time(&timenow); + + if ((timenow - timelast) > interval) { + timelast = timenow; + if (first_route != NULL) + transmit_routes(s); + } + } +} |