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