From 127516b4bf63dc922df222825a9a6a1d7eacc214 Mon Sep 17 00:00:00 2001 From: Paul Buetow Date: Tue, 19 May 2026 10:12:32 +0300 Subject: u6: add socket/socketpair kind scaffolding and wiring --- cmd/ioworkload/scenario_socket.go | 31 +++++++++++++++++++++++++++++++ cmd/ioworkload/scenarios.go | 2 ++ 2 files changed, 33 insertions(+) create mode 100644 cmd/ioworkload/scenario_socket.go (limited to 'cmd') diff --git a/cmd/ioworkload/scenario_socket.go b/cmd/ioworkload/scenario_socket.go new file mode 100644 index 0000000..1ffc784 --- /dev/null +++ b/cmd/ioworkload/scenario_socket.go @@ -0,0 +1,31 @@ +package main + +import ( + "fmt" + "syscall" +) + +func socketBasic() error { + fd, err := syscall.Socket(syscall.AF_UNIX, syscall.SOCK_STREAM|syscall.SOCK_CLOEXEC, 0) + if err != nil { + return fmt.Errorf("socket: %w", err) + } + if err := syscall.Close(fd); err != nil { + return fmt.Errorf("close socket fd: %w", err) + } + return nil +} + +func socketpairBasic() error { + fds, err := syscall.Socketpair(syscall.AF_UNIX, syscall.SOCK_STREAM|syscall.SOCK_CLOEXEC, 0) + if err != nil { + return fmt.Errorf("socketpair: %w", err) + } + if err := syscall.Close(fds[0]); err != nil { + return fmt.Errorf("close socketpair fd0: %w", err) + } + if err := syscall.Close(fds[1]); err != nil { + return fmt.Errorf("close socketpair fd1: %w", err) + } + return nil +} diff --git a/cmd/ioworkload/scenarios.go b/cmd/ioworkload/scenarios.go index 326c954..aedbffa 100644 --- a/cmd/ioworkload/scenarios.go +++ b/cmd/ioworkload/scenarios.go @@ -25,6 +25,8 @@ var scenarios = map[string]func() error{ "readwrite-pread-invalid": readwritePreadInvalid, "readwrite-pwrite-invalid": readwritePwriteInvalid, "retbytes-phase-a": retbytesPhaseA, + "socket-basic": socketBasic, + "socketpair-basic": socketpairBasic, "family-mixed": familyMixed, "close-basic": closeBasic, "close-range": closeRange, -- cgit v1.2.3