summaryrefslogtreecommitdiff
path: root/cmd/ioworkload/scenario_timer.go
diff options
context:
space:
mode:
Diffstat (limited to 'cmd/ioworkload/scenario_timer.go')
-rw-r--r--cmd/ioworkload/scenario_timer.go87
1 files changed, 87 insertions, 0 deletions
diff --git a/cmd/ioworkload/scenario_timer.go b/cmd/ioworkload/scenario_timer.go
new file mode 100644
index 0000000..0bf628d
--- /dev/null
+++ b/cmd/ioworkload/scenario_timer.go
@@ -0,0 +1,87 @@
+package main
+
+import (
+ "fmt"
+ "syscall"
+ "unsafe"
+
+ "golang.org/x/sys/unix"
+)
+
+// itimerspec mirrors struct itimerspec from <time.h> (it_interval, it_value).
+// Used as the argument to timer_settime / timer_gettime.
+type itimerspec struct {
+ Interval unix.Timespec
+ Value unix.Timespec
+}
+
+// posixTimerLifecycle exercises the full POSIX per-process timer family so the
+// tracer's null_event handling is covered end-to-end:
+//
+// timer_create -> timer_settime -> timer_gettime -> timer_getoverrun -> timer_delete
+//
+// These are deliberately distinct from timerfd_create: timer_create returns a
+// timer_t through an OUTPUT pointer (args[2]), NOT a file descriptor, so the
+// tracer must emit a null_event for it and must never treat any argument or the
+// return value as an fd (contrast with timerfd_create, which is an fd-returning
+// eventfd-family syscall). See man 2 timer_create.
+func posixTimerLifecycle() error {
+ // timer_t (__kernel_timer_t) is an int in the Linux UAPI, not an fd.
+ var timerID int32
+
+ // timer_create(CLOCK_MONOTONIC, NULL, &timerID): a NULL sigevent requests
+ // the default notification (SIGALRM via signal), and timerID is the output
+ // timer_t — not an fd.
+ if _, _, errno := syscall.RawSyscall(
+ unix.SYS_TIMER_CREATE,
+ uintptr(unix.CLOCK_MONOTONIC),
+ 0, // sevp == NULL
+ uintptr(unsafe.Pointer(&timerID)),
+ ); errno != 0 {
+ return fmt.Errorf("timer_create: %w", errno)
+ }
+
+ // Arm the timer with a far-future one-shot expiry so it never actually
+ // fires during the test; we only care about the syscalls being traced.
+ newValue := itimerspec{
+ Value: unix.Timespec{Sec: 3600, Nsec: 0},
+ }
+ if _, _, errno := syscall.RawSyscall6(
+ unix.SYS_TIMER_SETTIME,
+ uintptr(timerID),
+ 0, // flags (relative)
+ uintptr(unsafe.Pointer(&newValue)),
+ 0, // old_value == NULL
+ 0, 0,
+ ); errno != 0 {
+ return fmt.Errorf("timer_settime: %w", errno)
+ }
+
+ var curValue itimerspec
+ if _, _, errno := syscall.RawSyscall(
+ unix.SYS_TIMER_GETTIME,
+ uintptr(timerID),
+ uintptr(unsafe.Pointer(&curValue)),
+ 0,
+ ); errno != 0 {
+ return fmt.Errorf("timer_gettime: %w", errno)
+ }
+
+ if _, _, errno := syscall.RawSyscall(
+ unix.SYS_TIMER_GETOVERRUN,
+ uintptr(timerID),
+ 0, 0,
+ ); errno != 0 {
+ return fmt.Errorf("timer_getoverrun: %w", errno)
+ }
+
+ if _, _, errno := syscall.RawSyscall(
+ unix.SYS_TIMER_DELETE,
+ uintptr(timerID),
+ 0, 0,
+ ); errno != 0 {
+ return fmt.Errorf("timer_delete: %w", errno)
+ }
+
+ return nil
+}