aboutgitcodebugslistschat
path: root/tcp_splice.c
diff options
context:
space:
mode:
authorDavid Gibson <david@gibson.dropbear.id.au>2024-01-16 11:50:33 +1100
committerStefano Brivio <sbrivio@redhat.com>2024-01-22 23:35:13 +0100
commiteebca1115fbdb0fc72af713171434b0adbf4e87b (patch)
tree7b7e4c7424eb46c21ceb6200f13de6d1d5e1d563 /tcp_splice.c
parent8563e7c870e139baf14ef00b26cdc7db4884246c (diff)
downloadpasst-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.c7
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;