Skip to content

perf(mpool): Stage 2 — async I/O backends (io_uring/IOCP/kqueue/POSIX-aio/threadpool) #24

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Draft
gburd wants to merge 11 commits into
base: master
Choose a base branch
from
Draft

perf(mpool): Stage 2 — async I/O backends (io_uring/IOCP/kqueue/POSIX-aio/threadpool) #24

Show file tree
Hide file tree
Changes from all commits
Commits
Show all changes
11 commits
Select commit Hold shift + click to select a range
9e6f5f1
perf(os): add os_aio abstraction with synchronous backend (Stage 2)
gburd Jun 18, 2026
06e243e
perf(os): add Linux io_uring backend for os_aio (reuse from libxtc)
gburd Jun 18, 2026
9de3e4f
fix(os): don't clobber reap max/wait via COMPQUIET before dispatch
gburd Jun 18, 2026
60f88df
perf(os): add portable thread-pool offload AIO backend + unify selection
gburd Jun 18, 2026
b4a98b5
perf(os): add Windows IOCP native file-AIO backend (reuse from libxtc)
gburd Jun 18, 2026
0d45b53
build: autodetect liburing + pthreads for os_aio backends
gburd Jun 18, 2026
09ece3c
refactor(mpool): factor __memp_pgwrite into prep/finish; add per-proc…
gburd Jun 19, 2026
6da3cb8
perf(mpool): async checkpoint writeback via os_aio (Stage 2 #5)
gburd Jun 19, 2026
7065988
perf(os): make the threadpool AIO backend global, lazy, and fork-safe
gburd Jun 19, 2026
fee819d
build(nix): provide liburing on Linux for the io_uring AIO backend
gburd Jun 19, 2026
bd0a9f5
perf(os): add native POSIX-aio and BSD kqueue AIO backends; fix C23 b…
gburd Jun 19, 2026
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
14 changes: 13 additions & 1 deletion dist/Makefile.in
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -281,7 +281,7 @@ DTRACE_OBJS= @ADDITIONAL_OBJS@ @REPLACEMENT_OBJS@ @CRYPTO_OBJS@ \
log_stat@o@ mkpath@o@ mp_alloc@o@ mp_backup@o@ mp_bh@o@ mp_fget@o@ \
mp_fmethod@o@ mp_fopen@o@ mp_fput@o@ mp_fset@o@ mp_method@o@ \
mp_mvcc@o@ mp_region@o@ mp_register@o@ mp_resize@o@ mp_stat@o@ \
mp_sync@o@ mp_trickle@o@ openflags@o@ os_abort@o@ os_abs@o@ \
mp_sync@o@ mp_trickle@o@ openflags@o@ os_abort@o@ os_abs@o@ os_aio@o@ os_aio_iocp@o@ os_aio_kqueue@o@ os_aio_pool@o@ os_aio_posix@o@ os_aio_uring@o@ \
os_alloc@o@ os_atomic@o@ os_clock@o@ os_cpu@o@ os_ctime@o@ os_config@o@ \
os_dir@o@ os_errno@o@ os_fid@o@ os_flock@o@ os_fsync@o@ \
os_getenv@o@ os_handle@o@ os_map@o@ os_method@o@ os_mkdir@o@ \
Expand Down Expand Up @@ -2239,6 +2239,18 @@ os_abort@o@: $(srcdir)/os/os_abort.c
$(CC) $(CFLAGS) $?
os_addrinfo@o@: $(srcdir)/os/os_addrinfo.c
$(CC) $(CFLAGS) $?
os_aio@o@: $(srcdir)/os/os_aio.c
$(CC) $(CFLAGS) $?
os_aio_uring@o@: $(srcdir)/os/os_aio_uring.c
$(CC) $(CFLAGS) $?
os_aio_posix@o@: $(srcdir)/os/os_aio_posix.c
$(CC) $(CFLAGS) $?
os_aio_kqueue@o@: $(srcdir)/os/os_aio_kqueue.c
$(CC) $(CFLAGS) $?
os_aio_pool@o@: $(srcdir)/os/os_aio_pool.c
$(CC) $(CFLAGS) $?
os_aio_iocp@o@: $(srcdir)/os/os_aio_iocp.c
$(CC) $(CFLAGS) $?
os_alloc@o@: $(srcdir)/os/os_alloc.c
$(CC) $(CFLAGS) $?
os_atomic@o@: $(srcdir)/os/os_atomic.c
Expand Down
12 changes: 12 additions & 0 deletions dist/config.hin
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -30,6 +30,15 @@
/* Define to 1 if you have the 'abort' function. */
#undef HAVE_ABORT

/* Define to 1 to use the BSD kqueue+aio backend. */
#undef HAVE_AIO_KQUEUE

/* Define to 1 to use the POSIX aio backend. */
#undef HAVE_AIO_POSIX

/* Define to 1 to use the thread-pool AIO offload backend. */
#undef HAVE_AIO_THREADPOOL

/* Define to 1 if you have the 'atoi' function. */
#undef HAVE_ATOI

Expand Down Expand Up @@ -189,6 +198,9 @@
/* Define to 1 if you have the <inttypes.h> header file. */
#undef HAVE_INTTYPES_H

/* Define to 1 to use the Linux io_uring AIO backend. */
#undef HAVE_IO_URING

/* Define to 1 if you have the 'isalpha' function. */
#undef HAVE_ISALPHA

Expand Down
Loading
Loading