diff options
author | Geliang Tang <geliang.tang@suse.com> | 2023-09-21 11:45:38 +0800 |
---|---|---|
committer | Geliang Tang <tanggeliang@kylinos.cn> | 2024-04-22 10:56:55 +0800 |
commit | 043030da965d152f50ead9452f202c3807c439c4 (patch) | |
tree | db75773b5419118275916d42470417de10c20e74 | |
parent | e1cc8ee71fb7b5c0a484f2896dcd275c99b9350a (diff) | |
download | mptcp_net-next-043030da965d152f50ead9452f202c3807c439c4.tar.gz |
Squash to "selftests/bpf: Add bpf_burst scheduler"
Use bpf_mptcp_wnd_end and bpf_mptcp_snd_nxt.
Signed-off-by: Geliang Tang <geliang.tang@suse.com>
-rw-r--r-- | tools/testing/selftests/bpf/progs/mptcp_bpf_burst.c | 5 |
1 files changed, 3 insertions, 2 deletions
diff --git a/tools/testing/selftests/bpf/progs/mptcp_bpf_burst.c b/tools/testing/selftests/bpf/progs/mptcp_bpf_burst.c index b3c8115648667..c37713bd019ba 100644 --- a/tools/testing/selftests/bpf/progs/mptcp_bpf_burst.c +++ b/tools/testing/selftests/bpf/progs/mptcp_bpf_burst.c @@ -16,7 +16,8 @@ struct subflow_send_info { extern bool mptcp_subflow_active(struct mptcp_subflow_context *subflow) __ksym; extern void mptcp_set_timeout(struct sock *sk) __ksym; -extern __u64 mptcp_wnd_end(const struct mptcp_sock *msk) __ksym; +extern __u64 bpf_mptcp_wnd_end(const struct mptcp_sock *msk) __ksym; +extern __u64 bpf_mptcp_snd_nxt(const struct mptcp_sock *msk) __ksym; extern bool tcp_stream_memory_free(const struct sock *sk, int wake) __ksym; extern bool bpf_mptcp_subflow_queues_empty(struct sock *sk) __ksym; extern void mptcp_pm_subflow_chk_stale(const struct mptcp_sock *msk, struct sock *ssk) __ksym; @@ -119,7 +120,7 @@ static int bpf_burst_get_send(struct mptcp_sock *msk, if (!ssk || !sk_stream_memory_free(ssk)) return -1; - burst = min(MPTCP_SEND_BURST_SIZE, mptcp_wnd_end(msk) - msk->snd_nxt); + burst = min(MPTCP_SEND_BURST_SIZE, bpf_mptcp_wnd_end(msk) - bpf_mptcp_snd_nxt(msk)); wmem = ssk->sk_wmem_queued; if (!burst) goto out; |