recvmmsg(2) System Calls Manual recvmmsg(2) recvmmsg - (libc -lc) #define _GNU_SOURCE /* feature_test_macros(7) */ #include int recvmmsg(unsigned int n; int sockfd, struct mmsghdr msgvec[n], unsigned int n, int flags, struct timespec *timeout); recvmmsg() recvmsg(2) . ( .) recvmsg(2) . sockfd . msgvec mmsghdr. n. mmsghdr : struct mmsghdr { struct msghdr msg_hdr; /* Message header */ unsigned int msg_len; /* Number of received bytes for header */ }; msg_hdr msghdr recvmsg(2). msg_len . recvmsg(2) . flags OR. recvmsg(2) : MSG_WAITFORONE ( 2.6.34) MSG_DONTWAIT . timeout struct timespec ( clock_gettime(2)) ( ) ( !). ( .) timeout NULL . recvmmsg() n . ( n) . recvmmsg() msgvec : msg_len msg_hdr recvmsg(2). msgvec . recvmmsg() msgvec -1 errno . recvmsg(2). : EINVAL timeout . . . 2.6.33 glibc 2.12. timeout . n-1 . . recvmmsg(). ICMP . recvmmsg() . . UDP : $ while true; do echo $RANDOM > /dev/udp/127.0.0.1/1234; sleep 0.25; done : $ ./a.out 5 messages received 1 11782 2 11345 3 304 4 13514 5 28421 #define _GNU_SOURCE #include #include #include #include #include #include #include int main(void) { #define VLEN 10 #define BUFSIZE 200 #define TIMEOUT 1 int sockfd, retval; char bufs[VLEN][BUFSIZE+1]; struct iovec iovecs[VLEN]; struct mmsghdr msgs[VLEN]; struct timespec timeout; struct sockaddr_in addr; sockfd = socket(AF_INET, SOCK_DGRAM, 0); if (sockfd == -1) { perror("socket()"); exit(EXIT_FAILURE); } addr.sin_family = AF_INET; addr.sin_addr.s_addr = htonl(INADDR_LOOPBACK); addr.sin_port = htons(1234); if (bind(sockfd, (struct sockaddr *) &addr, sizeof(addr)) == -1) { perror("bind()"); exit(EXIT_FAILURE); } memset(msgs, 0, sizeof(msgs)); for (size_t i = 0; i < VLEN; i++) { iovecs[i].iov_base = bufs[i]; iovecs[i].iov_len = BUFSIZE; msgs[i].msg_hdr.msg_iov = &iovecs[i]; msgs[i].msg_hdr.msg_iovlen = 1; } timeout.tv_sec = TIMEOUT; timeout.tv_nsec = 0; retval = recvmmsg(sockfd, msgs, VLEN, 0, &timeout); if (retval == -1) { perror("recvmmsg()"); exit(EXIT_FAILURE); } printf("%d messages received\n", retval); for (size_t i = 0; i < retval; i++) { bufs[i][msgs[i].msg_len] = 0; printf("%zu %s", i+1, bufs[i]); } exit(EXIT_SUCCESS); } clock_gettime(2), recvmsg(2), sendmmsg(2), sendmsg(2), socket(2), socket(7) 3 . . : . 6.18 8 2026 recvmmsg(2)