ntp/ntpd/ntp_io.c

396 collect_timing(struct recvbuf *rb, const char *tag, int count, l_fp *dts)
401 		 (rb != NULL)
402 		     ? ((rb->dstadr != NULL)
403 			    ? stoa(&rb->recv_srcadr)
3224 	struct recvbuf *	rb;
3226 	rb = get_free_recv_buffer();
3228 	if (NULL == rb) {
3242 	if (rp->datalen <= 0 || (size_t)rp->datalen > sizeof(rb->recv_space))
3243 		read_count = sizeof(rb->recv_space);
3247 		buflen = read(fd, (char *)&rb->recv_space, read_count);
3252 		freerecvbuf(rb);
3261 	rb->recv_length = buflen;
3262 	rb->recv_peer = rp->srcclock;
3263 	rb->dstadr = 0;
3264 	rb->fd = fd;
3265 	rb->recv_time = ts;
3266 	rb->receiver = rp->clock_recv;
3268 	consumed = indicate_refclock_packet(rp, rb);
3285 	struct recvbuf *	rb,
3378 			collect_timing(rb, "input processing delay", 1,
3412 	register struct recvbuf *rb;
3426 	rb = get_free_recv_buffer();
3427 	if (NULL == rb || itf->ignore_packets) {
3431 		if (rb != NULL)
3432 			freerecvbuf(rb);
3449 	fromlen = sizeof(rb->recv_srcadr);
3452 	rb->recv_length = recvfrom(fd, (char *)&rb->recv_space,
3453 				   sizeof(rb->recv_space), 0,
3454 				   &rb->recv_srcadr.sa, &fromlen);
3456 	iovec.iov_base        = &rb->recv_space;
3457 	iovec.iov_len         = sizeof(rb->recv_space);
3458 	msghdr.msg_name       = &rb->recv_srcadr;
3465 	rb->recv_length       = recvmsg(fd, &msghdr, 0);
3468 	buflen = rb->recv_length;
3476 		freerecvbuf(rb);
3480 			stoa(&rb->recv_srcadr), fd);
3483 		freerecvbuf(rb);
3488 		    fd, buflen, stoa(&rb->recv_srcadr)));
3491 	if (ISREFCLOCKADR(&rb->recv_srcadr)) {
3493 			stoa(&rb->recv_srcadr), fd);
3497 		freerecvbuf(rb);
3508 			stoa(&rb->recv_srcadr),
3509 			IN6_IS_ADDR_LOOPBACK(PSOCK_ADDR6(&rb->recv_srcadr)),
3514 		if (   IN6_IS_ADDR_LOOPBACK(PSOCK_ADDR6(&rb->recv_srcadr))
3519 			freerecvbuf(rb);
3529 	rb->dstadr = itf;
3530 	rb->fd = fd;
3533 	ts = fetch_timestamp(rb, &msghdr, ts);
3535 	rb->recv_time = ts;
3536 	rb->receiver = receive;
3538 	add_full_recv_buffer(rb);