nsd/dist/xfrd-notify.c

2  * xfrd-notify.c - notify sending routines
15 #include "xfrd-notify.h"
16 #include "xfrd.h"
17 #include "xfrd-tcp.h"
67 	if(xfrd->notify_udp_num == XFRD_MAX_UDP_NOTIFY) {
69 		while(xfrd->notify_waiting_first) {
71 			struct notify_zone* wz = xfrd->notify_waiting_first;
74 			xfrd->notify_waiting_first = wz->waiting_next;
77 			if(xfrd->notify_waiting_last == wz)
78 				xfrd->notify_waiting_last = NULL;
82 					"xfrd: zone %s: notify off waiting list.",
89 	xfrd->notify_udp_num--;
121 xfrd_del_notify(xfrd_state_type* xfrd, const dname_type* dname)
125 		xfrd->notify_zones, dname);
133 		else	xfrd->notify_waiting_first = not->waiting_next;
136 		else	xfrd->notify_waiting_last = not->waiting_prev;
149 	region_recycle(xfrd->region, not->current_soa, sizeof(xfrd_soa_type));
151 	region_recycle(xfrd->region, not, sizeof(*not));
159 		log_msg(LOG_ERR, "xfrd: zone %s: received bad notify reply opcode/flags from %s",
166 		log_msg(LOG_ERR, "xfrd: zone %s: received notify-ack with bad ID from %s",
172 		log_msg(LOG_ERR, "xfrd: zone %s: received notify response error %s from %s",
179 	DEBUG(DEBUG_XFRD,1, (LOG_INFO, "xfrd: zone %s: host %s acknowledges notify",
239 		log_msg(LOG_ERR, "xfrd: zone %s: max notify send count reached, %s unreachable",
303 			log_msg(LOG_ERR, "xfrd: zone %s: could not send notify #%d to %s",
327 			log_msg(LOG_ERR, "xfrd notify: sendto %s failed %s",
334 	DEBUG(DEBUG_XFRD,1, (LOG_INFO, "xfrd: zone %s: sent notify #%d to %s",
389 		if(event_base_set(xfrd->event_base, &zone->notify_send_handler) != 0)
405 		if(event_base_set(xfrd->event_base, &zone->notify_send6_handler) != 0)
420 			"xfrd: notify waiting, skipped, %s", zone->apex_str));
427 			"xfrd: zone %s: read notify ACK", zone->apex_str));
437 		DEBUG(DEBUG_XFRD,1, (LOG_INFO, "xfrd: zone %s: notify timeout",
452 			"xfrd: zone %s: no more notify-send acls. stop notify.",
476 	if(event_base_set(xfrd->event_base, &zone->notify_send_handler) != 0)
497 	if(xfrd->notify_udp_num < XFRD_MAX_UDP_NOTIFY) {
499 		xfrd->notify_udp_num++;
506 	zone->waiting_prev = xfrd->notify_waiting_last;
507 	if(xfrd->notify_waiting_last) {
508 		xfrd->notify_waiting_last->waiting_next = zone;
510 		xfrd->notify_waiting_first = zone;
512 	xfrd->notify_waiting_last = zone;
513 	DEBUG(DEBUG_XFRD,1, (LOG_INFO, "xfrd: zone %s: notify on waiting list.",
518 xfrd_notify_start(struct notify_zone* zone, struct xfrd_state* xfrd)
524 	xz = (xfrd_zone_type*)rbtree_search(xfrd->zones, zone->apex);