Lines Matching refs:rbufp
210 nak_code valid_NAK (struct peer *peer, struct recvbuf *rbufp, u_char hismode);
300 struct recvbuf *rbufp, in valid_NAK() argument
314 if (rbufp->recv_length == base_packet_length) { in valid_NAK()
318 remainder_size = rbufp->recv_length - base_packet_length; in valid_NAK()
340 rpkt = &rbufp->recv_pkt; in valid_NAK()
627 struct recvbuf *rbufp in receive() argument
687 if (0 == SRCPORT(&rbufp->recv_srcadr) || rbufp->recv_length < 2) { in receive()
691 restrictions(&rbufp->recv_srcadr, &r4a); in receive()
694 pkt = &rbufp->recv_pkt; in receive()
709 process_private(rbufp, !(RES_NOMODIFY & restrict_mask)); in receive()
718 process_control(rbufp, restrict_mask); in receive()
733 if (rbufp->recv_length < LEN_PKT_NOMAC) { in receive()
744 current_time, stoa(&rbufp->dstadr->sin), in receive()
745 stoa(&rbufp->recv_srcadr), r4a.ippeerlimit, hismode, in receive()
746 iflags_str(rbufp->dstadr->flags), in receive()
824 pkt->ppoll, stoa(&rbufp->recv_srcadr))); in receive()
829 pkt->ppoll, stoa(&rbufp->recv_srcadr))); in receive()
857 has_mac = rbufp->recv_length - authlen; in receive()
883 || (int)len + authlen > rbufp->recv_length) { in receive()
956 restrict_mask = ntp_monitor(rbufp, restrict_mask); in receive()
964 stoa(&rbufp->recv_srcadr))); in receive()
971 fast_xmit(rbufp, MODE_SERVER, skeyid, in receive()
974 fast_xmit(rbufp, MODE_ACTIVE, skeyid, in receive()
1001 peer = findpeer(rbufp, hismode, &retcode); in receive()
1002 dstadr_sin = &rbufp->dstadr->sin; in receive()
1034 crypto_nak_test = valid_NAK(peer, rbufp, hismode); in receive()
1045 current_time, stoa(dstadr_sin), stoa(&rbufp->recv_srcadr)); in receive()
1054 stoa(&rbufp->recv_srcadr), hismode, hm_str, am_str, in receive()
1063 stoa(&rbufp->recv_srcadr), hismode, hm_str, am_str, in receive()
1086 stoa(&rbufp->recv_srcadr), hismode, hm_str, am_str, in receive()
1151 && rbufp->dstadr == in receive()
1152 ANY_INTERFACE_CHOOSE(&rbufp->recv_srcadr)) { in receive()
1158 if (!SOCK_UNSPEC(&rbufp->dstadr->bcast)) in receive()
1160 &rbufp->dstadr->bcast; in receive()
1163 &rbufp->recv_srcadr, dstadr_sin, 0, in receive()
1177 session_key(&rbufp->recv_srcadr, in receive()
1180 &rbufp->recv_srcadr, dstadr_sin, in receive()
1184 &rbufp->recv_srcadr, dstadr_sin, in receive()
1209 stoa(&rbufp->recv_srcadr), hismode, hm_str, am_str, in receive()
1238 stoa(&rbufp->recv_srcadr))); in receive()
1253 stoa(&rbufp->recv_srcadr))); in receive()
1264 stoa(&rbufp->recv_srcadr))); in receive()
1317 if (!(rbufp->dstadr->flags & INT_MCASTOPEN)) { in receive()
1319 record_raw_stats(&rbufp->recv_srcadr, in receive()
1320 &rbufp->dstadr->sin, in receive()
1321 &p_org, &p_rec, &p_xmt, &rbufp->recv_time, in receive()
1331 rbufp->recv_length - MIN_V4_PKT_LEN, (u_char *)&pkt->exten); in receive()
1336 fast_xmit(rbufp, MODE_SERVER, skeyid, in receive()
1340 fast_xmit(rbufp, MODE_SERVER, 0, in receive()
1380 || rbufp->dstadr->addr_refid == pkt->refid in receive()
1382 || ( IS_IPV6(&rbufp->dstadr->sin) in receive()
1383 &&rbufp->dstadr->old_refid == pkt->refid) in receive()
1386 … == pkt refid %#x\n", sys_leap, sys_stratum, hisstratum + 1, !sys_cohort, rbufp->dstadr->addr_refi… in receive()
1397 if (INT_LL_OF_GLOB & rbufp->dstadr->flags) { in receive()
1408 record_raw_stats(&rbufp->recv_srcadr, in receive()
1409 &rbufp->dstadr->sin, in receive()
1410 &p_org, &p_rec, &p_xmt, &rbufp->recv_time, in receive()
1420 rbufp->recv_length - MIN_V4_PKT_LEN, (u_char *)&pkt->exten); in receive()
1423 fast_xmit(rbufp, MODE_SERVER, skeyid, in receive()
1462 if (INT_LL_OF_GLOB & rbufp->dstadr->flags) { in receive()
1467 if ((peer2 = findmanycastpeer(rbufp)) == NULL) { in receive()
1498 peer = newpeer(&rbufp->recv_srcadr, NULL, rbufp->dstadr, in receive()
1594 if (!(INT_MCASTOPEN & rbufp->dstadr->flags)) in receive()
1595 match_ep = rbufp->dstadr; in receive()
1619 peer = newpeer(&rbufp->recv_srcadr, NULL, match_ep, in receive()
1643 peer = newpeer(&rbufp->recv_srcadr, NULL, match_ep, in receive()
1656 crypto_recv(peer, rbufp); in receive()
1697 fast_xmit(rbufp, MODE_PASSIVE, skeyid, in receive()
1703 fast_xmit(rbufp, MODE_PASSIVE, 0, in receive()
1729 current_time, stoa(&rbufp->recv_srcadr), in receive()
1765 if ((peer = newpeer(&rbufp->recv_srcadr, NULL, rbufp->dstadr, in receive()
1815 stoa(&rbufp->recv_srcadr), in receive()
1823 pkt->ppoll, stoa(&rbufp->recv_srcadr), in receive()
1843 stoa(&rbufp->recv_srcadr), in receive()
1889 stoa(&rbufp->recv_srcadr), in receive()
2231 fast_xmit(rbufp, MODE_ACTIVE, 0, restrict_mask); in receive()
2269 peer->borg = rbufp->recv_time; in receive()
2299 peer->dst = rbufp->recv_time; in receive()
2324 pkt->ppoll, stoa(&rbufp->recv_srcadr))); in receive()
2439 rval = crypto_recv(peer, rbufp); in receive()
2500 &rbufp->recv_srcadr, dstadr_sin, in receive()
2528 process_packet(peer, pkt, rbufp->recv_length); in receive()
2546 peer->dst = rbufp->recv_time; in receive()
4590 struct recvbuf* rbufp, /* receive packet pointer */ in fast_xmit() argument
4612 rpkt = &rbufp->recv_pkt; in fast_xmit()
4619 if (rbufp->dstadr->flags & INT_MCASTOPEN) { in fast_xmit()
4620 rbufp->dstadr = findinterface(&rbufp->recv_srcadr); in fast_xmit()
4621 if (NULL == rbufp->dstadr || in fast_xmit()
4622 ANY_INTERFACE_CHOOSE(&rbufp->recv_srcadr) /* wildcard */ in fast_xmit()
4623 == rbufp->dstadr) { in fast_xmit()
4626 stoa(&rbufp->recv_srcadr))); in fast_xmit()
4756 this_recv_time = rbufp->recv_time; in fast_xmit()
4761 HTONL_FP(&rbufp->recv_time, &xpkt.rec); in fast_xmit()
4778 send_via_ntp_signd(rbufp, xmode, xkeyid, flags, &xpkt); in fast_xmit()
4789 if (rbufp->recv_length == sendlen) { in fast_xmit()
4790 sendpkt(&rbufp->recv_srcadr, rbufp->dstadr, 0, &xpkt, in fast_xmit()
4793 current_time, stoa(&rbufp->dstadr->sin), in fast_xmit()
4794 stoa(&rbufp->recv_srcadr), xmode, in fast_xmit()
4820 cookie = session_key(&rbufp->recv_srcadr, in fast_xmit()
4821 &rbufp->dstadr->sin, 0, sys_private, 0); in fast_xmit()
4822 if ((size_t)rbufp->recv_length > sendlen + MAX_MAC_LEN) { in fast_xmit()
4823 session_key(&rbufp->dstadr->sin, in fast_xmit()
4824 &rbufp->recv_srcadr, xkeyid, 0, 2); in fast_xmit()
4827 sendlen += crypto_xmit(NULL, &xpkt, rbufp, in fast_xmit()
4831 session_key(&rbufp->dstadr->sin, in fast_xmit()
4832 &rbufp->recv_srcadr, xkeyid, cookie, 2); in fast_xmit()
4842 sendpkt(&rbufp->recv_srcadr, rbufp->dstadr, 0, &xpkt, sendlen); in fast_xmit()
4847 current_time, ntoa(&rbufp->dstadr->sin), in fast_xmit()
4848 ntoa(&rbufp->recv_srcadr), xmode, xkeyid, in fast_xmit()