From 5c13a7321502c4a5767be17ed48e7cdb576deab3 Mon Sep 17 00:00:00 2001 From: Paul Buetow Date: Mon, 18 May 2026 18:47:02 +0300 Subject: j6: defer mmsg byte classification --- integrationtests/retbytes_test.go | 8 ++++++++ 1 file changed, 8 insertions(+) (limited to 'integrationtests') diff --git a/integrationtests/retbytes_test.go b/integrationtests/retbytes_test.go index 2e2ea1d..c6f06d8 100644 --- a/integrationtests/retbytes_test.go +++ b/integrationtests/retbytes_test.go @@ -10,6 +10,8 @@ func TestRetbytesPhaseA(t *testing.T) { {Tracepoint: "enter_recvfrom", Comm: "ioworkload", MinCount: 1}, {Tracepoint: "enter_sendmsg", Comm: "ioworkload", MinCount: 1}, {Tracepoint: "enter_recvmsg", Comm: "ioworkload", MinCount: 1}, + {Tracepoint: "enter_sendmmsg", Comm: "ioworkload", MinCount: 1}, + {Tracepoint: "enter_recvmmsg", Comm: "ioworkload", MinCount: 1}, {Tracepoint: "enter_sendfile64", Comm: "ioworkload", MinCount: 1}, {Tracepoint: "enter_splice", Comm: "ioworkload", MinCount: 1}, {Tracepoint: "enter_tee", Comm: "ioworkload", MinCount: 1}, @@ -32,4 +34,10 @@ func TestRetbytesPhaseA(t *testing.T) { assertEventBytesAtLeast(t, result, exp, payloadLen) assertEventDurationPositive(t, result, exp) } + + for _, tracepoint := range []string{"enter_sendmmsg", "enter_recvmmsg"} { + exp := ExpectedEvent{Tracepoint: tracepoint, Comm: "ioworkload"} + assertEventBytesEqual(t, result, exp, 0) + assertEventDurationPositive(t, result, exp) + } } -- cgit v1.2.3