diff options
author | David Gibson <david@gibson.dropbear.id.au> | 2024-01-16 11:50:33 +1100 |
---|---|---|
committer | Stefano Brivio <sbrivio@redhat.com> | 2024-01-22 23:35:13 +0100 |
commit | eebca1115fbdb0fc72af713171434b0adbf4e87b (patch) | |
tree | 7b7e4c7424eb46c21ceb6200f13de6d1d5e1d563 /tcp_splice.c | |
parent | 8563e7c870e139baf14ef00b26cdc7db4884246c (diff) | |
download | passt-eebca1115fbdb0fc72af713171434b0adbf4e87b.tar passt-eebca1115fbdb0fc72af713171434b0adbf4e87b.tar.gz passt-eebca1115fbdb0fc72af713171434b0adbf4e87b.tar.bz2 passt-eebca1115fbdb0fc72af713171434b0adbf4e87b.tar.lz passt-eebca1115fbdb0fc72af713171434b0adbf4e87b.tar.xz passt-eebca1115fbdb0fc72af713171434b0adbf4e87b.tar.zst passt-eebca1115fbdb0fc72af713171434b0adbf4e87b.zip |
tcp, tcp_splice: Remove redundant handling from tcp_timer()
tcp_timer() scans the connection table, expiring "tap" connections and
calling tcp_splice_timer() for "splice" connections. tcp_splice_timer()
expires spliced connections and then does some other processing.
However, tcp_timer() is always called shortly after tcp_defer_handler()
(from post_handler()), which also scans the flow table expiring both tap
and spliced connections. So remove the redundant handling, and only do
the extra tcp_splice_timer() work from tcp_timer().
Signed-off-by: David Gibson <david@gibson.dropbear.id.au>
Signed-off-by: Stefano Brivio <sbrivio@redhat.com>
Diffstat (limited to 'tcp_splice.c')
-rw-r--r-- | tcp_splice.c | 7 |
1 files changed, 2 insertions, 5 deletions
diff --git a/tcp_splice.c b/tcp_splice.c index a91cb37..a187136 100644 --- a/tcp_splice.c +++ b/tcp_splice.c @@ -755,15 +755,12 @@ void tcp_splice_init(struct ctx *c) * @c: Execution context * @flow: Flow table entry */ -void tcp_splice_timer(struct ctx *c, union flow *flow) +void tcp_splice_timer(const struct ctx *c, union flow *flow) { struct tcp_splice_conn *conn = &flow->tcp_splice; int side; - if (conn->flags & CLOSING) { - tcp_splice_destroy(c, flow); - return; - } + ASSERT(!(conn->flags & CLOSING)); for (side = 0; side < SIDES; side++) { uint8_t set = side == 0 ? RCVLOWAT_SET_0 : RCVLOWAT_SET_1; |