diff options
author | David Gibson <david@gibson.dropbear.id.au> | 2024-01-16 11:50:36 +1100 |
---|---|---|
committer | Stefano Brivio <sbrivio@redhat.com> | 2024-01-22 23:35:19 +0100 |
commit | 36dfa8b8fb62c0eb9ff4c2c5127e29525035e325 (patch) | |
tree | ca6729d3a422f624fe45f1fa2764cffe624f908f /flow.h | |
parent | b43e4483ed4888e1ab0c5195fa3f61bb24bde904 (diff) | |
download | passt-36dfa8b8fb62c0eb9ff4c2c5127e29525035e325.tar passt-36dfa8b8fb62c0eb9ff4c2c5127e29525035e325.tar.gz passt-36dfa8b8fb62c0eb9ff4c2c5127e29525035e325.tar.bz2 passt-36dfa8b8fb62c0eb9ff4c2c5127e29525035e325.tar.lz passt-36dfa8b8fb62c0eb9ff4c2c5127e29525035e325.tar.xz passt-36dfa8b8fb62c0eb9ff4c2c5127e29525035e325.tar.zst passt-36dfa8b8fb62c0eb9ff4c2c5127e29525035e325.zip |
flow, tcp: Add handling for per-flow timers
tcp_timer() scans the flow table so that it can run tcp_splice_timer() on
each spliced connection. More generally, other flow types might want to
run similar timers in future.
We could add a flow_timer() analagous to tcp_timer(), udp_timer() etc.
However, this would need to scan the flow table, which we would have just
done in flow_defer_handler(). We'd prefer to just scan the flow table
once, dispatching both per-flow deferred events and per-flow timed events
if necessary.
So, extend flow_defer_handler() to do this. For now we use the same timer
interval for all flow types (1s). We can make that more flexible in future
if we need to.
Signed-off-by: David Gibson <david@gibson.dropbear.id.au>
Signed-off-by: Stefano Brivio <sbrivio@redhat.com>
Diffstat (limited to 'flow.h')
-rw-r--r-- | flow.h | 4 |
1 files changed, 3 insertions, 1 deletions
@@ -7,6 +7,8 @@ #ifndef FLOW_H #define FLOW_H +#define FLOW_TIMER_INTERVAL 1000 /* ms */ + /** * enum flow_type - Different types of packet flows we track */ @@ -67,7 +69,7 @@ static inline bool flow_sidx_eq(flow_sidx_t a, flow_sidx_t b) union flow; void flow_table_compact(struct ctx *c, union flow *hole); -void flow_defer_handler(struct ctx *c); +void flow_defer_handler(struct ctx *c, const struct timespec *now); void flow_log_(const struct flow_common *f, int pri, const char *fmt, ...) __attribute__((format(printf, 3, 4))); |