diff options
| author | David Gibson <david@gibson.dropbear.id.au> | 2024-09-06 15:17:06 +1000 |
|---|---|---|
| committer | Stefano Brivio <sbrivio@redhat.com> | 2024-09-06 12:53:24 +0200 |
| commit | 1166401c2f2b97961bdc285b336eed912b4f8bb1 (patch) | |
| tree | 095cb89dbc43bcbb9680ec7a7fd85bfff0dffc32 /udp_flow.h | |
| parent | 7ad9f9bd2bbda8d705e0c6faf5acf2792fce063c (diff) | |
| download | passt-1166401c2f2b97961bdc285b336eed912b4f8bb1.tar passt-1166401c2f2b97961bdc285b336eed912b4f8bb1.tar.gz passt-1166401c2f2b97961bdc285b336eed912b4f8bb1.tar.bz2 passt-1166401c2f2b97961bdc285b336eed912b4f8bb1.tar.lz passt-1166401c2f2b97961bdc285b336eed912b4f8bb1.tar.xz passt-1166401c2f2b97961bdc285b336eed912b4f8bb1.tar.zst passt-1166401c2f2b97961bdc285b336eed912b4f8bb1.zip | |
udp: Allow UDP flows to be prematurely closed
Unlike TCP, UDP has no in-band signalling for the end of a flow. So the
only way we remove flows is on a timer if they have no activity for 180s.
However, we've started to investigate some error conditions in which we
want to prematurely abort / abandon a UDP flow. We can call
udp_flow_close(), which will make the flow inert (sockets closed, no epoll
events, can't be looked up in hash). However it will still wait 3 minutes
to clear away the stale entry.
Clean this up by adding an explicit 'closed' flag which will cause a flow
to be more promptly cleaned up. We also publish udp_flow_close() so it
can be called from other places to abort UDP flows().
Signed-off-by: David Gibson <david@gibson.dropbear.id.au>
Signed-off-by: Stefano Brivio <sbrivio@redhat.com>
Diffstat (limited to 'udp_flow.h')
| -rw-r--r-- | udp_flow.h | 4 |
1 files changed, 4 insertions, 0 deletions
@@ -10,6 +10,7 @@ /** * struct udp - Descriptor for a flow of UDP packets * @f: Generic flow information + * @closed: Flow is already closed * @ts: Activity timestamp * @s: Socket fd (or -1) for each side of the flow */ @@ -17,6 +18,7 @@ struct udp_flow { /* Must be first element */ struct flow_common f; + bool closed :1; time_t ts; int s[SIDES]; }; @@ -30,6 +32,8 @@ flow_sidx_t udp_flow_from_tap(const struct ctx *c, const void *saddr, const void *daddr, in_port_t srcport, in_port_t dstport, const struct timespec *now); +void udp_flow_close(const struct ctx *c, struct udp_flow *uflow); +bool udp_flow_defer(const struct udp_flow *uflow); bool udp_flow_timer(const struct ctx *c, struct udp_flow *uflow, const struct timespec *now); |