* [nft PATCH] mnl: support RLIMIT_NOFILE soft limit > FD_SETSIZE
@ 2026-07-09 16:53 Cory Snider
2026-07-10 11:40 ` Pablo Neira Ayuso
0 siblings, 1 reply; 2+ messages in thread
From: Cory Snider @ 2026-07-09 16:53 UTC (permalink / raw)
To: netfilter-devel; +Cc: Cory Snider
Use poll(2) instead of select(2) to poll the netlink socket so processes
which raise their file descriptor soft limit beyond FD_SETSIZE can use
libnftables without risk of the process aborting when too many files are
open.
Signed-off-by: Cory Snider <csnider@mirantis.com>
---
The use of select(2) is preventing us from integrating libnftables into
Docker as its RLIMIT_NOFILE soft limit is raised to the hard limit.
See also https://github.com/moby/moby/issues/52873.
src/mnl.c | 39 ++++++++++++++++++++-------------------
1 file changed, 20 insertions(+), 19 deletions(-)
diff --git a/src/mnl.c b/src/mnl.c
index b9efd3cf..d9abbb72 100644
--- a/src/mnl.c
+++ b/src/mnl.c
@@ -34,6 +34,7 @@
#include <intervals.h>
#include <net/if.h>
#include <sys/socket.h>
+#include <poll.h>
#include <arpa/inet.h>
#include <fcntl.h>
#include <errno.h>
@@ -406,14 +407,13 @@ int mnl_batch_talk(struct netlink_ctx *ctx, struct list_head *err_list,
const struct sockaddr_nl snl = {
.nl_family = AF_NETLINK
};
- struct timeval tv = {
- .tv_sec = 0,
- .tv_usec = 0
- };
struct iovec iov[iov_len];
struct msghdr msg = {};
unsigned int rcvbufsiz;
- fd_set readfds;
+ struct pollfd pfd = {
+ .fd = fd,
+ .events = POLLIN,
+ };
static mnl_cb_t cb_ctl_array[NLMSG_MIN_TYPE] = {
[NLMSG_ERROR] = mnl_batch_extack_cb,
};
@@ -440,14 +440,11 @@ int mnl_batch_talk(struct netlink_ctx *ctx, struct list_head *err_list,
/* receive and digest all the acknowledgments from the kernel. */
while (true) {
- FD_ZERO(&readfds);
- FD_SET(fd, &readfds);
-
- ret = select(fd + 1, &readfds, NULL, NULL, &tv);
+ ret = poll(&pfd, 1, 0);
if (ret == -1)
return -1;
- if (!FD_ISSET(fd, &readfds))
+ if (ret == 0)
break;
ret = mnl_socket_recvfrom(nl, rcv_buf, sizeof(rcv_buf));
@@ -2436,7 +2433,16 @@ int mnl_nft_event_listener(struct mnl_socket *nf_sock, unsigned int debug_mask,
int fd = mnl_socket_get_fd(nf_sock);
char buf[NFT_NLMSG_MAXSIZE];
int sigfd = get_signalfd();
- fd_set readfds;
+ struct pollfd pfd[2] = {
+ {
+ .fd = fd,
+ .events = POLLIN,
+ },
+ {
+ .fd = sigfd,
+ .events = POLLIN,
+ },
+ };
int ret;
ret = mnl_set_rcvbuffer(nf_sock, bufsiz);
@@ -2445,19 +2451,14 @@ int mnl_nft_event_listener(struct mnl_socket *nf_sock, unsigned int debug_mask,
NFTABLES_NLEVENT_BUFSIZ, bufsiz);
while (1) {
- FD_ZERO(&readfds);
- FD_SET(fd, &readfds);
- if (sigfd != -1)
- FD_SET(sigfd, &readfds);
-
- ret = select(max(fd, sigfd) + 1, &readfds, NULL, NULL, NULL);
+ ret = poll(pfd, array_size(pfd), -1);
if (ret < 0)
return -1;
- if (sigfd >= 0 && FD_ISSET(sigfd, &readfds))
+ if (sigfd >= 0 && (pfd[1].revents & POLLIN))
check_signalfd(sigfd);
- if (FD_ISSET(fd, &readfds)) {
+ if (pfd[0].revents & POLLIN) {
ret = mnl_socket_recvfrom(nf_sock, buf, sizeof(buf));
if (ret < 0) {
if (errno == ENOBUFS) {
--
2.47.0
^ permalink raw reply related [flat|nested] 2+ messages in thread
* Re: [nft PATCH] mnl: support RLIMIT_NOFILE soft limit > FD_SETSIZE
2026-07-09 16:53 [nft PATCH] mnl: support RLIMIT_NOFILE soft limit > FD_SETSIZE Cory Snider
@ 2026-07-10 11:40 ` Pablo Neira Ayuso
0 siblings, 0 replies; 2+ messages in thread
From: Pablo Neira Ayuso @ 2026-07-10 11:40 UTC (permalink / raw)
To: Cory Snider; +Cc: netfilter-devel
On Thu, Jul 09, 2026 at 12:53:13PM -0400, Cory Snider wrote:
> Use poll(2) instead of select(2) to poll the netlink socket so processes
> which raise their file descriptor soft limit beyond FD_SETSIZE can use
> libnftables without risk of the process aborting when too many files are
> open.
Applied, thanks.
^ permalink raw reply [flat|nested] 2+ messages in thread
end of thread, other threads:[~2026-07-10 11:40 UTC | newest]
Thread overview: 2+ messages (download: mbox.gz follow: Atom feed
-- links below jump to the message on this page --
2026-07-09 16:53 [nft PATCH] mnl: support RLIMIT_NOFILE soft limit > FD_SETSIZE Cory Snider
2026-07-10 11:40 ` Pablo Neira Ayuso
This is an external index of several public inboxes,
see mirroring instructions on how to clone and mirror
all data and code used by this external index.