![[BACK]](/cvsweb/icons/back.gif){kind=icon}
Return to ns_maint.c CVS log ![[TXT]](/cvsweb/icons/text.gif){kind=icon}
![[DIR]](/cvsweb/icons/dir.gif){kind=icon}
Up to [CSRG BSD Unix] / 43BSD / etc / named|
Return to ns_maint.c CVS log | Up to [CSRG BSD Unix] / 43BSD / etc / named |
1.1 ! root 1: #ifndef lint ! 2: static char sccsid[] = "@(#)ns_maint.c 4.3 (Berkeley) 6/4/86"; ! 3: #endif ! 4: ! 5: /* ! 6: * Copyright (c) 1986 Regents of the University of California ! 7: * All Rights Reserved ! 8: */ ! 9: ! 10: #include <sys/types.h> ! 11: #include <sys/socket.h> ! 12: #include <sys/time.h> ! 13: #include <netinet/in.h> ! 14: #include <stdio.h> ! 15: #include <syslog.h> ! 16: #include <signal.h> ! 17: #include <errno.h> ! 18: #include <arpa/nameser.h> ! 19: #include "ns.h" ! 20: #include "db.h" ! 21: ! 22: /* ! 23: * Invoked at regular intervals by signal interrupt; refresh all secondary ! 24: * zones from primary name server and remove old cache entries. ! 25: */ ! 26: ns_maint() ! 27: { ! 28: register struct zoneinfo *zp; ! 29: struct itimerval ival; ! 30: time_t now, next_refresh; ! 31: int first; ! 32: extern errno; ! 33: #ifdef DEBUG ! 34: if (debug) ! 35: fprintf(ddt,"ns_maint()\n"); ! 36: #endif ! 37: ! 38: ! 39: first = 1; ! 40: for (zp = zones; zp < &zones[nzones]; zp++) { ! 41: if (zp->z_type != Z_SECONDARY) ! 42: continue; ! 43: if (gettimeofday(&tt, (struct timezone *)0) < 0) ! 44: syslog(LOG_ERR, "gettimeofday failed: %m"); ! 45: now = tt.tv_sec; ! 46: #ifdef DEBUG ! 47: if (debug >=2) { ! 48: if (zp->z_origin[0] == '\0') ! 49: fprintf(ddt,"origin ='.'"); ! 50: else ! 51: fprintf(ddt,"origin ='%s'", zp->z_origin); ! 52: fprintf(ddt,", source = %s\n", zp->z_source); ! 53: fprintf(ddt,"z_refresh = %ld", zp->z_refresh); ! 54: fprintf(ddt,", retry = %ld", zp->z_retry); ! 55: fprintf(ddt,", expire = %ld", zp->z_expire); ! 56: fprintf(ddt,", minimum = %ld", zp->z_minimum); ! 57: fprintf(ddt,", serial = %ld\n", zp->z_serial); ! 58: fprintf(ddt,"z_time = %d", zp->z_time); ! 59: fprintf(ddt,", now time : %d sec", now); ! 60: fprintf(ddt,", time left: %d sec\n", zp->z_time - now); ! 61: } ! 62: #endif ! 63: if (now >= zp->z_time) { ! 64: zoneref(zp); ! 65: zp->z_time = tt.tv_sec + zp->z_refresh; ! 66: } ! 67: /* ! 68: * Find when the next refresh needs to be and set ! 69: * interupt time accordingly. ! 70: * Why have needless intruptions. ! 71: * I just hate it when the cleaning crew come early. ! 72: */ ! 73: if (first) { ! 74: next_refresh = zp->z_time; ! 75: first = 0; ! 76: } ! 77: else if (next_refresh > zp->z_time) ! 78: next_refresh = zp->z_time; ! 79: } ! 80: /* ! 81: * If first is still true, no secondary zones were found ! 82: * therefore refreshes aren't needed and interupts are turned off ! 83: * This needs to be changed when we have refreshes for co-masters ! 84: */ ! 85: if (!first) { ! 86: bzero((char *)&ival, sizeof (ival)); ! 87: ival.it_value.tv_sec = next_refresh - now; ! 88: if (ival.it_value.tv_sec < 0) ! 89: ival.it_value.tv_sec = 60; ! 90: (void) setitimer(ITIMER_REAL, &ival, (struct itimerval *)NULL); ! 91: #ifdef DEBUG ! 92: if (debug) ! 93: fprintf(ddt,"exit ns_maint() Next interupt in %d sec\n", ! 94: ival.it_value.tv_sec); ! 95: #endif ! 96: } ! 97: } ! 98: ! 99: zoneref(zp) ! 100: struct zoneinfo *zp; ! 101: { ! 102: register struct databuf *dp; ! 103: HEADER *hp; ! 104: u_short len; ! 105: u_long serial; ! 106: int s, n, l; ! 107: int cnt, soacnt, error = 0; ! 108: int zone = zp - zones; ! 109: char *cp; ! 110: char *tmp; ! 111: char *fname; ! 112: char buf[PACKETSZ]; ! 113: struct sockaddr_in sin; ! 114: struct zoneinfo zp_start, zp_finish; ! 115: struct databuf *pdp, *tdp; ! 116: struct namebuf *np; ! 117: struct hashbuf *htp; ! 118: struct itimerval ival; ! 119: struct itimerval zeroival; ! 120: extern struct sockaddr_in nsaddr; ! 121: extern int errno; ! 122: extern int read_interrupted; ! 123: extern int read_alarm(); ! 124: struct sigvec sv, osv; ! 125: ! 126: #ifdef DEBUG ! 127: if (debug) ! 128: fprintf(ddt,"zoneref()\n"); ! 129: #endif ! 130: bzero((char *)&zeroival, sizeof(zeroival)); ! 131: ival = zeroival; ! 132: ival.it_value.tv_sec = 30; ! 133: sv.sv_handler = read_alarm; ! 134: sv.sv_onstack = 0; ! 135: sv.sv_mask = ~0; ! 136: (void) sigvec(SIGALRM, &sv, &osv); ! 137: ! 138: for( cnt = 0; cnt < zp->z_addrcnt; cnt++) { ! 139: error = 0; ! 140: bzero((char *)&sin, sizeof(sin)); ! 141: sin.sin_family = AF_INET; ! 142: sin.sin_port = nsaddr.sin_port; ! 143: sin.sin_addr = zp->z_addr[cnt]; ! 144: if ((s = socket(AF_INET, SOCK_STREAM, 0)) < 0) { ! 145: syslog(LOG_ERR, "zoneref: socket: %m"); ! 146: exit(1); ! 147: } ! 148: #ifdef DEBUG ! 149: if (debug >= 2) { ! 150: fprintf(ddt,"connecting to server #%d %s, %d\n", ! 151: cnt+1, inet_ntoa(sin.sin_addr), ntohs(sin.sin_port)); ! 152: } ! 153: #endif ! 154: if (connect(s, &sin, sizeof(sin)) < 0) { ! 155: (void) close(s); ! 156: error++; ! 157: #ifdef DEBUG ! 158: if (debug >= 2) ! 159: fprintf(ddt,"connect failed\n"); ! 160: #endif ! 161: continue; ! 162: } ! 163: if ((n = res_mkquery(QUERY, zp->z_origin, C_IN, ! 164: T_SOA, (char *)NULL, 0, NULL, buf, sizeof(buf))) < 0) { ! 165: syslog(LOG_ERR, "zoneref: res_mkquery failed"); ! 166: (void) close(s); ! 167: (void) sigvec(SIGALRM, &osv, (struct sigvec *)0); ! 168: return; ! 169: } ! 170: /* ! 171: * Send length & message for zone transfer ! 172: */ ! 173: if (writemsg(s, buf, n) < 0) { ! 174: (void) close(s); ! 175: error++; ! 176: #ifdef DEBUG ! 177: if (debug >= 2) ! 178: fprintf(ddt,"writemsg failed\n"); ! 179: #endif ! 180: continue; ! 181: } ! 182: /* ! 183: * Get out your butterfly net and catch the SOA ! 184: */ ! 185: cp = buf; ! 186: l = sizeof(u_short); ! 187: read_interrupted = 0; ! 188: while (l > 0) { ! 189: (void) setitimer(ITIMER_REAL, &ival, ! 190: (struct itimerval *)NULL); ! 191: if ((n = recv(s, cp, l, 0)) > 0) { ! 192: cp += n; ! 193: l -= n; ! 194: } else { ! 195: if (errno == EINTR && !read_interrupted) ! 196: continue; ! 197: error++; ! 198: break; ! 199: } ! 200: } ! 201: (void) setitimer(ITIMER_REAL, &zeroival, ! 202: (struct itimerval *)NULL); ! 203: if (error) { ! 204: (void) close(s); ! 205: continue; ! 206: } ! 207: if ((len = htons(*(u_short *)buf)) == 0) { ! 208: (void) close(s); ! 209: continue; ! 210: } ! 211: l = len; ! 212: cp = buf; ! 213: while (l > 0) { ! 214: (void) setitimer(ITIMER_REAL, &ival, ! 215: (struct itimerval *)NULL); ! 216: if ((n = recv(s, cp, l, 0)) > 0) { ! 217: cp += n; ! 218: l -= n; ! 219: } else { ! 220: if (errno == EINTR && !read_interrupted) ! 221: continue; ! 222: error++; ! 223: break; ! 224: } ! 225: } ! 226: (void) setitimer(ITIMER_REAL, &zeroival, ! 227: (struct itimerval *)NULL); ! 228: if (error) { ! 229: (void) close(s); ! 230: continue; ! 231: } ! 232: #ifdef DEBUG ! 233: if (debug >= 3) { ! 234: fprintf(ddt,"len = %d\n", len); ! 235: fp_query(buf, ddt); ! 236: } ! 237: #endif DEBUG ! 238: zp_start = *zp; ! 239: tmp = buf + sizeof(HEADER); ! 240: tmp += dn_skip(tmp) + QFIXEDSZ; ! 241: tmp += dn_skip(tmp); ! 242: soa_zinfo(&zp_start, tmp); ! 243: if (zp->z_serial >= zp_start.z_serial) { ! 244: (void) close(s); ! 245: (void) sigvec(SIGALRM, &osv, (struct sigvec *)0); ! 246: return; ! 247: } ! 248: zp_finish = *zp; ! 249: hp = (HEADER *) buf; ! 250: soacnt = 0; ! 251: for(;;) { ! 252: if (soacnt == 0) { ! 253: if ((n = res_mkquery(QUERY, zp->z_origin, C_IN, ! 254: T_AXFR, (char *)NULL, 0, NULL, ! 255: buf, sizeof(buf))) < 0) { ! 256: syslog(LOG_ERR, "zoneref: res_mkquery failed"); ! 257: (void) close(s); ! 258: (void) sigvec(SIGALRM, &osv, ! 259: (struct sigvec *)0); ! 260: return; ! 261: } ! 262: /* ! 263: * Send length & message for zone transfer ! 264: */ ! 265: if (writemsg(s, buf, n) < 0) { ! 266: (void) close(s); ! 267: error++; ! 268: #ifdef DEBUG ! 269: if (debug >= 2) ! 270: fprintf(ddt,"writemsg failed\n"); ! 271: #endif ! 272: break; ! 273: } ! 274: } ! 275: /* ! 276: * Receive length & response ! 277: */ ! 278: cp = buf; ! 279: l = sizeof(u_short); ! 280: while (l > 0) { ! 281: (void) setitimer(ITIMER_REAL, &ival, ! 282: (struct itimerval *)NULL); ! 283: if ((n = recv(s, cp, l, 0)) > 0) { ! 284: cp += n; ! 285: l -= n; ! 286: } else { ! 287: if (errno == EINTR && !read_interrupted) ! 288: continue; ! 289: error++; ! 290: break; ! 291: } ! 292: } ! 293: (void) setitimer(ITIMER_REAL, &zeroival, ! 294: (struct itimerval *)NULL); ! 295: if (error) ! 296: break; ! 297: if ((len = htons(*(u_short *)buf)) == 0) ! 298: break; ! 299: l = len; ! 300: cp = buf; ! 301: while (l > 0) { ! 302: (void) setitimer(ITIMER_REAL, &ival, ! 303: (struct itimerval *)NULL); ! 304: if ((n = recv(s, cp, l, 0)) > 0) { ! 305: cp += n; ! 306: l -= n; ! 307: } else { ! 308: if (errno == EINTR && !read_interrupted) ! 309: continue; ! 310: error++; ! 311: break; ! 312: } ! 313: } ! 314: (void) setitimer(ITIMER_REAL, &zeroival, ! 315: (struct itimerval *)NULL); ! 316: if (error) ! 317: break; ! 318: #ifdef DEBUG ! 319: if (debug >= 3) { ! 320: fprintf(ddt,"len = %d\n", len); ! 321: fp_query(buf, ddt); ! 322: } ! 323: #endif ! 324: cp = buf + sizeof(HEADER); ! 325: if (hp->qdcount) ! 326: cp += dn_skip(cp) + QFIXEDSZ; ! 327: tmp = cp + dn_skip(cp); ! 328: n = doupdate(buf, sizeof(buf), cp, zone, 0); ! 329: if ((cp - buf) + n != len) { ! 330: #ifdef DEBUG ! 331: if (debug) ! 332: fprintf(ddt,"zoneref: doupdate failed (%d, %d)\n", ! 333: cp - buf, n); ! 334: #endif ! 335: error++; ! 336: break; ! 337: } ! 338: if ((getshort(tmp)) == T_SOA) { ! 339: if (soacnt == 0) { ! 340: soacnt++; ! 341: tmp += 3 * sizeof(u_short) ! 342: + sizeof(u_long); ! 343: tmp += dn_skip(tmp); ! 344: tmp += dn_skip(tmp); ! 345: serial = getlong(tmp); ! 346: continue; ! 347: } ! 348: soa_zinfo(zp, tmp); ! 349: if (serial != zp->z_serial) ! 350: soacnt = 0; ! 351: else { ! 352: break; ! 353: } ! 354: } ! 355: } ! 356: (void) close(s); ! 357: if ( error == 0) { ! 358: htp = hashtab; ! 359: np = nlookup(zp->z_origin, &htp, &fname, 0); ! 360: if (np == NULL || fname != zp->z_origin) { ! 361: (void) sigvec(SIGALRM, &osv, (struct sigvec *)0); ! 362: return; ! 363: } ! 364: pdp = NULL; ! 365: dp = np->n_data; ! 366: while (dp != NULL) { ! 367: if (!match(dp, C_ANY, T_SOA)) { ! 368: pdp = dp; ! 369: dp = dp->d_next; ! 370: continue; ! 371: } ! 372: /* find serial number */ ! 373: cp = dp->d_data; ! 374: cp += strlen(cp) + 1; /* origin */ ! 375: cp += strlen(cp) + 1; /* address */ ! 376: serial = getlong(cp); ! 377: #ifdef DEBUG ! 378: if (debug >= 2) ! 379: fprintf(ddt,"Found serial = %d\n",serial); ! 380: #endif ! 381: ! 382: /* remove data if not = current serial number */ ! 383: if (serial != zp->z_serial) { ! 384: #ifdef DEBUG ! 385: if (debug >= 2) ! 386: fprintf(ddt,"deleting SOA serial #%d\n", ! 387: serial); ! 388: #endif ! 389: tdp = dp->d_next; ! 390: free((char *)dp); ! 391: dp = tdp; ! 392: if (pdp == NULL) ! 393: np->n_data = dp; ! 394: else ! 395: pdp->d_next = dp; ! 396: continue; ! 397: } ! 398: pdp = dp; ! 399: dp = dp->d_next; ! 400: } ! 401: (void) sigvec(SIGALRM, &osv, (struct sigvec *)0); ! 402: return; ! 403: } ! 404: #ifdef DEBUG ! 405: if (debug >= 2) ! 406: fprintf(ddt,"error reciving zone transfer\n"); ! 407: #endif ! 408: } ! 409: (void) sigvec(SIGALRM, &osv, (struct sigvec *)0); ! 410: /* ! 411: * Freedom at last!! ! 412: * ! 413: * The land where all repressed slaves dream of. ! 414: * ! 415: * Can't find a master to talk to. ! 416: * syslog it and hope we can find a master during maintenance ! 417: */ ! 418: if (error) ! 419: syslog(LOG_ERR, "zoneref: Can't find Master for secondary zone %s", ! 420: zp->z_origin); ! 421: zp->z_refresh = zp->z_retry; ! 422: if (gettimeofday(&tt, (struct timezone *)0) < 0) ! 423: syslog(LOG_ERR, "gettimeofday failed: %m"); ! 424: zp->z_time = tt.tv_sec + zp->z_retry; ! 425: return; ! 426: }
This archive runs on limited infrastructure. Preserving old code on modern bandwidth. Automated agents are requested to crawl responsibly.