d7: add POSIX mq syscall kind/classification and coverage

1 files changed, 48 insertions, 1 deletions

diff --git a/integrationtests/ipc_test.go b/integrationtests/ipc_test.go
index b9967b8..007ebc2 100644
--- a/integrationtests/ipc_test.go
+++ b/integrationtests/ipc_test.go
@@ -1,6 +1,11 @@
 package integrationtests
 
-import "testing"
+import (
+	"strings"
+	"testing"
+)
+
+const mqPayloadLen = uint64(14)
 
 func TestPipeBasic(t *testing.T) {
 	result, _ := runScenarioResult(t, "pipe-basic", []ExpectedEvent{
@@ -45,3 +50,45 @@ func TestEventfd2Basic(t *testing.T) {
 	assertTracepointPathPrefix(t, result, "enter_eventfd2", "eventfd:")
 	assertTracepointPathPrefix(t, result, "enter_close", "eventfd:")
 }
+
+func TestPosixMqBasic(t *testing.T) {
+	enableParallelIfRequested(t)
+	h := newTestHarness(t)
+	result, pid, err := h.Run("mq-posix-basic", defaultDuration)
+	if err != nil {
+		errText := err.Error()
+		if strings.Contains(errText, "mq_open: permission denied") ||
+			strings.Contains(errText, "mq_open: operation not permitted") ||
+			strings.Contains(errText, "mq_open: function not implemented") {
+			t.Skipf("mq syscalls unavailable in this environment: %v", err)
+		}
+		t.Fatalf("run scenario mq-posix-basic: %v", err)
+	}
+
+	AssertNoUnexpectedPID(t, result, pid)
+	AssertNoUnexpectedComm(t, result, "ioworkload")
+	AssertEventsPresent(t, result, []ExpectedEvent{
+		{Tracepoint: "enter_mq_open", MinCount: 1},
+		{Tracepoint: "enter_mq_unlink", MinCount: 1},
+		{Tracepoint: "enter_mq_timedsend", MinCount: 1},
+		{Tracepoint: "enter_mq_timedreceive", MinCount: 1},
+		{Tracepoint: "enter_mq_notify", MinCount: 1},
+		{Tracepoint: "enter_mq_getsetattr", MinCount: 1},
+		{Tracepoint: "enter_close", MinCount: 1},
+	})
+
+	assertTracepointPathPrefix(t, result, "enter_mq_open", "/ior-mq-")
+	assertTracepointPathPrefix(t, result, "enter_mq_unlink", "/ior-mq-")
+	assertTracepointPathPrefix(t, result, "enter_mq_timedsend", "/ior-mq-")
+	assertTracepointPathPrefix(t, result, "enter_mq_timedreceive", "/ior-mq-")
+	assertTracepointPathPrefix(t, result, "enter_mq_notify", "/ior-mq-")
+	assertTracepointPathPrefix(t, result, "enter_mq_getsetattr", "/ior-mq-")
+	assertTracepointPathPrefix(t, result, "enter_close", "/ior-mq-")
+
+	sendExp := ExpectedEvent{Tracepoint: "enter_mq_timedsend", Comm: "ioworkload", PathContains: "/ior-mq-"}
+	recvExp := ExpectedEvent{Tracepoint: "enter_mq_timedreceive", Comm: "ioworkload", PathContains: "/ior-mq-"}
+	assertEventBytesAtLeast(t, result, sendExp, mqPayloadLen)
+	assertEventBytesAtLeast(t, result, recvExp, mqPayloadLen)
+	assertEventDurationPositive(t, result, sendExp)
+	assertEventDurationPositive(t, result, recvExp)
+}