ntp/ntpd/ntp_proto.c

191 nak_code	valid_NAK	(struct peer *peer, struct recvbuf *rbufp, u_char hismode);
281 	  struct recvbuf *rbufp,
295 	if (rbufp->recv_length == base_packet_length) {
299 	remainder_size = rbufp->recv_length - base_packet_length;
321 	rpkt = &rbufp->recv_pkt;
580 	struct recvbuf *rbufp
636 	if (0 == SRCPORT(&rbufp->recv_srcadr)) {
640 	restrictions(&rbufp->recv_srcadr, &r4a);
643 	pkt = &rbufp->recv_pkt;
649 		    current_time, stoa(&rbufp->dstadr->sin),
650 		    stoa(&rbufp->recv_srcadr), r4a.ippeerlimit, hismode,
651 		    build_iflags(rbufp->dstadr->flags),
670 		process_private(rbufp, ((restrict_mask &
680 		process_control(rbufp, restrict_mask);
768 	has_mac = rbufp->recv_length - authlen;
794 			    || (int)len + authlen > rbufp->recv_length) {
867 	restrict_mask = ntp_monitor(rbufp, restrict_mask);
875 					stoa(&rbufp->recv_srcadr)));
882 			fast_xmit(rbufp, MODE_SERVER, skeyid,
885 			fast_xmit(rbufp, MODE_ACTIVE, skeyid,
911 	peer = findpeer(rbufp,  hismode, &retcode);
912 	dstadr_sin = &rbufp->dstadr->sin;
942 	crypto_nak_test = valid_NAK(peer, rbufp, hismode);
953 			current_time, stoa(dstadr_sin), stoa(&rbufp->recv_srcadr));
962 			    stoa(&rbufp->recv_srcadr), hismode, hm_str, am_str,
971 			    stoa(&rbufp->recv_srcadr), hismode, hm_str, am_str,
1053 				    && rbufp->dstadr ==
1054 				       ANY_INTERFACE_CHOOSE(&rbufp->recv_srcadr)) {
1060 				if (!SOCK_UNSPEC(&rbufp->dstadr->bcast))
1062 					    &rbufp->dstadr->bcast;
1065 				    &rbufp->recv_srcadr, dstadr_sin, 0,
1079 				session_key(&rbufp->recv_srcadr,
1082 				    &rbufp->recv_srcadr, dstadr_sin,
1086 				    &rbufp->recv_srcadr, dstadr_sin,
1111 			    stoa(&rbufp->recv_srcadr), hismode, hm_str, am_str,
1140 				    stoa(&rbufp->recv_srcadr)));
1155 				    stoa(&rbufp->recv_srcadr)));
1166 					    stoa(&rbufp->recv_srcadr)));
1217 		if (!(rbufp->dstadr->flags & INT_MCASTOPEN)) {
1219 			record_raw_stats(&rbufp->recv_srcadr,
1220 			    &rbufp->dstadr->sin,
1221 			    &p_org, &p_rec, &p_xmt, &rbufp->recv_time,
1231 			    rbufp->recv_length - MIN_V4_PKT_LEN, (u_char *)&pkt->exten);
1235 				fast_xmit(rbufp, MODE_SERVER, skeyid,
1238 				fast_xmit(rbufp, MODE_SERVER, 0,
1278 		    || rbufp->dstadr->addr_refid == pkt->refid) {
1289 			record_raw_stats(&rbufp->recv_srcadr,
1290 			    &rbufp->dstadr->sin,
1291 			    &p_org, &p_rec, &p_xmt, &rbufp->recv_time,
1301 			    rbufp->recv_length - MIN_V4_PKT_LEN, (u_char *)&pkt->exten);
1303 			fast_xmit(rbufp, MODE_SERVER, skeyid,
1341 		if ((peer2 = findmanycastpeer(rbufp)) == NULL) {
1368 		peer = newpeer(&rbufp->recv_srcadr, NULL, rbufp->dstadr,
1464 		if (!(INT_MCASTOPEN & rbufp->dstadr->flags))
1465 			match_ep = rbufp->dstadr;
1489 			peer = newpeer(&rbufp->recv_srcadr, NULL, match_ep,
1513 		peer = newpeer(&rbufp->recv_srcadr, NULL, match_ep,
1526 			crypto_recv(peer, rbufp);
1564 					fast_xmit(rbufp, MODE_PASSIVE, skeyid,
1569 					fast_xmit(rbufp, MODE_ACTIVE, 0,
1589 				    current_time, stoa(&rbufp->recv_srcadr),
1618 		if ((peer = newpeer(&rbufp->recv_srcadr, NULL, rbufp->dstadr,
1668 					stoa(&rbufp->recv_srcadr),
1676 					pkt->ppoll, stoa(&rbufp->recv_srcadr),
1696 					stoa(&rbufp->recv_srcadr),
1742 					stoa(&rbufp->recv_srcadr),
2065 			fast_xmit(rbufp, MODE_ACTIVE, 0, restrict_mask);
2103 					peer->borg = rbufp->recv_time;
2133 		peer->dst = rbufp->recv_time;
2265 		rval = crypto_recv(peer, rbufp);
2326 				    &rbufp->recv_srcadr, dstadr_sin,
2354 	process_packet(peer, pkt, rbufp->recv_length);
2362 		peer->dst = rbufp->recv_time;
4342 	struct recvbuf *rbufp,	/* receive packet pointer */
4367 	rpkt = &rbufp->recv_pkt;
4368 	if (rbufp->dstadr->flags & INT_MCASTOPEN)
4369 		rbufp->dstadr = findinterface(&rbufp->recv_srcadr);
4438 		this_recv_time = rbufp->recv_time;
4443 		HTONL_FP(&rbufp->recv_time, &xpkt.rec);
4456 		send_via_ntp_signd(rbufp, xmode, xkeyid, flags, &xpkt);
4467 	if (rbufp->recv_length == sendlen) {
4468 		sendpkt(&rbufp->recv_srcadr, rbufp->dstadr, 0, &xpkt,
4471 			    current_time, stoa(&rbufp->dstadr->sin),
4472 			    stoa(&rbufp->recv_srcadr), xmode,
4498 		cookie = session_key(&rbufp->recv_srcadr,
4499 		    &rbufp->dstadr->sin, 0, sys_private, 0);
4500 		if ((size_t)rbufp->recv_length > sendlen + MAX_MAC_LEN) {
4501 			session_key(&rbufp->dstadr->sin,
4502 			    &rbufp->recv_srcadr, xkeyid, 0, 2);
4505 			sendlen += crypto_xmit(NULL, &xpkt, rbufp,
4509 			session_key(&rbufp->dstadr->sin,
4510 			    &rbufp->recv_srcadr, xkeyid, cookie, 2);
4520 	sendpkt(&rbufp->recv_srcadr, rbufp->dstadr, 0, &xpkt, sendlen);
4525 		    current_time, ntoa(&rbufp->dstadr->sin),
4526 		    ntoa(&rbufp->recv_srcadr), xmode, xkeyid,