1 files changed, 83 insertions, 0 deletions
diff --git a/internal/eventloop_polling_test.go b/internal/eventloop_polling_test.go
new file mode 100644
index 0000000..9d807d5
--- /dev/null
+++ b/internal/eventloop_polling_test.go
@@ -0,0 +1,83 @@
+package internal
+
+import (
+	"testing"
+
+	"ior/internal/event"
+	"ior/internal/file"
+	"ior/internal/globalfilter"
+	"ior/internal/types"
+)
+
+func TestHandleEpollCtlExitUsesEpollInstanceFd(t *testing.T) {
+	el := mustNewEventLoop(t, eventLoopConfig{})
+	el.fdState().set(41, file.NewFd(41, "anon_inode:[eventpoll]", -1))
+
+	enter := &types.EpollCtlEvent{
+		EventType: types.ENTER_EPOLL_CTL_EVENT,
+		TraceId:   types.SYS_ENTER_EPOLL_CTL,
+		Time:      100,
+		Pid:       90,
+		Tid:       91,
+		Epfd:      41,
+		Op:        1,
+		Fd:        42,
+		Events:    1,
+	}
+	exit := &types.RetEvent{
+		EventType: types.EXIT_RET_EVENT,
+		TraceId:   types.SYS_EXIT_EPOLL_CTL,
+		Time:      200,
+		Ret:       0,
+		Pid:       90,
+		Tid:       91,
+	}
+	ep := &event.Pair{EnterEv: enter, ExitEv: exit}
+
+	if ok := el.handleEpollCtlExit(ep, enter); !ok {
+		t.Fatal("handleEpollCtlExit returned false")
+	}
+	if ep.File == nil || ep.File.FD() != 41 {
+		t.Fatalf("expected resolved epoll instance fd 41, got file=%v", ep.File)
+	}
+}
+
+func TestHandleEpollCtlExitAppliesPairFilter(t *testing.T) {
+	el := mustNewEventLoop(t, eventLoopConfig{
+		filter: globalfilter.Filter{
+			Syscall: &globalfilter.StringFilter{Pattern: "openat"},
+		},
+	})
+
+	enter := &types.EpollCtlEvent{
+		EventType: types.ENTER_EPOLL_CTL_EVENT,
+		TraceId:   types.SYS_ENTER_EPOLL_CTL,
+		Time:      100,
+		Pid:       92,
+		Tid:       93,
+		Epfd:      51,
+		Op:        1,
+		Fd:        52,
+		Events:    1,
+	}
+	exit := &types.RetEvent{
+		EventType: types.EXIT_RET_EVENT,
+		TraceId:   types.SYS_EXIT_EPOLL_CTL,
+		Time:      200,
+		Ret:       0,
+		Pid:       92,
+		Tid:       93,
+	}
+	ep := &event.Pair{EnterEv: enter, ExitEv: exit}
+
+	if ok := el.handleEpollCtlExit(ep, enter); ok {
+		t.Fatal("handleEpollCtlExit should reject pair due to filter mismatch")
+	}
+}
+
+func TestInitRawHandlersRegistersPollingEvents(t *testing.T) {
+	el := mustNewEventLoop(t, eventLoopConfig{})
+	if _, ok := el.rawHandlers[types.ENTER_EPOLL_CTL_EVENT]; !ok {
+		t.Fatal("ENTER_EPOLL_CTL_EVENT handler is not registered")
+	}
+}