ntp/ntpd/ntp_monitor.c

126 	mon_entry *mon
133 	hash = MON_HASH(&mon->rmtadr);
134 	UNLINK_SLIST(punlinked, mon_hash[hash], mon, hash_next,
136 	ENSURE(punlinked == mon);
241 	mon_entry *mon;
257 	ITER_DLIST_BEGIN(mon_mru_list, mon, mru, mon_entry)
258 		mon_free_entry(mon);
277 	mon_entry *mon;
279 	/* iterate mon over mon_mru_list */
280 	ITER_DLIST_BEGIN(mon_mru_list, mon, mru, mon_entry)
281 		if (mon->lcladr == lcladr) {
283 			UNLINK_DLIST(mon, mru);
285 			remove_from_hash(mon);
287 			mon_free_entry(mon);
316 	mon_entry *	mon;
337 	mon = mon_hash[hash];
344 	for (; mon != NULL; mon = mon->hash_next)
345 		if (SOCK_EQ(&mon->rmtadr, &rbufp->recv_srcadr))
348 	if (mon != NULL) {
350 		L_SUB(&interval_fp, &mon->last);
354 		mon->last = rbufp->recv_time;
355 		NSRCPORT(&mon->rmtadr) = NSRCPORT(&rbufp->recv_srcadr);
356 		mon->count++;
358 		mon->vn_mode = VN_MODE(version, mode);
361 		UNLINK_DLIST(mon, mru);
362 		LINK_DLIST(mon_mru_list, mon, mru);
369 		mon->leak -= interval;
370 		mon->leak = max(0, mon->leak);
372 		leak = mon->leak + head;
393 			mon->leak = leak - 2;
395 		} else if (mon->leak < limit)
396 			mon->leak = limit + head;
400 		mon->flags = restrict_mask;
402 		return mon->flags;
441 		UNLINK_HEAD_SLIST(mon, mon_free, hash_next);
455 			mon = oldest;
460 			UNLINK_HEAD_SLIST(mon, mon_free, hash_next);
467 			mon = oldest;
471 	INSIST(mon != NULL);
478 	mon->last = rbufp->recv_time;
479 	mon->first = mon->last;
480 	mon->count = 1;
481 	mon->flags = ~(RES_LIMITED | RES_KOD) & flags;
482 	mon->leak = 0;
483 	memcpy(&mon->rmtadr, &rbufp->recv_srcadr, sizeof(mon->rmtadr));
484 	mon->vn_mode = VN_MODE(version, mode);
485 	mon->lcladr = rbufp->dstadr;
486 	mon->cast_flags = (u_char)(((rbufp->dstadr->flags &
487 	    INT_MCASTOPEN) && rbufp->fd == mon->lcladr->fd) ? MDF_MCAST
488 	    : rbufp->fd == mon->lcladr->bfd ? MDF_BCAST : MDF_UCAST);
494 	LINK_SLIST(mon_hash[hash], mon, hash_next);
495 	LINK_DLIST(mon_mru_list, mon, mru);
497 	return mon->flags;