j6: defer mmsg byte classification

1 files changed, 8 insertions, 0 deletions

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)
+	}
 }