aboutgitcodebugslistschat
path: root/udp.c
diff options
context:
space:
mode:
authorDavid Gibson <david@gibson.dropbear.id.au>2023-11-06 13:17:09 +1100
committerStefano Brivio <sbrivio@redhat.com>2023-11-07 09:55:08 +0100
commitde974f0cf13eeaaa5e06b2cf7bebbe59af261e76 (patch)
treef129ce374da210f4aaa1f7662dd695c1880ba198 /udp.c
parent480aa4a10818ee25d739af2f9f156dcbbbcb64dd (diff)
downloadpasst-de974f0cf13eeaaa5e06b2cf7bebbe59af261e76.tar
passt-de974f0cf13eeaaa5e06b2cf7bebbe59af261e76.tar.gz
passt-de974f0cf13eeaaa5e06b2cf7bebbe59af261e76.tar.bz2
passt-de974f0cf13eeaaa5e06b2cf7bebbe59af261e76.tar.lz
passt-de974f0cf13eeaaa5e06b2cf7bebbe59af261e76.tar.xz
passt-de974f0cf13eeaaa5e06b2cf7bebbe59af261e76.tar.zst
passt-de974f0cf13eeaaa5e06b2cf7bebbe59af261e76.zip
udp: Remove socket from udp_{tap,splice}_map when timed out
We save sockets bound to particular ports in udp_{tap,splice}_map for reuse later. If they're not used for a time, we time them out and close them. However, when that happened, we weren't actually removing the fds from the relevant map. That meant that later interactions on the same port could get a stale fd from the map. The stale fd might be closed, leading to unexpected EBADF errors, or it could have been re-used by a completely different socket bound to a different port, which could lead to us incorrectly forwarding packets. Reported-by: Chris Kuhn <kuhnchris@kuhnchris.eu> Reported-by: Jay <bugs.passt.top@bitsbetwixt.com> Link: https://bugs.passt.top/show_bug.cgi?id=57 Signed-off-by: David Gibson <david@gibson.dropbear.id.au> Signed-off-by: Stefano Brivio <sbrivio@redhat.com>
Diffstat (limited to 'udp.c')
-rw-r--r--udp.c12
1 files changed, 7 insertions, 5 deletions
diff --git a/udp.c b/udp.c
index 1b7650d..a13efd2 100644
--- a/udp.c
+++ b/udp.c
@@ -1147,14 +1147,14 @@ static void udp_timer_one(struct ctx *c, int v6, enum udp_act_type type,
{
struct udp_splice_port *sp;
struct udp_tap_port *tp;
- int s = -1;
+ int *sockp = NULL;
switch (type) {
case UDP_ACT_TAP:
tp = &udp_tap_map[v6 ? V6 : V4][port];
if (ts->tv_sec - tp->ts > UDP_CONN_TIMEOUT) {
- s = tp->sock;
+ sockp = &tp->sock;
tp->flags = 0;
}
@@ -1163,21 +1163,23 @@ static void udp_timer_one(struct ctx *c, int v6, enum udp_act_type type,
sp = &udp_splice_init[v6 ? V6 : V4][port];
if (ts->tv_sec - sp->ts > UDP_CONN_TIMEOUT)
- s = sp->sock;
+ sockp = &sp->sock;
break;
case UDP_ACT_SPLICE_NS:
sp = &udp_splice_ns[v6 ? V6 : V4][port];
if (ts->tv_sec - sp->ts > UDP_CONN_TIMEOUT)
- s = sp->sock;
+ sockp = &sp->sock;
break;
default:
return;
}
- if (s >= 0) {
+ if (sockp && *sockp >= 0) {
+ int s = *sockp;
+ *sockp = -1;
epoll_ctl(c->epollfd, EPOLL_CTL_DEL, s, NULL);
close(s);
bitmap_clear(udp_act[v6 ? V6 : V4][type], port);