nsd/dist/xfrd-notify.c

160 			zone->apex_str, zone->pkts[index].dest->ip_address_spec);
165 	if(ID(packet) != zone->pkts[index].notify_query_id) {
167 			zone->apex_str, zone->pkts[index].dest->ip_address_spec);
174 			zone->pkts[index].dest->ip_address_spec);
180 		zone->apex_str, zone->pkts[index].dest->ip_address_spec));
227 	zone->pkts[index].dest = NULL;
228 	zone->pkts[index].notify_retry = 0;
229 	zone->pkts[index].send_time = 0;
230 	zone->pkts[index].notify_query_id = 0;
237 	if(++zone->pkts[index].notify_retry >=
241 			zone->pkts[index].dest->ip_address_spec);
257 		if(!zone->pkts[i].dest)
260 		if(!cmp_addr_equal(src, srclen, zone->pkts[i].dest))
278 	if(!zone->pkts[index].dest) return 0;
282 	zone->pkts[index].notify_query_id = ID(packet);
290 	if(zone->pkts[index].dest->key_options) {
291 		xfrd_tsig_sign_request(packet, &zone->notify_tsig, zone->pkts[index].dest);
295 	if((zone->pkts[index].dest->is_ipv6
297 		(!zone->pkts[index].dest->is_ipv6
300 		int fd = xfrd_send_udp(zone->pkts[index].dest, packet,
304 				zone->apex_str, zone->pkts[index].notify_retry,
305 				zone->pkts[index].dest->ip_address_spec);
308 		if(zone->pkts[index].dest->is_ipv6)
320 			zone->pkts[index].dest, &to);
321 		if(zone->pkts[index].dest->is_ipv6)
328 				zone->pkts[index].dest->ip_address_spec,
333 	zone->pkts[index].send_time = time(NULL);
335 		zone->apex_str, zone->pkts[index].notify_retry,
336 		zone->pkts[index].dest->ip_address_spec));
346 		if(!zone->pkts[i].dest)
348 		if(now >= zone->pkts[i].send_time + XFRD_NOTIFY_RETRY_TIMOUT) {
362 		while(zone->pkts[i].dest==NULL && zone->notify_current) {
363 			zone->pkts[i].dest = zone->notify_current;
365 			zone->pkts[i].notify_retry = 0;
366 			zone->pkts[i].notify_query_id = 0;
367 			zone->pkts[i].send_time = 0;
442 	/* see which pkts have timeouted, retry or NULL them */
465 	memset(zone->pkts, 0, sizeof(zone->pkts));