![[BACK]](/cvsweb/icons/back.gif){kind=icon}
Return to named-xfer.c CVS log ![[TXT]](/cvsweb/icons/text.gif){kind=icon}
![[DIR]](/cvsweb/icons/dir.gif){kind=icon}
Up to [CSRG BSD Unix] / 43BSDReno / usr.sbin / named / xfer|
Return to named-xfer.c CVS log | Up to [CSRG BSD Unix] / 43BSDReno / usr.sbin / named / xfer |
1.1 ! root 1: /*- ! 2: * Copyright (c) 1988, 1990 The Regents of the University of California. ! 3: * All rights reserved. ! 4: * ! 5: * Redistribution and use in source and binary forms are permitted provided ! 6: * that: (1) source distributions retain this entire copyright notice and ! 7: * comment, and (2) distributions including binaries display the following ! 8: * acknowledgement: ``This product includes software developed by the ! 9: * University of California, Berkeley and its contributors'' in the ! 10: * documentation or other materials provided with the distribution and in ! 11: * all advertising materials mentioning features or use of this software. ! 12: * Neither the name of the University nor the names of its contributors may ! 13: * be used to endorse or promote products derived from this software without ! 14: * specific prior written permission. ! 15: * THIS SOFTWARE IS PROVIDED ``AS IS'' AND WITHOUT ANY EXPRESS OR IMPLIED ! 16: * WARRANTIES, INCLUDING, WITHOUT LIMITATION, THE IMPLIED WARRANTIES OF ! 17: * MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE. ! 18: * ! 19: * The original version of xfer by Kevin Dunlap. ! 20: * Completed and integrated with named by David Waitzman ! 21: * ([email protected]) 3/14/88. ! 22: * Modified by M. Karels and O. Kure 10-88. ! 23: */ ! 24: ! 25: #ifndef lint ! 26: char copyright[] = ! 27: "@(#) Copyright (c) 1988, 1990 The Regents of the University of California.\n\ ! 28: All rights reserved.\n"; ! 29: #endif /* not lint */ ! 30: ! 31: #ifndef lint ! 32: static char sccsid[] = "@(#)named-xfer.c 4.15 (Berkeley) 7/24/90"; ! 33: #endif /* not lint */ ! 34: ! 35: #include <sys/types.h> ! 36: #include <sys/file.h> ! 37: #include <sys/stat.h> ! 38: #include <sys/socket.h> ! 39: #include <sys/uio.h> ! 40: #include <sys/signal.h> ! 41: ! 42: #include <netinet/in.h> ! 43: #include <net/if.h> ! 44: #include <netdb.h> ! 45: #include <arpa/inet.h> ! 46: #include <arpa/nameser.h> ! 47: ! 48: #include <errno.h> ! 49: #include <resolv.h> ! 50: #include <string.h> ! 51: #include <stdio.h> ! 52: #include <syslog.h> ! 53: ! 54: #define XFER /* modifies the ns.h include file */ ! 55: #include "ns.h" ! 56: #include "pathnames.h" ! 57: ! 58: char *savestr(); ! 59: ! 60: /* max length of data in RR data field */ ! 61: #define MAXDATA 2048 /* from db.h */ ! 62: ! 63: int debug = 0; ! 64: int quiet = 0; ! 65: int read_interrupted = 0; ! 66: struct zoneinfo zones; /* zone information */ ! 67: struct timeval tt; ! 68: ! 69: static char *ddtfile = _PATH_TMPXFER; ! 70: static char *tmpname; ! 71: FILE *fp = 0, *ddt, *dbfp; ! 72: char *domain; /* domain being xfered */ ! 73: int domain_len; /* strlen(domain) */ ! 74: ! 75: main(argc, argv) ! 76: int argc; ! 77: char *argv[]; ! 78: { ! 79: register struct zoneinfo *zp; ! 80: register struct hostent *hp; ! 81: char *dbfile = NULL, *tracefile = NULL, *tm = NULL; ! 82: int dbfd, ddtd, result, c; ! 83: u_long serial_no = 0; ! 84: extern char *optarg; ! 85: extern int optind, getopt(); ! 86: u_short port = htons(NAMESERVER_PORT); ! 87: ! 88: (void) umask(022); ! 89: #ifdef LOG_DAEMON ! 90: openlog("named-xfer", LOG_PID|LOG_CONS, LOG_DAEMON); ! 91: #else ! 92: openlog("named-xfer", LOG_PID); ! 93: #endif ! 94: while ((c = getopt(argc, argv, "d:l:s:t:z:f:p:P:q")) != EOF) ! 95: switch (c) { ! 96: case 'd': ! 97: debug = atoi(optarg); ! 98: break; ! 99: case 'l': ! 100: ddtfile = (char *)malloc(strlen(optarg) + ! 101: sizeof(".XXXXXX") + 1); ! 102: (void) strcpy(ddtfile, optarg); ! 103: (void) strcat(ddtfile, ".XXXXXX"); ! 104: break; ! 105: case 's': ! 106: serial_no = (u_long) atol(optarg); ! 107: break; ! 108: case 't': ! 109: tracefile = optarg; ! 110: break; ! 111: case 'z': /* zone == domain */ ! 112: domain = optarg; ! 113: domain_len = strlen(domain); ! 114: break; ! 115: case 'f': ! 116: dbfile = optarg; ! 117: tmpname = (char *)malloc((unsigned)strlen(optarg) + ! 118: sizeof(".XXXXXX") + 1); ! 119: (void) strcpy(tmpname, optarg); ! 120: break; ! 121: case 'p': ! 122: port = htons((u_short)atoi(optarg)); ! 123: break; ! 124: case 'P': ! 125: port = (u_short)atoi(optarg); ! 126: break; ! 127: case 'q': ! 128: quiet++; ! 129: break; ! 130: case '?': ! 131: default: ! 132: usage(); ! 133: /* NOTREACHED */ ! 134: } ! 135: ! 136: if (!domain || !dbfile || optind >= argc) { ! 137: usage(); ! 138: /* NOTREACHED */ ! 139: } ! 140: if (tracefile && (fp = fopen(tracefile, "w")) == NULL) ! 141: perror(tracefile); ! 142: (void) strcat(tmpname, ".XXXXXX"); ! 143: /* tmpname is now something like "/etc/named/named.bu.db.XXXXXX" */ ! 144: if ((dbfd = mkstemp(tmpname)) == -1) { ! 145: perror(tmpname); ! 146: if (!quiet) ! 147: syslog(LOG_ERR, "can't make tmpfile (%s): %m\n", ! 148: tmpname); ! 149: exit(XFER_FAIL); ! 150: } ! 151: if (fchmod(dbfd, 0644) == -1) { ! 152: perror(tmpname); ! 153: if (!quiet) ! 154: syslog(LOG_ERR, "can't fchmod tmpfile (%s): %m\n", ! 155: tmpname); ! 156: exit(XFER_FAIL); ! 157: } ! 158: if ((dbfp = fdopen(dbfd, "r+")) == NULL) { ! 159: perror(tmpname); ! 160: if (!quiet) ! 161: syslog(LOG_ERR, "can't fdopen tmpfile (%s)", tmpname); ! 162: exit(XFER_FAIL); ! 163: } ! 164: #ifdef DEBUG ! 165: if (debug) { ! 166: /* ddtfile is now something like "/usr/tmp/xfer.ddt.XXXXXX" */ ! 167: if ((ddtd = mkstemp(ddtfile)) == -1) { ! 168: perror(ddtfile); ! 169: debug = 0; ! 170: } else if (fchmod(ddtd, 0644) == -1) { ! 171: perror(ddtfile); ! 172: debug = 0; ! 173: } else if ((ddt = fdopen(ddtd, "w")) == NULL) { ! 174: perror(ddtfile); ! 175: debug = 0; ! 176: } else { ! 177: #if defined(SYSV) ! 178: setvbuf(ddt, NULL, _IOLBF, BUFSIZ); ! 179: #else ! 180: setlinebuf(ddt); ! 181: #endif ! 182: } ! 183: } ! 184: #endif ! 185: /* ! 186: * Ignore many types of signals that named (assumed to be our parent) ! 187: * considers important- if not, the user controlling named with ! 188: * signals usually kills us. ! 189: */ ! 190: (void) signal(SIGHUP, SIG_IGN); ! 191: (void) signal(SIGSYS, SIG_IGN); ! 192: if (debug == 0) { ! 193: (void) signal(SIGINT, SIG_IGN); ! 194: (void) signal(SIGQUIT, SIG_IGN); ! 195: } ! 196: (void) signal(SIGIOT, SIG_IGN); ! 197: ! 198: #if defined(SIGUSR1) && defined(SIGUSR2) ! 199: (void) signal(SIGUSR1, SIG_IGN); ! 200: (void) signal(SIGUSR2, SIG_IGN); ! 201: #else SIGUSR1&&SIGUSR2 ! 202: (void) signal(SIGEMT, SIG_IGN); ! 203: (void) signal(SIGFPE, SIG_IGN); ! 204: #endif SIGUSR1&&SIGUSR2 ! 205: ! 206: #ifdef DEBUG ! 207: if (debug) (void)fprintf(ddt, "domain `%s' file `%s' ser no %lu \n", ! 208: domain, dbfile,serial_no); ! 209: #endif ! 210: buildservicelist(); ! 211: buildprotolist(); ! 212: ! 213: /* init zone data */ ! 214: ! 215: zp = &zones; ! 216: zp->z_type = Z_SECONDARY; ! 217: zp->z_origin = domain; ! 218: zp->z_source = dbfile; ! 219: zp->z_addrcnt = 0; ! 220: #ifdef DEBUG ! 221: if (debug) { ! 222: (void)fprintf(ddt,"zone found (%d): ", zp->z_type); ! 223: if (zp->z_origin[0] == '\0') ! 224: (void)fprintf(ddt,"'.'"); ! 225: else ! 226: (void)fprintf(ddt,"'%s'", zp->z_origin); ! 227: (void)fprintf(ddt,", source = %s\n", zp->z_source); ! 228: } ! 229: #endif ! 230: for (; optind != argc; optind++,zp->z_addrcnt++) { ! 231: tm = argv[optind]; ! 232: zp->z_addr[zp->z_addrcnt].s_addr = inet_addr(tm); ! 233: ! 234: if (zp->z_addr[zp->z_addrcnt].s_addr == (unsigned)-1) { ! 235: hp = gethostbyname(tm); ! 236: if (hp == NULL) { ! 237: syslog(LOG_ERR, "uninterpretable server %s\n", ! 238: tm); ! 239: continue; ! 240: } ! 241: bcopy(hp->h_addr, ! 242: (char *)&zp->z_addr[zp->z_addrcnt].s_addr, ! 243: sizeof(zp->z_addr[zp->z_addrcnt].s_addr)); ! 244: #ifdef DEBUG ! 245: if (debug) ! 246: (void)fprintf(ddt,", %s",tm); ! 247: #endif ! 248: } ! 249: if (zp->z_addrcnt >= NSMAX) { ! 250: zp->z_addrcnt = NSMAX; ! 251: #ifdef DEBUG ! 252: if (debug) ! 253: (void)fprintf(ddt, "\nns.h NSMAX reached\n"); ! 254: #endif ! 255: break; ! 256: } ! 257: } ! 258: #ifdef DEBUG ! 259: if (debug) (void)fprintf(ddt," (addrcnt) = %d\n", zp->z_addrcnt); ! 260: #endif ! 261: ! 262: _res.options &= ~(RES_DEFNAMES | RES_DNSRCH | RES_RECURSE); ! 263: result = getzone(zp, serial_no, port); ! 264: (void) fclose(dbfp); ! 265: switch (result) { ! 266: ! 267: case XFER_SUCCESS: /* ok exit */ ! 268: if (rename(tmpname, dbfile) == -1) { ! 269: perror("rename"); ! 270: if (!quiet) ! 271: syslog(LOG_ERR, "rename %s to %s: %m", ! 272: tmpname, dbfile); ! 273: exit(XFER_FAIL); ! 274: } ! 275: exit(XFER_SUCCESS); ! 276: ! 277: case XFER_UPTODATE: /* the zone was already uptodate */ ! 278: (void) unlink(tmpname); ! 279: exit(XFER_UPTODATE); ! 280: ! 281: case XFER_TIMEOUT: ! 282: #ifdef DEBUG ! 283: if (!debug) ! 284: #endif ! 285: (void) unlink(tmpname); ! 286: exit(XFER_TIMEOUT); /* servers not reachable exit */ ! 287: ! 288: case XFER_FAIL: ! 289: default: ! 290: #ifdef DEBUG ! 291: if (!debug) ! 292: #endif ! 293: (void) unlink(tmpname); ! 294: exit(XFER_FAIL); /* yuck exit */ ! 295: } ! 296: } ! 297: ! 298: usage() ! 299: { ! 300: (void)fprintf(stderr, ! 301: "Usage: xfer\n\ ! 302: \t-z zone_to_transfer\n\ ! 303: \t-f db_file\n\ ! 304: \t-s serial_no\n\ ! 305: \t[-d debug_level]\n\ ! 306: \t[-l debug_log_file (default %s)]\n\ ! 307: \t[-t trace_file]\n\ ! 308: \t[-p port]\n\ ! 309: \tservers...\n", ddtfile); ! 310: exit(XFER_FAIL); ! 311: } ! 312: ! 313: int minimum_ttl = 0, got_soa = 0; ! 314: char prev_origin[MAXDNAME]; ! 315: char prev_dname[MAXDNAME]; ! 316: ! 317: getzone(zp, serial_no, port) ! 318: struct zoneinfo *zp; ! 319: u_long serial_no; ! 320: u_short port; ! 321: { ! 322: HEADER *hp; ! 323: u_short len; ! 324: u_long serial; ! 325: int s, n, l, cnt, soacnt, error = 0; ! 326: u_char *cp, *nmp, *eom, *tmp ; ! 327: u_char *buf = NULL; ! 328: int bufsize; ! 329: u_char name[MAXDNAME], name2[MAXDNAME]; ! 330: struct sockaddr_in sin; ! 331: struct zoneinfo zp_start, zp_finish; ! 332: struct itimerval ival, zeroival; ! 333: extern VOID read_alarm(); ! 334: struct sigvec sv, osv; ! 335: int ancount, aucount; ! 336: #ifdef DEBUG ! 337: if (debug) ! 338: (void)fprintf(ddt,"getzone() %s\n", zp->z_origin); ! 339: #endif ! 340: bzero((char *)&zeroival, sizeof(zeroival)); ! 341: ival = zeroival; ! 342: ival.it_value.tv_sec = 120; ! 343: sv.sv_handler = read_alarm; ! 344: sv.sv_onstack = 0; ! 345: sv.sv_mask = ~0; ! 346: (void) sigvec(SIGALRM, &sv, &osv); ! 347: ! 348: strcpy(prev_origin, zp->z_origin); ! 349: ! 350: for (cnt = 0; cnt < zp->z_addrcnt; cnt++) { ! 351: error = 0; ! 352: if (buf == NULL) { ! 353: if ((buf = (u_char *)malloc(2 * PACKETSZ)) == NULL) { ! 354: syslog(LOG_ERR, "malloc(%u) failed", ! 355: 2 * PACKETSZ); ! 356: error++; ! 357: break; ! 358: } ! 359: bufsize = 2 * PACKETSZ; ! 360: } ! 361: bzero((char *)&sin, sizeof(sin)); ! 362: sin.sin_family = AF_INET; ! 363: sin.sin_port = port; ! 364: sin.sin_addr = zp->z_addr[cnt]; ! 365: if ((s = socket(AF_INET, SOCK_STREAM, 0)) < 0) { ! 366: syslog(LOG_ERR, "socket: %m"); ! 367: error++; ! 368: break; ! 369: } ! 370: #ifdef DEBUG ! 371: if (debug >= 2) { ! 372: (void)fprintf(ddt,"connecting to server #%d %s, %d\n", ! 373: cnt+1, inet_ntoa(sin.sin_addr), ntohs(sin.sin_port)); ! 374: } ! 375: #endif ! 376: if (connect(s, (struct sockaddr *)&sin, sizeof(sin)) < 0) { ! 377: (void) close(s); ! 378: error++; ! 379: #ifdef DEBUG ! 380: if (debug >= 2) ! 381: (void)fprintf(ddt, "connect failed, %s\n", ! 382: strerror(errno)); ! 383: #endif ! 384: continue; ! 385: } ! 386: if ((n = res_mkquery(QUERY, zp->z_origin, C_IN, ! 387: T_SOA, (char *)NULL, 0, NULL, buf, bufsize)) < 0) { ! 388: if (!quiet) ! 389: syslog(LOG_ERR, "zone %s: res_mkquery T_SOA failed", ! 390: zp->z_origin); ! 391: (void) close(s); ! 392: (void) sigvec(SIGALRM, &osv, (struct sigvec *)0); ! 393: return XFER_FAIL; ! 394: } ! 395: /* ! 396: * Send length & message for zone transfer ! 397: */ ! 398: if (writemsg(s, buf, n) < 0) { ! 399: (void) close(s); ! 400: error++; ! 401: #ifdef DEBUG ! 402: if (debug >= 2) ! 403: (void)fprintf(ddt,"writemsg failed\n"); ! 404: #endif ! 405: continue; ! 406: } ! 407: /* ! 408: * Get out your butterfly net and catch the SOA ! 409: */ ! 410: cp = buf; ! 411: l = sizeof(u_short); ! 412: read_interrupted = 0; ! 413: while (l > 0) { ! 414: #ifdef DEBUG ! 415: if (debug > 10) (void)fprintf(ddt,"Before setitimer\n"); ! 416: #endif ! 417: (void) setitimer(ITIMER_REAL, &ival, ! 418: (struct itimerval *)NULL); ! 419: #ifdef DEBUG ! 420: if (debug > 10) (void)fprintf(ddt,"Before recv(l = %d)\n",n); ! 421: #endif ! 422: errno = 0; ! 423: if ((n = recv(s, (char *)cp, l, 0)) > 0) { ! 424: cp += n; ! 425: l -= n; ! 426: } else { ! 427: #ifdef DEBUG ! 428: if (debug > 10) ! 429: (void)fprintf(ddt, ! 430: "bad recv->%d, errno= %d, read_interrupt=%d\n", n, errno, read_interrupted); ! 431: #endif ! 432: if (n == -1 && errno == EINTR ! 433: && !read_interrupted) ! 434: continue; ! 435: error++; ! 436: break; ! 437: } ! 438: } ! 439: ! 440: (void) setitimer(ITIMER_REAL, &zeroival, ! 441: (struct itimerval *)NULL); ! 442: if (error) { ! 443: (void) close(s); ! 444: continue; ! 445: } ! 446: if ((len = htons(*(u_short *)buf)) == 0) { ! 447: (void) close(s); ! 448: continue; ! 449: } ! 450: if (len > bufsize) { ! 451: if ((buf = (u_char *)realloc(buf, len)) == NULL) { ! 452: syslog(LOG_ERR, ! 453: "malloc(%u) failed for SOA from server %s, zone %s\n", ! 454: len, inet_ntoa(sin.sin_addr), zp->z_origin); ! 455: (void) close(s); ! 456: continue; ! 457: } ! 458: bufsize = len; ! 459: } ! 460: l = len; ! 461: cp = buf; ! 462: while (l > 0) { ! 463: (void) setitimer(ITIMER_REAL, &ival, ! 464: (struct itimerval *)NULL); ! 465: errno = 0; ! 466: if ((n = recv(s, (char *)cp, l, 0)) > 0) { ! 467: cp += n; ! 468: l -= n; ! 469: } else { ! 470: if (errno == EINTR && !read_interrupted) ! 471: continue; ! 472: error++; ! 473: #ifdef DEBUG ! 474: if (debug > 10) ! 475: (void)fprintf(ddt, ! 476: "recv failed: n= %d, errno = %d\n", ! 477: n, errno); ! 478: #endif ! 479: break; ! 480: } ! 481: } ! 482: (void) setitimer(ITIMER_REAL, &zeroival, ! 483: (struct itimerval *)NULL); ! 484: if (error) { ! 485: (void) close(s); ! 486: continue; ! 487: } ! 488: #ifdef DEBUG ! 489: if (debug >= 3) { ! 490: (void)fprintf(ddt,"len = %d\n", len); ! 491: fp_query(buf, ddt); ! 492: } ! 493: #endif DEBUG ! 494: hp = (HEADER *) buf; ! 495: ancount = ntohs(hp->ancount); ! 496: aucount = ntohs(hp->nscount); ! 497: ! 498: /* ! 499: * close socket if: ! 500: * 1) rcode != NOERROR ! 501: * 2) not an authority response ! 502: * 3) both the number of answers and authority count < 1) ! 503: */ ! 504: if (hp->rcode != NOERROR || !(hp->aa) || ! 505: (ancount < 1 && aucount < 1)) { ! 506: if (!quiet) ! 507: syslog(LOG_ERR, ! 508: "%s from %s, zone %s: rcode %d, aa %d, ancount %d, aucount %d\n", ! 509: "bad response to SOA query", ! 510: inet_ntoa(sin.sin_addr), zp->z_origin, ! 511: hp->rcode, hp->aa, ancount, aucount); ! 512: #ifdef DEBUG ! 513: if (debug) ! 514: fprintf(ddt, ! 515: "%s from %s, zone %s: rcode %d, aa %d, ancount %d, aucount %d\n", ! 516: "bad response to SOA query", ! 517: inet_ntoa(sin.sin_addr), zp->z_origin, ! 518: hp->rcode, hp->aa, ancount, aucount); ! 519: #endif DEBUG ! 520: (void) close(s); ! 521: error++; ! 522: continue; ! 523: } ! 524: zp_start = *zp; ! 525: if (len < sizeof(HEADER) + QFIXEDSZ) { ! 526: badsoa: ! 527: if (!quiet) ! 528: syslog(LOG_ERR, ! 529: "malformed SOA from %s, zone %s: too short\n", ! 530: inet_ntoa(sin.sin_addr), zp->z_origin); ! 531: #ifdef DEBUG ! 532: if (debug) ! 533: fprintf(ddt, ! 534: "malformed SOA from %s: too short\n", ! 535: inet_ntoa(sin.sin_addr)); ! 536: #endif DEBUG ! 537: (void) close(s); ! 538: error++; ! 539: continue; ! 540: } ! 541: tmp = buf + sizeof(HEADER); ! 542: eom = buf + len; ! 543: if ((n = dn_skipname(tmp, eom)) == -1) ! 544: goto badsoa; ! 545: tmp += n + QFIXEDSZ; ! 546: if ((n = dn_skipname(tmp, eom)) == -1) ! 547: goto badsoa; ! 548: tmp += n; ! 549: if (soa_zinfo(&zp_start, tmp, eom) == -1) ! 550: goto badsoa; ! 551: if (zp_start.z_serial > serial_no || serial_no == 0) { ! 552: #ifdef DEBUG ! 553: if (debug) ! 554: (void)fprintf(ddt, "need update, serial %d\n", ! 555: zp_start.z_serial); ! 556: #endif DEBUG ! 557: hp = (HEADER *) buf; ! 558: soacnt = 0; ! 559: for (;;) { ! 560: if (soacnt == 0) { ! 561: if ((n = res_mkquery(QUERY, zp->z_origin, C_IN, ! 562: T_AXFR, (char *)NULL, 0, NULL, ! 563: buf, bufsize)) < 0) { ! 564: if (!quiet) ! 565: syslog(LOG_ERR, ! 566: "zone %s: res_mkquery T_AXFR failed", ! 567: zp->z_origin); ! 568: (void) close(s); ! 569: (void) sigvec(SIGALRM, &osv, ! 570: (struct sigvec *)0); ! 571: return XFER_FAIL; ! 572: } ! 573: /* ! 574: * Send length & message for zone transfer ! 575: */ ! 576: if (writemsg(s, buf, n) < 0) { ! 577: (void) close(s); ! 578: error++; ! 579: #ifdef DEBUG ! 580: if (debug >= 2) ! 581: (void)fprintf(ddt,"writemsg failed\n"); ! 582: #endif ! 583: break; ! 584: } ! 585: } ! 586: /* ! 587: * Receive length & response ! 588: */ ! 589: cp = buf; ! 590: l = sizeof(u_short); ! 591: /* allow extra time for the fork on first read */ ! 592: if (soacnt == 0) ! 593: ival.it_value.tv_sec = 300; ! 594: while (l > 0) { ! 595: (void) setitimer(ITIMER_REAL, &ival, ! 596: (struct itimerval *)NULL); ! 597: errno = 0; ! 598: if ((n = recv(s, (char *)cp, l, 0)) > 0) { ! 599: cp += n; ! 600: l -= n; ! 601: } else { ! 602: if (errno == EINTR && !read_interrupted) ! 603: continue; ! 604: error++; ! 605: #ifdef DEBUG ! 606: if (debug >= 2) ! 607: (void)fprintf(ddt, ! 608: "recv failed: n= %d, errno = %d\n", ! 609: n, errno); ! 610: #endif ! 611: break; ! 612: } ! 613: } ! 614: if (soacnt == 0) ! 615: ival.it_value.tv_sec = 120; ! 616: (void) setitimer(ITIMER_REAL, &zeroival, ! 617: (struct itimerval *)NULL); ! 618: if (error) ! 619: break; ! 620: if ((len = htons(*(u_short *)buf)) == 0) ! 621: break; ! 622: l = len; ! 623: cp = buf; ! 624: eom = buf + len; ! 625: while (l > 0) { ! 626: (void) setitimer(ITIMER_REAL, &ival, ! 627: (struct itimerval *)NULL); ! 628: errno = 0; ! 629: if ((n = recv(s, (char *)cp, l, 0)) > 0) { ! 630: cp += n; ! 631: l -= n; ! 632: } else { ! 633: if (errno == EINTR && !read_interrupted) ! 634: continue; ! 635: error++; ! 636: #ifdef DEBUG ! 637: if (debug >= 2) ! 638: (void)fprintf(ddt,"recv failed\n"); ! 639: #endif ! 640: break; ! 641: } ! 642: } ! 643: (void) setitimer(ITIMER_REAL, &zeroival, ! 644: (struct itimerval *)NULL); ! 645: if (error) ! 646: break; ! 647: #ifdef DEBUG ! 648: if (debug >= 3) { ! 649: (void)fprintf(ddt,"len = %d\n", len); ! 650: fp_query(buf, ddt); ! 651: } ! 652: if (fp) fp_query(buf,fp); ! 653: #endif ! 654: if (len < sizeof(HEADER)) { ! 655: badrec: ! 656: error++; ! 657: if (!quiet) ! 658: syslog(LOG_ERR, ! 659: "record too short from %s, zone %s\n", ! 660: inet_ntoa(sin.sin_addr), ! 661: zp->z_source); ! 662: #ifdef DEBUG ! 663: if (debug) ! 664: fprintf(ddt, ! 665: "record too short from %s\n", ! 666: inet_ntoa(sin.sin_addr)); ! 667: #endif DEBUG ! 668: break; ! 669: } ! 670: cp = buf + sizeof(HEADER); ! 671: if (hp->qdcount) { ! 672: if ((n = dn_skipname(cp, eom)) == -1 || ! 673: n + QFIXEDSZ >= eom - cp) ! 674: goto badrec; ! 675: cp += n + QFIXEDSZ; ! 676: } ! 677: nmp = cp; ! 678: if ((n = dn_skipname(cp, eom)) == -1) ! 679: goto badrec; ! 680: tmp = cp + n; ! 681: ! 682: n = print_output(buf, bufsize, cp); ! 683: if (cp + n != eom) { ! 684: #ifdef DEBUG ! 685: if (debug) ! 686: (void)fprintf(ddt, ! 687: "getzone: print_update failed (%d, %d)\n", ! 688: cp - buf, n); ! 689: #endif ! 690: error++; ! 691: break; ! 692: } ! 693: GETSHORT(n, tmp); ! 694: if (n == T_SOA) { ! 695: if (soacnt == 0) { ! 696: soacnt++; ! 697: if (dn_expand(buf, buf + 512, nmp, ! 698: name, sizeof(name)) == -1) ! 699: goto badsoa; ! 700: if (eom - tmp <= 2 * sizeof(u_short) + ! 701: sizeof(u_long)) ! 702: goto badsoa; ! 703: tmp += 2 * sizeof(u_short) ! 704: + sizeof(u_long); ! 705: if ((n = dn_skipname(tmp, eom)) == -1) ! 706: goto badsoa; ! 707: tmp += n; ! 708: if ((n = dn_skipname(tmp, eom)) == -1) ! 709: goto badsoa; ! 710: tmp += n; ! 711: if (eom - tmp <= sizeof(u_long)) ! 712: goto badsoa; ! 713: GETLONG(serial, tmp); ! 714: #ifdef DEBUG ! 715: if (debug > 2) ! 716: (void)fprintf(ddt, ! 717: "first SOA for %s, serial %d\n", ! 718: name, serial); ! 719: #endif DEBUG ! 720: continue; ! 721: } ! 722: if (dn_expand(buf, buf + 512, nmp, name2, ! 723: sizeof(name2)) == -1) ! 724: goto badsoa; ! 725: if (strcasecmp((char *)name, (char *)name2) != 0) { ! 726: #ifdef DEBUG ! 727: if (debug > 1) ! 728: (void)fprintf(ddt, ! 729: "extraneous SOA for %s\n", ! 730: name2); ! 731: #endif DEBUG ! 732: continue; ! 733: } ! 734: tmp -= sizeof(u_short); ! 735: if (soa_zinfo(&zp_finish, tmp, eom) == -1) ! 736: goto badsoa; ! 737: #ifdef DEBUG ! 738: if (debug > 1) ! 739: (void)fprintf(ddt, ! 740: "SOA, serial %d\n", zp_finish.z_serial); ! 741: #endif DEBUG ! 742: if (serial != zp_finish.z_serial) { ! 743: soacnt = 0; ! 744: got_soa = 0; ! 745: minimum_ttl = 0; ! 746: strcpy(prev_origin, zp->z_origin); ! 747: prev_dname[0] = 0; ! 748: #ifdef DEBUG ! 749: if (debug) ! 750: (void)fprintf(ddt, ! 751: "serial changed, restart\n"); ! 752: #endif DEBUG ! 753: /* ! 754: * Flush buffer, truncate file ! 755: * and seek to beginning to restart. ! 756: */ ! 757: fflush(dbfp); ! 758: if (ftruncate(fileno(dbfp), 0) != 0) { ! 759: if (!quiet) ! 760: syslog(LOG_ERR, ! 761: "ftruncate %s: %m\n", ! 762: tmpname); ! 763: return(XFER_FAIL); ! 764: } ! 765: fseek(dbfp, 0L, 0); ! 766: } else ! 767: break; ! 768: } ! 769: } ! 770: (void) close(s); ! 771: if (error == 0) { ! 772: (void) sigvec(SIGALRM, &osv, (struct sigvec *)0); ! 773: return XFER_SUCCESS; ! 774: } ! 775: #ifdef DEBUG ! 776: if (debug >= 2) ! 777: (void)fprintf(ddt,"error receiving zone transfer\n"); ! 778: #endif ! 779: } else { ! 780: (void) close(s); ! 781: #ifdef DEBUG ! 782: if (debug) ! 783: (void)fprintf(ddt, ! 784: "zone up-to-date, serial %d\n", zp_start.z_serial); ! 785: #endif DEBUG ! 786: return XFER_UPTODATE; ! 787: } ! 788: } ! 789: (void) sigvec(SIGALRM, &osv, (struct sigvec *)0); ! 790: if (error) ! 791: return XFER_TIMEOUT; ! 792: return XFER_FAIL; ! 793: } ! 794: ! 795: /* ! 796: * Set flag saying to read was interrupted ! 797: * used for a read timer ! 798: */ ! 799: VOID ! 800: read_alarm() ! 801: { ! 802: extern int read_interrupted; ! 803: read_interrupted = 1; ! 804: } ! 805: ! 806: writemsg(rfd, msg, msglen) ! 807: int rfd; ! 808: u_char *msg; ! 809: int msglen; ! 810: { ! 811: struct iovec iov[2]; ! 812: u_short len = htons((u_short)msglen); ! 813: ! 814: iov[0].iov_base = (caddr_t)&len; ! 815: iov[0].iov_len = sizeof(len); ! 816: iov[1].iov_base = (caddr_t)msg; ! 817: iov[1].iov_len = msglen; ! 818: if (writev(rfd, iov, 2) != sizeof(len) + msglen) { ! 819: #ifdef DEBUG ! 820: if (debug) ! 821: (void)fprintf(ddt,"write failed %d\n", errno); ! 822: #endif ! 823: return (-1); ! 824: } ! 825: return (0); ! 826: } ! 827: ! 828: ! 829: soa_zinfo(zp, cp, eom) ! 830: register struct zoneinfo *zp; ! 831: register u_char *cp; ! 832: u_char *eom; ! 833: { ! 834: register int n; ! 835: ! 836: if (eom - cp < 3 * sizeof(u_short) + sizeof(u_long)) ! 837: return (-1); ! 838: cp += 3 * sizeof(u_short) + sizeof(u_long); ! 839: if ((n = dn_skipname(cp, eom)) == -1) ! 840: return (-1); ! 841: cp += n; ! 842: if ((n = dn_skipname(cp, eom)) == -1) ! 843: return (-1); ! 844: cp += n; ! 845: if (eom - cp < 5 * sizeof(u_long)) ! 846: return (-1); ! 847: GETLONG(zp->z_serial, cp); ! 848: GETLONG(zp->z_refresh, cp); ! 849: gettime(&tt); ! 850: zp->z_time = tt.tv_sec + zp->z_refresh; ! 851: GETLONG(zp->z_retry, cp); ! 852: GETLONG(zp->z_expire, cp); ! 853: GETLONG(zp->z_minimum, cp); ! 854: return (0); ! 855: } ! 856: ! 857: gettime(ttp) ! 858: struct timeval *ttp; ! 859: { ! 860: if (gettimeofday(ttp, (struct timezone *)0) < 0) ! 861: syslog(LOG_ERR, "gettimeofday failed: %m"); ! 862: } ! 863: ! 864: /* ! 865: * Parse the message, determine if it should be printed, and if so, print it ! 866: * in .db file form. ! 867: * Does minimal error checking on the message content. ! 868: */ ! 869: print_output(msg, msglen, rrp) ! 870: u_char *msg; ! 871: int msglen; ! 872: u_char *rrp; ! 873: { ! 874: register u_char *cp; ! 875: register HEADER *hp = (HEADER *) msg; ! 876: u_long addr, ttl; ! 877: int i, j, tab, result, class, type, dlen, n1; ! 878: long n; ! 879: u_char *cp1, data[BUFSIZ]; ! 880: u_char *temp_ptr; /* used to get ttl for RR */ ! 881: char *cdata, *origin, *proto, dname[MAXDNAME]; ! 882: extern char *inet_ntoa(), *protocolname(), *servicename(); ! 883: ! 884: cp = rrp; ! 885: if ((n = dn_expand(msg, msg + msglen, cp, (u_char *) dname, ! 886: sizeof(dname))) < 0) { ! 887: hp->rcode = FORMERR; ! 888: return (-1); ! 889: } ! 890: cp += n; ! 891: GETSHORT(type, cp); ! 892: GETSHORT(class, cp); ! 893: GETLONG(ttl, cp); ! 894: GETSHORT(dlen, cp); ! 895: ! 896: origin = index(dname, '.'); ! 897: if (origin == NULL) ! 898: origin = ""; ! 899: else ! 900: origin++; /* move past the '.' */ ! 901: #ifdef DEBUG ! 902: if (debug > 2) ! 903: (void) fprintf(ddt, "print_output: dname %s type %d class %d ttl %d\n", ! 904: dname, type, class, ttl); ! 905: #endif ! 906: /* ! 907: * Convert the resource record data into the internal database format. ! 908: */ ! 909: switch (type) { ! 910: case T_A: ! 911: case T_WKS: ! 912: case T_HINFO: ! 913: case T_UINFO: ! 914: case T_TXT: ! 915: case T_UID: ! 916: case T_GID: ! 917: cp1 = cp; ! 918: n = dlen; ! 919: cp += n; ! 920: break; ! 921: ! 922: case T_CNAME: ! 923: case T_MB: ! 924: case T_MG: ! 925: case T_MR: ! 926: case T_NS: ! 927: case T_PTR: ! 928: if ((n = dn_expand(msg, msg + msglen, cp, data, ! 929: sizeof(data))) < 0) { ! 930: hp->rcode = FORMERR; ! 931: return (-1); ! 932: } ! 933: cp += n; ! 934: cp1 = data; ! 935: n = strlen((char *) data) + 1; ! 936: break; ! 937: ! 938: case T_MINFO: ! 939: case T_SOA: ! 940: if ((n = dn_expand(msg, msg + msglen, cp, data, ! 941: sizeof(data))) < 0) { ! 942: hp->rcode = FORMERR; ! 943: return (-1); ! 944: } ! 945: cp += n; ! 946: cp1 = data + (n = strlen((char *) data) + 1); ! 947: n1 = sizeof(data) - n; ! 948: if (type == T_SOA) ! 949: n1 -= 5 * sizeof(u_long); ! 950: if ((n = dn_expand(msg, msg + msglen, cp, cp1, n1)) < 0) { ! 951: hp->rcode = FORMERR; ! 952: return (-1); ! 953: } ! 954: cp += n; ! 955: cp1 += strlen((char *) cp1) + 1; ! 956: if (type == T_SOA) { ! 957: temp_ptr = cp + 4 * sizeof(u_long); ! 958: GETLONG(minimum_ttl, temp_ptr); ! 959: bcopy((char *) cp, (char *) cp1, ! 960: n = 5 * sizeof(u_long)); ! 961: cp += n; ! 962: cp1 += n; ! 963: } ! 964: n = cp1 - data; ! 965: cp1 = data; ! 966: break; ! 967: ! 968: case T_MX: ! 969: /* grab preference */ ! 970: bcopy((char *) cp, (char *) data, sizeof(u_short)); ! 971: cp1 = data + sizeof(u_short); ! 972: cp += sizeof(u_short); ! 973: ! 974: /* get name */ ! 975: if ((n = dn_expand(msg, msg + msglen, cp, cp1, ! 976: sizeof(data) - sizeof(u_short))) < 0) ! 977: return (-1); ! 978: cp += n; ! 979: ! 980: /* compute end of data */ ! 981: cp1 += strlen((char *) cp1) + 1; ! 982: /* compute size of data */ ! 983: n = cp1 - data; ! 984: cp1 = data; ! 985: break; ! 986: ! 987: default: ! 988: #ifdef DEBUG ! 989: if (debug >= 3) ! 990: (void) fprintf(ddt, "unknown type %d\n", type); ! 991: #endif ! 992: return ((cp - rrp) + dlen); ! 993: } ! 994: if (n > MAXDATA) { ! 995: #ifdef DEBUG ! 996: if (debug) ! 997: (void) fprintf(ddt, ! 998: "update type %d: %d bytes is too much data\n", ! 999: type, n); ! 1000: #endif ! 1001: hp->rcode = NOCHANGE; /* XXX - FORMERR ??? */ ! 1002: return (-1); ! 1003: } ! 1004: cdata = (char *) cp1; ! 1005: result = cp - rrp; ! 1006: ! 1007: /* ! 1008: * Only print one SOA per db file ! 1009: */ ! 1010: if (type == T_SOA) { ! 1011: if (got_soa) ! 1012: return result; ! 1013: else ! 1014: got_soa++; ! 1015: } ! 1016: /* ! 1017: * If the origin has changed, print the new origin ! 1018: */ ! 1019: if (strcasecmp(prev_origin, origin)) { ! 1020: (void) strcpy(prev_origin, origin); ! 1021: (void) fprintf(dbfp, "$ORIGIN %s.\n", origin); ! 1022: } ! 1023: tab = 0; ! 1024: ! 1025: if (strcasecmp(prev_dname, dname)) { ! 1026: /* ! 1027: * set the prev_dname to be the current dname, then cut off all ! 1028: * characters of dname after (and including) the first '.' ! 1029: */ ! 1030: char *cutp = index(dname, '.'); ! 1031: ! 1032: (void) strcpy(prev_dname, dname); ! 1033: if (cutp) ! 1034: *cutp = NULL; ! 1035: ! 1036: if (dname[0] == 0) { ! 1037: if (origin[0] == 0) ! 1038: (void) fprintf(dbfp, ".\t"); ! 1039: else ! 1040: (void) fprintf(dbfp, ".%s.\t", origin); /* ??? */ ! 1041: } else ! 1042: (void) fprintf(dbfp, "%s\t", dname); ! 1043: if (strlen(dname) < 8) ! 1044: tab = 1; ! 1045: } else { ! 1046: (void) putc('\t', dbfp); ! 1047: tab = 1; ! 1048: } ! 1049: ! 1050: if (ttl != 0 && ttl != minimum_ttl) ! 1051: (void) fprintf(dbfp, "%d\t", (int) ttl); ! 1052: else if (tab) ! 1053: (void) putc('\t', dbfp); ! 1054: ! 1055: (void) fprintf(dbfp, "%s\t%s\t", p_class(class), p_type(type)); ! 1056: cp = (u_char *) cdata; ! 1057: ! 1058: /* ! 1059: * Print type specific data ! 1060: */ ! 1061: switch (type) { ! 1062: ! 1063: case T_A: ! 1064: switch (class) { ! 1065: case C_IN: ! 1066: case C_HS: ! 1067: GETLONG(n, cp); ! 1068: n = htonl(n); ! 1069: (void) fprintf(dbfp, "%s", ! 1070: inet_ntoa(*(struct in_addr *) & n)); ! 1071: break; ! 1072: } ! 1073: (void) fprintf(dbfp, "\n"); ! 1074: break; ! 1075: ! 1076: case T_CNAME: ! 1077: case T_MB: ! 1078: case T_MG: ! 1079: case T_MR: ! 1080: case T_PTR: ! 1081: if (cp[0] == '\0') ! 1082: (void) fprintf(dbfp, ".\n"); ! 1083: else ! 1084: (void) fprintf(dbfp, "%s.\n", cp); ! 1085: break; ! 1086: ! 1087: case T_NS: ! 1088: cp = (u_char *) cdata; ! 1089: if (cp[0] == '\0') ! 1090: (void) fprintf(dbfp, ".\t"); ! 1091: else ! 1092: (void) fprintf(dbfp, "%s.", cp); ! 1093: (void) fprintf(dbfp, "\n"); ! 1094: break; ! 1095: ! 1096: case T_HINFO: ! 1097: if (n = *cp++) { ! 1098: (void) fprintf(dbfp, "\"%.*s\"", (int) n, cp); ! 1099: cp += n; ! 1100: } else ! 1101: (void) fprintf(dbfp, "\"\""); ! 1102: if (n = *cp++) ! 1103: (void) fprintf(dbfp, " \"%.*s\"", (int) n, cp); ! 1104: else ! 1105: (void) fprintf(dbfp, "\"\""); ! 1106: (void) putc('\n', dbfp); ! 1107: break; ! 1108: ! 1109: case T_SOA: ! 1110: (void) fprintf(dbfp, "%s.", cp); ! 1111: cp += strlen((char *) cp) + 1; ! 1112: (void) fprintf(dbfp, " %s. (\n", cp); ! 1113: cp += strlen((char *) cp) + 1; ! 1114: GETLONG(n, cp); ! 1115: (void) fprintf(dbfp, "\t\t%lu", n); ! 1116: GETLONG(n, cp); ! 1117: (void) fprintf(dbfp, " %lu", n); ! 1118: GETLONG(n, cp); ! 1119: (void) fprintf(dbfp, " %lu", n); ! 1120: GETLONG(n, cp); ! 1121: (void) fprintf(dbfp, " %lu", n); ! 1122: GETLONG(n, cp); ! 1123: (void) fprintf(dbfp, " %lu )\n", n); ! 1124: break; ! 1125: ! 1126: case T_MX: ! 1127: GETSHORT(n, cp); ! 1128: (void) fprintf(dbfp, "%lu", n); ! 1129: (void) fprintf(dbfp, " %s.\n", cp); ! 1130: break; ! 1131: ! 1132: case T_TXT: ! 1133: cp1 = cp + n; ! 1134: (void) putc('"', dbfp); ! 1135: while (cp < cp1) { ! 1136: if (i = *cp++) { ! 1137: for (j = i ; j > 0 && cp < cp1 ; j--) ! 1138: if (*cp == '\n') { ! 1139: (void) putc('\\', dbfp); ! 1140: (void) putc(*cp++, dbfp); ! 1141: } else ! 1142: (void) putc(*cp++, dbfp); ! 1143: } ! 1144: } ! 1145: (void) fputs("\"\n", dbfp); ! 1146: break; ! 1147: ! 1148: case T_UINFO: ! 1149: (void) fprintf(dbfp, "\"%s\"\n", cp); ! 1150: break; ! 1151: ! 1152: case T_UID: ! 1153: case T_GID: ! 1154: if (n == sizeof(u_long)) { ! 1155: GETLONG(n, cp); ! 1156: (void) fprintf(dbfp, "%lu\n", n); ! 1157: } ! 1158: break; ! 1159: ! 1160: case T_WKS: ! 1161: GETLONG(addr, cp); ! 1162: addr = htonl(addr); ! 1163: (void) fprintf(dbfp, "%s ", ! 1164: inet_ntoa(*(struct in_addr *) & addr)); ! 1165: proto = protocolname(*cp); ! 1166: cp += sizeof(char); ! 1167: (void) fprintf(dbfp, "%s ", proto); ! 1168: i = 0; ! 1169: while (cp < (u_char *) cdata + n) { ! 1170: j = *cp++; ! 1171: do { ! 1172: if (j & 0200) ! 1173: (void) fprintf(dbfp, " %s", ! 1174: servicename(i, proto)); ! 1175: j <<= 1; ! 1176: } while (++i & 07); ! 1177: } ! 1178: (void) fprintf(dbfp, "\n"); ! 1179: break; ! 1180: ! 1181: case T_MINFO: ! 1182: (void) fprintf(dbfp, "%s.", cp); ! 1183: cp += strlen((char *) cp) + 1; ! 1184: (void) fprintf(dbfp, " %s.\n", cp); ! 1185: break; ! 1186: ! 1187: default: ! 1188: (void) fprintf(dbfp, "???\n"); ! 1189: } ! 1190: if (ferror(dbfp)) { ! 1191: syslog(LOG_ERR, "%s: %m", tmpname); ! 1192: exit(XFER_FAIL); ! 1193: } ! 1194: return result; ! 1195: } ! 1196: ! 1197: /* ! 1198: * Make a copy of a string and return a pointer to it. ! 1199: */ ! 1200: char * ! 1201: savestr(str) ! 1202: char *str; ! 1203: { ! 1204: char *cp; ! 1205: ! 1206: cp = (char *)malloc((unsigned)strlen(str) + 1); ! 1207: if (cp == NULL) { ! 1208: syslog(LOG_ERR, "savestr: %m"); ! 1209: exit(XFER_FAIL); ! 1210: } ! 1211: (void) strcpy(cp, str); ! 1212: return (cp); ! 1213: }
This archive runs on limited infrastructure. Preserving old code on modern bandwidth. Automated agents are requested to crawl responsibly.