Lines Matching refs:rb

396 collect_timing(struct recvbuf *rb, const char *tag, int count, l_fp *dts)  in collect_timing()  argument
401 (rb != NULL) in collect_timing()
402 ? ((rb->dstadr != NULL) in collect_timing()
403 ? stoa(&rb->recv_srcadr) in collect_timing()
3293 struct recvbuf * rb; local
3295 rb = get_free_recv_buffer(TRUE);
3297 if (NULL == rb) {
3316 if (rp->datalen <= 0 || (size_t)rp->datalen > sizeof(rb->recv_space))
3317 read_count = sizeof(rb->recv_space);
3321 buflen = read(fd, (char *)&rb->recv_space, read_count);
3326 freerecvbuf(rb);
3335 rb->recv_length = buflen;
3336 rb->recv_peer = rp->srcclock;
3337 rb->dstadr = 0;
3338 rb->fd = fd;
3339 rb->recv_time = ts;
3340 rb->receiver = rp->clock_recv;
3342 consumed = indicate_refclock_packet(rp, rb);
3359 struct recvbuf * rb, argument
3452 collect_timing(rb, "input processing delay", 1,
3486 register struct recvbuf *rb; local
3499 rb = itf->ignore_packets ? NULL : get_free_recv_buffer(FALSE);
3500 if (NULL == rb) {
3508 if (rb != NULL)
3509 freerecvbuf(rb);
3526 fromlen = sizeof(rb->recv_srcadr);
3529 rb->recv_length = recvfrom(fd, (char *)&rb->recv_space,
3530 sizeof(rb->recv_space), 0,
3531 &rb->recv_srcadr.sa, &fromlen);
3533 iovec.iov_base = &rb->recv_space;
3534 iovec.iov_len = sizeof(rb->recv_space);
3535 msghdr.msg_name = &rb->recv_srcadr;
3542 rb->recv_length = recvmsg(fd, &msghdr, 0);
3545 buflen = rb->recv_length;
3553 freerecvbuf(rb);
3557 stoa(&rb->recv_srcadr), fd);
3560 freerecvbuf(rb);
3565 fd, buflen, stoa(&rb->recv_srcadr)));
3568 if (ISREFCLOCKADR(&rb->recv_srcadr)) {
3570 stoa(&rb->recv_srcadr), fd);
3574 freerecvbuf(rb);
3585 stoa(&rb->recv_srcadr),
3586 IN6_IS_ADDR_LOOPBACK(PSOCK_ADDR6(&rb->recv_srcadr)),
3591 if ( IN6_IS_ADDR_LOOPBACK(PSOCK_ADDR6(&rb->recv_srcadr))
3596 freerecvbuf(rb);
3606 rb->dstadr = itf;
3607 rb->fd = fd;
3610 ts = fetch_timestamp(rb, &msghdr, ts);
3612 rb->recv_time = ts;
3613 rb->receiver = receive;
3615 add_full_recv_buffer(rb);