aboutsummaryrefslogtreecommitdiffstats
diff options
context:
space:
mode:
authorGeliang Tang <geliang.tang@suse.com>2023-09-21 11:45:38 +0800
committerGeliang Tang <tanggeliang@kylinos.cn>2024-04-22 10:56:55 +0800
commit043030da965d152f50ead9452f202c3807c439c4 (patch)
treedb75773b5419118275916d42470417de10c20e74
parente1cc8ee71fb7b5c0a484f2896dcd275c99b9350a (diff)
downloadmptcp_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.c5
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;