public inbox for passt-dev@passt.top
 help / color / mirror / code / Atom feed
From: Stefano Brivio <sbrivio@redhat.com>
To: Yumei Huang <yuhuang@redhat.com>
Cc: passt-dev@passt.top, david@gibson.dropbear.id.au
Subject: Re: [PATCH] udp: Split activity timeouts for UDP flows
Date: Fri, 13 Feb 2026 08:08:44 +0100 (CET)	[thread overview]
Message-ID: <20260213080843.5186d859@elisabeth> (raw)
In-Reply-To: <CANsz47mGXDgJSKpLqFiW_n5bXW13ZiayC_xhBEEGeBJTZwN5Xw@mail.gmail.com>

On Fri, 13 Feb 2026 14:45:24 +0800
Yumei Huang <yuhuang@redhat.com> wrote:

> On Fri, Feb 13, 2026 at 5:51 AM Stefano Brivio <sbrivio@redhat.com> wrote:
> 
> > Oops, I missed one point at a first review, and also during a quick
> > test.
> >
> > I just tried outbound DNS queries in pasta with single responses, not
> > inbound traffic or passt in vhost-user mode. Then I realised
> > that:
> >
> > On Thu, 12 Feb 2026 16:04:14 +0800
> > Yumei Huang <yuhuang@redhat.com> wrote:
> >  
> > > [...]
> > > @@ -954,6 +964,7 @@ void udp_sock_handler(const struct ctx *c, union  
> > epoll_ref ref,  
> > >
> > >               flow_trace(uflow, "Received data on reply socket");
> > >               uflow->ts = now->tv_sec;
> > > +             udp_flow_activity(uflow, !tosidx.sidei);  
> >
> > ...this only covers three of the four paths we need to act upon:
> >
> > 1. inbound datagrams received on the reply socket via
> >    udp_buf_sock_to_tap(), called from here
> >
> > 2. inbound datagrams received on the reply socket in passt's vhost-user
> >    mode, that's udp_vu_sock_recv(), also called from here
> >
> > 3. "spliced" sockets (that's not really the case for UDP, we can't call
> >    splice(), but a pair of recvmmsg() / sendmmsg()), that is, loopback
> >    UDP traffic, handled by udp_sock_to_sock(), called from here as well
> >
> > but not:
> >
> > 4. outbound, non-spliced datagrams from container/guest: that's
> >    udp_tap_handler(), in both vhost-user and non-vhost-user cases, or
> >    udp_flow_from_tap() in udp_flow.c.
> >
> >    I guess we want to take care of this directly from udp_flow_from_tap(),
> >    for consistency, because that's also where we update the timestamp
> >    value:
> >
> >         sidx = flow_lookup_sa(c, IPPROTO_UDP, pif, s_in, dst, port);
> >         if ((uflow = udp_at_sidx(sidx))) {
> >                 uflow->ts = now->tv_sec;
> >
> >                 ^^^ here
> >
> >                 return flow_sidx_opposite(sidx);
> >         }
> >
> > I haven't really tested this side of it but it should be fairly easy
> > with socat and a UDP "server" inside pasta or a guest.
> 
> Somehow, it worked well in my tests with pasta, it looks like the if
> condition always returns false.

Hmm, weird, it should return false only for the first *inbound* datagram
of a UDP flow.

> But now when I test with passt, it becomes
> an issue and we need to track the activity here as you mentioned.
> 
> Besides, I also noticed we update the timestamp value in
> udp_flow_from_sock() as well. I feel we should call udp_flow_activity()
> there too,  but couldn't come up with a test to prove it.

I haven't really checked, but udp_sock_handler() should anyway be
called for the datagram triggering udp_flow_from_sock(), so I don't
think you need an extra call to udp_flow_activity() there.

But you should check that with a pair of debugging prints, I guess.

> On top of it,  I just found two other issues.
> 1. in udp_flow_new(),  we should initialize uflow->activity[INISIDE] to 1
> instead of 0. Otherwise, we fail to track the first datagram.

Same here, I *thought* that calling udp_flow_activity() from
udp_sock_handler() *and* udp_tap_handler() would anyway account for the
first datagram, but I didn't check.

> 2. I guess we need to add the profs entries (nf_conntrack_udp_timeout
> and nf_conntrack_udp_timeout_stream) to apparmor like the tcp ones in
> https://passt.top/passt/commit/?id=2aa63237109b97a55c85e4c86c72db0d055bfe7a.
> I don't have an environment to test it now. Maybe I can set up a debian vm
> later.

Ah, right, good catch. The rules are quite obvious, so you can just add
them to the patch, and I'll test them later on Debian anyway.

-- 
Stefano


  parent reply	other threads:[~2026-02-13  7:08 UTC|newest]

Thread overview: 11+ messages / expand[flat|nested]  mbox.gz  Atom feed  top
2026-02-12  8:04 Yumei Huang
2026-02-12  8:59 ` Stefano Brivio
2026-02-12 21:51 ` Stefano Brivio
     [not found]   ` <CANsz47mGXDgJSKpLqFiW_n5bXW13ZiayC_xhBEEGeBJTZwN5Xw@mail.gmail.com>
2026-02-13  7:08     ` Stefano Brivio [this message]
     [not found]       ` <CANsz47m8BPdUK2N-_Ka5GUHP_USnyHgO01Accktf-wxuX5rxDw@mail.gmail.com>
2026-02-13  9:12         ` Stefano Brivio
2026-02-13  9:54           ` Yumei Huang
2026-02-13 10:00             ` Stefano Brivio
2026-02-13 10:04               ` Yumei Huang
2026-02-13 10:17                 ` Stefano Brivio
2026-02-14  7:20                   ` Yumei Huang
2026-02-14  9:15                     ` Stefano Brivio

Reply instructions:

You may reply publicly to this message via plain-text email
using any one of the following methods:

* Save the following mbox file, import it into your mail client,
  and reply-to-all from there: mbox

  Avoid top-posting and favor interleaved quoting:
  https://en.wikipedia.org/wiki/Posting_style#Interleaved_style

* Reply using the --to, --cc, and --in-reply-to
  switches of git-send-email(1):

  git send-email \
    --in-reply-to=20260213080843.5186d859@elisabeth \
    --to=sbrivio@redhat.com \
    --cc=david@gibson.dropbear.id.au \
    --cc=passt-dev@passt.top \
    --cc=yuhuang@redhat.com \
    /path/to/YOUR_REPLY

  https://kernel.org/pub/software/scm/git/docs/git-send-email.html

* If your mail client supports setting the In-Reply-To header
  via mailto: links, try the mailto: link
Be sure your reply has a Subject: header at the top and a blank line before the message body.
Code repositories for project(s) associated with this public inbox

	https://passt.top/passt

This is a public inbox, see mirroring instructions
for how to clone and mirror all data and code used for this inbox;
as well as URLs for IMAP folder(s).