Lines Matching refs:rbufp
210 nak_code valid_NAK (struct peer *peer, struct recvbuf *rbufp, u_char hismode);
300 struct recvbuf *rbufp,
314 if (rbufp->recv_length == base_packet_length) {
318 remainder_size = rbufp->recv_length - base_packet_length;
340 rpkt = &rbufp->recv_pkt;
616 struct recvbuf *rbufp
673 if (0 == SRCPORT(&rbufp->recv_srcadr) || rbufp->recv_length < 2) {
677 restrictions(&rbufp->recv_srcadr, &r4a);
680 pkt = &rbufp->recv_pkt;
695 process_private(rbufp, ((restrict_mask &
705 process_control(rbufp, restrict_mask);
720 if (rbufp->recv_length < LEN_PKT_NOMAC) {
731 current_time, stoa(&rbufp->dstadr->sin),
732 stoa(&rbufp->recv_srcadr), r4a.ippeerlimit, hismode,
733 build_iflags(rbufp->dstadr->flags),
817 has_mac = rbufp->recv_length - authlen;
843 || (int)len + authlen > rbufp->recv_length) {
916 restrict_mask = ntp_monitor(rbufp, restrict_mask);
924 stoa(&rbufp->recv_srcadr)));
931 fast_xmit(rbufp, MODE_SERVER, skeyid,
934 fast_xmit(rbufp, MODE_ACTIVE, skeyid,
961 peer = findpeer(rbufp, hismode, &retcode);
962 dstadr_sin = &rbufp->dstadr->sin;
992 crypto_nak_test = valid_NAK(peer, rbufp, hismode);
1003 current_time, stoa(dstadr_sin), stoa(&rbufp->recv_srcadr));
1012 stoa(&rbufp->recv_srcadr), hismode, hm_str, am_str,
1021 stoa(&rbufp->recv_srcadr), hismode, hm_str, am_str,
1044 stoa(&rbufp->recv_srcadr), hismode, hm_str, am_str,
1109 && rbufp->dstadr ==
1110 ANY_INTERFACE_CHOOSE(&rbufp->recv_srcadr)) {
1116 if (!SOCK_UNSPEC(&rbufp->dstadr->bcast))
1118 &rbufp->dstadr->bcast;
1121 &rbufp->recv_srcadr, dstadr_sin, 0,
1135 session_key(&rbufp->recv_srcadr,
1138 &rbufp->recv_srcadr, dstadr_sin,
1142 &rbufp->recv_srcadr, dstadr_sin,
1167 stoa(&rbufp->recv_srcadr), hismode, hm_str, am_str,
1196 stoa(&rbufp->recv_srcadr)));
1211 stoa(&rbufp->recv_srcadr)));
1222 stoa(&rbufp->recv_srcadr)));
1275 if (!(rbufp->dstadr->flags & INT_MCASTOPEN)) {
1277 record_raw_stats(&rbufp->recv_srcadr,
1278 &rbufp->dstadr->sin,
1279 &p_org, &p_rec, &p_xmt, &rbufp->recv_time,
1289 rbufp->recv_length - MIN_V4_PKT_LEN, (u_char *)&pkt->exten);
1294 fast_xmit(rbufp, MODE_SERVER, skeyid,
1298 fast_xmit(rbufp, MODE_SERVER, 0,
1338 || rbufp->dstadr->addr_refid == pkt->refid) {
1339 DPRINTF(2, ("receive: sys leap: %0x, sys_stratum %d > hisstratum+1 %d, !sys_cohort %d && sys_stratum == hisstratum+1, loop refid %#x == pkt refid %#x\n", sys_leap, sys_stratum, hisstratum + 1, !sys_cohort, rbufp->dstadr->addr_refid, pkt->refid));
1350 record_raw_stats(&rbufp->recv_srcadr,
1351 &rbufp->dstadr->sin,
1352 &p_org, &p_rec, &p_xmt, &rbufp->recv_time,
1362 rbufp->recv_length - MIN_V4_PKT_LEN, (u_char *)&pkt->exten);
1365 fast_xmit(rbufp, MODE_SERVER, skeyid,
1403 if ((peer2 = findmanycastpeer(rbufp)) == NULL) {
1430 peer = newpeer(&rbufp->recv_srcadr, NULL, rbufp->dstadr,
1526 if (!(INT_MCASTOPEN & rbufp->dstadr->flags))
1527 match_ep = rbufp->dstadr;
1551 peer = newpeer(&rbufp->recv_srcadr, NULL, match_ep,
1575 peer = newpeer(&rbufp->recv_srcadr, NULL, match_ep,
1588 crypto_recv(peer, rbufp);
1629 fast_xmit(rbufp, MODE_PASSIVE, skeyid,
1635 fast_xmit(rbufp, MODE_PASSIVE, 0,
1661 current_time, stoa(&rbufp->recv_srcadr),
1697 if ((peer = newpeer(&rbufp->recv_srcadr, NULL, rbufp->dstadr,
1747 stoa(&rbufp->recv_srcadr),
1755 pkt->ppoll, stoa(&rbufp->recv_srcadr),
1775 stoa(&rbufp->recv_srcadr),
1821 stoa(&rbufp->recv_srcadr),
2152 fast_xmit(rbufp, MODE_ACTIVE, 0, restrict_mask);
2190 peer->borg = rbufp->recv_time;
2220 peer->dst = rbufp->recv_time;
2352 rval = crypto_recv(peer, rbufp);
2413 &rbufp->recv_srcadr, dstadr_sin,
2441 process_packet(peer, pkt, rbufp->recv_length);
2457 peer->dst = rbufp->recv_time;
4504 struct recvbuf *rbufp, /* receive packet pointer */
4529 rpkt = &rbufp->recv_pkt;
4530 if (rbufp->dstadr->flags & INT_MCASTOPEN)
4531 rbufp->dstadr = findinterface(&rbufp->recv_srcadr);
4657 this_recv_time = rbufp->recv_time;
4662 HTONL_FP(&rbufp->recv_time, &xpkt.rec);
4679 send_via_ntp_signd(rbufp, xmode, xkeyid, flags, &xpkt);
4690 if (rbufp->recv_length == sendlen) {
4691 sendpkt(&rbufp->recv_srcadr, rbufp->dstadr, 0, &xpkt,
4694 current_time, stoa(&rbufp->dstadr->sin),
4695 stoa(&rbufp->recv_srcadr), xmode,
4721 cookie = session_key(&rbufp->recv_srcadr,
4722 &rbufp->dstadr->sin, 0, sys_private, 0);
4723 if ((size_t)rbufp->recv_length > sendlen + MAX_MAC_LEN) {
4724 session_key(&rbufp->dstadr->sin,
4725 &rbufp->recv_srcadr, xkeyid, 0, 2);
4728 sendlen += crypto_xmit(NULL, &xpkt, rbufp,
4732 session_key(&rbufp->dstadr->sin,
4733 &rbufp->recv_srcadr, xkeyid, cookie, 2);
4743 sendpkt(&rbufp->recv_srcadr, rbufp->dstadr, 0, &xpkt, sendlen);
4748 current_time, ntoa(&rbufp->dstadr->sin),
4749 ntoa(&rbufp->recv_srcadr), xmode, xkeyid,