summaryrefslogtreecommitdiff
path: root/internal/eventloop_sleep_test.go
diff options
context:
space:
mode:
Diffstat (limited to 'internal/eventloop_sleep_test.go')
-rw-r--r--internal/eventloop_sleep_test.go76
1 files changed, 76 insertions, 0 deletions
diff --git a/internal/eventloop_sleep_test.go b/internal/eventloop_sleep_test.go
new file mode 100644
index 0000000..2edf276
--- /dev/null
+++ b/internal/eventloop_sleep_test.go
@@ -0,0 +1,76 @@
+package internal
+
+import (
+ "testing"
+
+ "ior/internal/event"
+ "ior/internal/globalfilter"
+ "ior/internal/types"
+)
+
+func TestHandleSleepExitCarriesCommAndAppliesFilter(t *testing.T) {
+ t.Run("accepted", func(t *testing.T) {
+ el := mustNewEventLoop(t, eventLoopConfig{})
+ enter := &types.SleepEvent{
+ EventType: types.ENTER_SLEEP_EVENT,
+ TraceId: types.SYS_ENTER_NANOSLEEP,
+ Time: 100,
+ Pid: 10,
+ Tid: 11,
+ RequestedNs: 2_000_000,
+ }
+ exit := &types.RetEvent{
+ EventType: types.EXIT_RET_EVENT,
+ TraceId: types.SYS_EXIT_NANOSLEEP,
+ Time: 120,
+ Ret: 0,
+ Pid: 10,
+ Tid: 11,
+ }
+ ep := &event.Pair{EnterEv: enter, ExitEv: exit}
+
+ if ok := el.handleSleepExit(ep, enter); !ok {
+ t.Fatal("handleSleepExit returned false")
+ }
+ if ep.Comm != "" {
+ t.Fatalf("expected empty comm for unresolved tid, got %q", ep.Comm)
+ }
+ })
+
+ t.Run("filtered", func(t *testing.T) {
+ el := mustNewEventLoop(t, eventLoopConfig{
+ filter: globalfilter.Filter{
+ Syscall: &globalfilter.StringFilter{Pattern: "openat"},
+ },
+ })
+ enter := &types.SleepEvent{
+ EventType: types.ENTER_SLEEP_EVENT,
+ TraceId: types.SYS_ENTER_CLOCK_NANOSLEEP,
+ Time: 100,
+ Pid: 10,
+ Tid: 11,
+ RequestedNs: 3_000_000,
+ }
+ exit := &types.RetEvent{
+ EventType: types.EXIT_RET_EVENT,
+ TraceId: types.SYS_EXIT_CLOCK_NANOSLEEP,
+ Time: 120,
+ Ret: 0,
+ Pid: 10,
+ Tid: 11,
+ }
+ ep := &event.Pair{EnterEv: enter, ExitEv: exit}
+
+ if ok := el.handleSleepExit(ep, enter); ok {
+ t.Fatal("handleSleepExit should reject pair due to filter mismatch")
+ }
+ })
+}
+
+func TestInitRawHandlersRegistersSleepEvents(t *testing.T) {
+ el := mustNewEventLoop(t, eventLoopConfig{})
+ if _, ok := el.rawHandlers[types.ENTER_SLEEP_EVENT]; !ok {
+ t.Fatal("ENTER_SLEEP_EVENT handler is not registered")
+ }
+}
+