j6: account bytes for ret-classified syscalls

1 files changed, 35 insertions, 0 deletions

diff --git a/integrationtests/retbytes_test.go b/integrationtests/retbytes_test.go
new file mode 100644
index 0000000..2e2ea1d
--- /dev/null
+++ b/integrationtests/retbytes_test.go
@@ -0,0 +1,35 @@
+package integrationtests
+
+import "testing"
+
+func TestRetbytesPhaseA(t *testing.T) {
+	const payloadLen = uint64(18)
+
+	result, _ := runScenarioResult(t, "retbytes-phase-a", []ExpectedEvent{
+		{Tracepoint: "enter_sendto", Comm: "ioworkload", MinCount: 1},
+		{Tracepoint: "enter_recvfrom", Comm: "ioworkload", MinCount: 1},
+		{Tracepoint: "enter_sendmsg", Comm: "ioworkload", MinCount: 1},
+		{Tracepoint: "enter_recvmsg", 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},
+		{Tracepoint: "enter_process_vm_writev", Comm: "ioworkload", MinCount: 1},
+		{Tracepoint: "enter_process_vm_readv", Comm: "ioworkload", MinCount: 1},
+	})
+
+	for _, tracepoint := range []string{
+		"enter_sendto",
+		"enter_recvfrom",
+		"enter_sendmsg",
+		"enter_recvmsg",
+		"enter_sendfile64",
+		"enter_splice",
+		"enter_tee",
+		"enter_process_vm_writev",
+		"enter_process_vm_readv",
+	} {
+		exp := ExpectedEvent{Tracepoint: tracepoint, Comm: "ioworkload"}
+		assertEventBytesAtLeast(t, result, exp, payloadLen)
+		assertEventDurationPositive(t, result, exp)
+	}
+}