Lines Matching refs:mmsg
362 struct mmsghdr mmsg[MMSG_NUM]; in recvmmsg_packets() local
379 memset(&mmsg, 0, sizeof(mmsg)); in recvmmsg_packets()
383 mmsg[i].msg_hdr.msg_iov = &msg_iov[i]; in recvmmsg_packets()
384 mmsg[i].msg_hdr.msg_iovlen = 1; in recvmmsg_packets()
385 mmsg[i].msg_hdr.msg_name = &remote_addr[i]; in recvmmsg_packets()
386 mmsg[i].msg_hdr.msg_namelen = sizeof(remote_addr[i]); in recvmmsg_packets()
387 mmsg[i].msg_hdr.msg_control = &msg_ctrl[i]; in recvmmsg_packets()
388 mmsg[i].msg_hdr.msg_controllen = CMSG_SPACE(sizeof(uint16_t)); in recvmmsg_packets()
391 while((mcount = recvmmsg(qctx->sockfd, mmsg, n, 0, NULL)) == -1 && in recvmmsg_packets()
416 total_nread += mmsg[i].msg_len; in recvmmsg_packets()
418 gso_size = msghdr_get_udp_gro(&mmsg[i].msg_hdr); in recvmmsg_packets()
420 gso_size = mmsg[i].msg_len; in recvmmsg_packets()
423 for(offset = 0; offset < mmsg[i].msg_len; offset = to) { in recvmmsg_packets()
427 if(to > mmsg[i].msg_len) { in recvmmsg_packets()
428 pktlen = mmsg[i].msg_len - offset; in recvmmsg_packets()
434 result = recv_cb(bufs[i] + offset, pktlen, mmsg[i].msg_hdr.msg_name, in recvmmsg_packets()
435 mmsg[i].msg_hdr.msg_namelen, 0, userp); in recvmmsg_packets()