Lines Matching defs: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;
629 struct recvbuf *rbufp
689 if (0 == SRCPORT(&rbufp->recv_srcadr) || rbufp->recv_length < 2) {
693 restrictions(&rbufp->recv_srcadr, &r4a);
696 pkt = &rbufp->recv_pkt;
711 process_private(rbufp, !(RES_NOMODIFY & restrict_mask));
720 process_control(rbufp, restrict_mask);
735 if (rbufp->recv_length < LEN_PKT_NOMAC) {
746 current_time, stoa(&rbufp->dstadr->sin),
747 stoa(&rbufp->recv_srcadr), r4a.ippeerlimit, hismode,
748 iflags_str(rbufp->dstadr->flags),
826 pkt->ppoll, stoa(&rbufp->recv_srcadr)));
831 pkt->ppoll, stoa(&rbufp->recv_srcadr)));
859 has_mac = rbufp->recv_length - authlen;
885 || (int)len + authlen > rbufp->recv_length) {
958 restrict_mask = ntp_monitor(rbufp, restrict_mask);
966 stoa(&rbufp->recv_srcadr)));
973 fast_xmit(rbufp, MODE_SERVER, skeyid,
976 fast_xmit(rbufp, MODE_ACTIVE, skeyid,
1003 peer = findpeer(rbufp, hismode, &retcode);
1004 dstadr_sin = &rbufp->dstadr->sin;
1036 crypto_nak_test = valid_NAK(peer, rbufp, hismode);
1047 current_time, stoa(dstadr_sin), stoa(&rbufp->recv_srcadr));
1056 stoa(&rbufp->recv_srcadr), hismode, hm_str, am_str,
1065 stoa(&rbufp->recv_srcadr), hismode, hm_str, am_str,
1088 stoa(&rbufp->recv_srcadr), hismode, hm_str, am_str,
1153 && rbufp->dstadr ==
1154 ANY_INTERFACE_CHOOSE(&rbufp->recv_srcadr)) {
1160 if (!SOCK_UNSPEC(&rbufp->dstadr->bcast))
1162 &rbufp->dstadr->bcast;
1165 &rbufp->recv_srcadr, dstadr_sin, 0,
1179 session_key(&rbufp->recv_srcadr,
1182 &rbufp->recv_srcadr, dstadr_sin,
1186 &rbufp->recv_srcadr, dstadr_sin,
1211 stoa(&rbufp->recv_srcadr), hismode, hm_str, am_str,
1240 stoa(&rbufp->recv_srcadr)));
1255 stoa(&rbufp->recv_srcadr)));
1266 stoa(&rbufp->recv_srcadr)));
1319 if (!(rbufp->dstadr->flags & INT_MCASTOPEN)) {
1321 record_raw_stats(&rbufp->recv_srcadr,
1322 &rbufp->dstadr->sin,
1323 &p_org, &p_rec, &p_xmt, &rbufp->recv_time,
1333 rbufp->recv_length - MIN_V4_PKT_LEN, (u_char *)&pkt->exten);
1338 fast_xmit(rbufp, MODE_SERVER, skeyid,
1342 fast_xmit(rbufp, MODE_SERVER, 0,
1382 || rbufp->dstadr->addr_refid == pkt->refid
1384 || ( IS_IPV6(&rbufp->dstadr->sin)
1385 &&rbufp->dstadr->old_refid == pkt->refid)
1388 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));
1399 if (INT_LL_OF_GLOB & rbufp->dstadr->flags) {
1410 record_raw_stats(&rbufp->recv_srcadr,
1411 &rbufp->dstadr->sin,
1412 &p_org, &p_rec, &p_xmt, &rbufp->recv_time,
1422 rbufp->recv_length - MIN_V4_PKT_LEN, (u_char *)&pkt->exten);
1425 fast_xmit(rbufp, MODE_SERVER, skeyid,
1464 if (INT_LL_OF_GLOB & rbufp->dstadr->flags) {
1469 if ((peer2 = findmanycastpeer(rbufp)) == NULL) {
1500 peer = newpeer(&rbufp->recv_srcadr, NULL, rbufp->dstadr,
1596 if (!(INT_MCASTOPEN & rbufp->dstadr->flags))
1597 match_ep = rbufp->dstadr;
1621 peer = newpeer(&rbufp->recv_srcadr, NULL, match_ep,
1645 peer = newpeer(&rbufp->recv_srcadr, NULL, match_ep,
1658 crypto_recv(peer, rbufp);
1699 fast_xmit(rbufp, MODE_PASSIVE, skeyid,
1705 fast_xmit(rbufp, MODE_PASSIVE, 0,
1731 current_time, stoa(&rbufp->recv_srcadr),
1767 if ((peer = newpeer(&rbufp->recv_srcadr, NULL, rbufp->dstadr,
1817 stoa(&rbufp->recv_srcadr),
1825 pkt->ppoll, stoa(&rbufp->recv_srcadr),
1845 stoa(&rbufp->recv_srcadr),
1891 stoa(&rbufp->recv_srcadr),
2233 fast_xmit(rbufp, MODE_ACTIVE, 0, restrict_mask);
2271 peer->borg = rbufp->recv_time;
2301 peer->dst = rbufp->recv_time;
2326 pkt->ppoll, stoa(&rbufp->recv_srcadr)));
2441 rval = crypto_recv(peer, rbufp);
2502 &rbufp->recv_srcadr, dstadr_sin,
2530 process_packet(peer, pkt, rbufp->recv_length);
2548 peer->dst = rbufp->recv_time;
4592 struct recvbuf* rbufp, /* receive packet pointer */
4614 rpkt = &rbufp->recv_pkt;
4621 if (rbufp->dstadr->flags & INT_MCASTOPEN) {
4622 rbufp->dstadr = findinterface(&rbufp->recv_srcadr);
4623 if (NULL == rbufp->dstadr ||
4624 ANY_INTERFACE_CHOOSE(&rbufp->recv_srcadr) /* wildcard */
4625 == rbufp->dstadr) {
4628 stoa(&rbufp->recv_srcadr)));
4758 this_recv_time = rbufp->recv_time;
4763 HTONL_FP(&rbufp->recv_time, &xpkt.rec);
4780 send_via_ntp_signd(rbufp, xmode, xkeyid, flags, &xpkt);
4791 if (rbufp->recv_length == sendlen) {
4792 sendpkt(&rbufp->recv_srcadr, rbufp->dstadr, 0, &xpkt,
4795 current_time, stoa(&rbufp->dstadr->sin),
4796 stoa(&rbufp->recv_srcadr), xmode,
4822 cookie = session_key(&rbufp->recv_srcadr,
4823 &rbufp->dstadr->sin, 0, sys_private, 0);
4824 if ((size_t)rbufp->recv_length > sendlen + MAX_MAC_LEN) {
4825 session_key(&rbufp->dstadr->sin,
4826 &rbufp->recv_srcadr, xkeyid, 0, 2);
4829 sendlen += crypto_xmit(NULL, &xpkt, rbufp,
4833 session_key(&rbufp->dstadr->sin,
4834 &rbufp->recv_srcadr, xkeyid, cookie, 2);
4844 sendpkt(&rbufp->recv_srcadr, rbufp->dstadr, 0, &xpkt, sendlen);
4849 current_time, ntoa(&rbufp->dstadr->sin),
4850 ntoa(&rbufp->recv_srcadr), xmode, xkeyid,