nsd/dist/xfrd.c

58 /* delete pending task xfr files in tmp */
100 static void xfrd_free_zone_xfr(xfrd_zone_type* zone, xfrd_xfr_type* xfr);
393 	/* unlink xfr files for running transfers */
396 		xfrd_xfr_type *xfr;
397 		for(xfr = zone->latest_xfr; xfr != NULL; xfr = xfr->prev) {
398 			if (xfr->acquired == 0)
400 			xfrd_unlink_xfrfile(xfrd->nsd, xfr->xfrfilenumber);
403 	/* unlink xfr files in not-yet-done task file */
554 				"master zone has no outgoing xfr requests",
570 	xfrd_xfr_type* xfr;
642 	for(xfr = zone->latest_xfr; xfr; xfr = prev_xfr) {
643 		prev_xfr = xfr->prev;
645 		if(!xfr->acquired) {
650 			if(!xfr->sent)
652 			assert(xfr->acquired <= before);
655 			    soa_ptr->serial != htonl(xfr->msg_new_serial))
660 				acquired = xfr->acquired;
667 					           xfr->msg_new_serial));
670 					xfrd->nsd, xfr->xfrfilenumber);
677 			           xfr->msg_new_serial));
678 		xfrd_delete_zone_xfr(zone, xfr);
1099 	/* perform xfr request */
1818 			DEBUG(DEBUG_XFRD,1, (LOG_ERR, "xfrd: zone %s xfr has "
1827 			DEBUG(DEBUG_XFRD,1, (LOG_ERR, "xfrd: zone %s xfr unable "
1832 			DEBUG(DEBUG_XFRD,1, (LOG_ERR, "xfrd: zone %s xfr hdr "
1842 			DEBUG(DEBUG_XFRD,1, (LOG_ERR, "xfrd: zone %s xfr pkt "
1849 			DEBUG(DEBUG_XFRD,1, (LOG_ERR, "xfrd: zone %s xfr unable "
1857 				DEBUG(DEBUG_XFRD,1, (LOG_ERR, "xfrd: zone %s xfr "
1866 					DEBUG(DEBUG_XFRD,1, (LOG_ERR, "xfrd: zone %s xfr "
1871 					DEBUG(DEBUG_XFRD,1, (LOG_ERR, "xfrd: zone %s xfr "
1890 					DEBUG(DEBUG_XFRD,1, (LOG_ERR, "xfrd: zone %s xfr "
1895 					DEBUG(DEBUG_XFRD,1, (LOG_ERR, "xfrd: zone %s xfr "
2019 			DEBUG(DEBUG_XFRD,1, (LOG_ERR, "dropping xfr reply due "
2031 		DEBUG(DEBUG_XFRD,1, (LOG_ERR, "dropping xfr reply, impossibly "
2050 		DEBUG(DEBUG_XFRD,1, (LOG_INFO, "xfrd: too short xfr packet: no "
2175 		DEBUG(DEBUG_XFRD,1, (LOG_INFO, "xfrd: zone %s sent bad xfr "
2208 xfrd_free_zone_xfr(xfrd_zone_type *zone, xfrd_xfr_type *xfr)
2210 	if(xfr == zone->latest_xfr) {
2211 		assert(xfr->next == NULL);
2212 		if((zone->latest_xfr = xfr->prev) != NULL)
2215 		if(xfr->next != NULL)
2216 			xfr->next->prev = xfr->prev;
2217 		if(xfr->prev != NULL)
2218 			xfr->prev->next = xfr->next;
2220 	tsig_delete_record(&xfr->tsig, xfrd->region);
2221 	region_recycle(xfrd->region, xfr, sizeof(*xfr));
2225 xfrd_delete_zone_xfr(xfrd_zone_type *zone, xfrd_xfr_type *xfr)
2227 	if(xfr->acquired != 0 || xfr->msg_seq_nr != 0) {
2228 		xfrd_unlink_xfrfile(xfrd->nsd, xfr->xfrfilenumber);
2230 	xfrd_free_zone_xfr(zone, xfr);
2236 	xfrd_xfr_type *xfr;
2243 	xfr = region_alloc_zero(xfrd->region, sizeof(*xfr));
2244 	if((xfr->prev = zone->latest_xfr) != NULL) {
2245 		xfr->prev->next = xfr;
2247 	tsig_create_record_custom(&xfr->tsig, NULL, 0, 0, 4);
2248 	zone->latest_xfr = xfr;
2249 	xfr->query_type = query_type;
2251 	return xfr;
2262 	/* parse and check the packet - see if it ends the xfr */
2280 				/* do not process xfr - if only one part simply ignore it. */
2363 	/* reset msg seq nr, so if that is nonnull we know xfr file exists */
2508 		/* First, see if our notifier has a match in provide-xfr */
2583 	xfrd_xfr_type* xfr;
2591 		xfr = zone->latest_xfr;
2592 		while(!xfr->sent && xfr->prev) {
2593 			xfr = xfr->prev;
2598 		if(xfr->sent == sent &&
2600 			 zone->soa_nsd.serial != htonl(xfr->msg_new_serial)))
2603 			soa.serial = htonl(xfr->msg_new_serial);
2607 			                 zone->apex_str, xfr->msg_new_serial);
2609 			if(xfr->acquired == zone->soa_nsd_acquired) {
2623 			soa.serial = htonl(xfr->msg_new_serial);
2627 			for(xfr = zone->latest_xfr; xfr; xfr = prev_xfr) {
2628 				prev_xfr = xfr->prev;
2630 				if(!xfr->acquired)
2636 					           xfr->msg_new_serial));
2637 				xfrd_delete_zone_xfr(zone, xfr);
2647 	xfrd_xfr_type* xfr;
2654 		xfr = zone->latest_xfr;
2655 		while(xfr) {
2656 			if(!xfr->prev)
2658 			xfr = xfr->prev;
2659 			assert(xfr->acquired);
2662 		while(xfr && xfr->acquired) {
2664 			if(xfrd->reload_cmd_first_sent && !xfr->sent)
2667 			        xfrd->reload_cmd_first_sent >= xfr->acquired);
2673 					xfr->msg_old_serial,
2674 					xfr->msg_new_serial,
2675 					xfr->xfrfilenumber);
2681 			xfr->sent = send ? 1 + xfrd->nsd->mytask : 0;
2682 			xfr = xfr->next;