rust io - #7055

Closed

mikea wants to merge 234 commits into

mainfrom

maizatskyi/2026-08-18-rust-io

Commits on Aug 18, 2026

Add Rust I/O dependency features
mikea
committed
24184aa
Document kj::Maybe unsafe invariants
mikea
committed
213580d
Tighten KjOwn thread-safety guarantees
mikea
committed
e9cfec0
Tighten KjArc thread-safety bounds
mikea
committed
f0201b3
Document promise bridge safety invariants
mikea
committed
d88afc9
Keep guarded executors alive through teardown
mikea
committed
21ec538
Add tokio runtime accessors
mikea
committed
747be9d
Add readiness polling helper
mikea
committed
45e7007
Add KJ stream unwrap interface
mikea
committed
31f46d2
Declare tokio file watcher bridge
mikea
committed
ed44089
Declare peer filtering interfaces
mikea
committed
a626e4f
Add tokio event port setup entry point
mikea
committed
ffc60b5
Declare CLI I/O backend selection
mikea
committed
f60aa1a
Declare tokio event port bridge
mikea
committed
96b9e97
Tune high-resolution timer threads
mikea
committed
9cd1c1d
Add precise macOS deadline sleeps
mikea
committed
9b4be93
Add precise Linux deadline sleeps
mikea
committed
e4d58c1
Add portable Unix deadline sleep fallback
mikea
committed
b1509f7
Define tokio event port scheduling constants
mikea
committed
c889b06
Add local tokio task spawning
mikea
committed
f4de76c
Define tokio event port shared state
mikea
committed
4e1c62e
Add high-resolution timer arming
mikea
committed
9467417
Stop high-resolution timers on drop
mikea
committed
e668daa
Run high-resolution timer requests
mikea
committed
90d6be6
Define the tokio event port
mikea
committed
b0119ba
Initialize tokio event ports
mikea
committed
1771614
Wait on tokio event ports
mikea
committed
9dd0696
Poll and wake tokio event ports
mikea
committed
4a3ea71
Clean up tokio event ports on drop
mikea
committed
3cc6180
Test tokio event port behavior
mikea
committed
c625213
Expose tokio event port APIs
mikea
committed
b88af97
Declare tokio event port
mikea
committed
55644ee
Add tokio async I/O context
mikea
committed
86dd088
Format tokio event port modules
mikea
committed
e5dc51b
Define tokio I/O errors
mikea
committed
c1493ba
Classify portable I/O errors
mikea
committed
5519fe5
Map Unix errors to KJ exception types
mikea
committed
71b4333
Convert I/O errors to KJ exceptions
mikea
committed
8733b93
Add portable signal watcher fallback
mikea
committed
3442b95
Watch Unix signals on the tokio runtime
mikea
committed
b22bdab
Watch Windows console signals
mikea
committed
f1be13f
Declare tokio async I/O streams
mikea
committed
dd6f73a
Declare tokio connection receivers
mikea
committed
e3cf632
Declare tokio network addresses
mikea
committed
bc00183
Declare tokio networks
mikea
committed
dc78222
Declare low-level tokio I/O providers
mikea
committed
5d73e96
Declare tokio async I/O providers
mikea
committed
563093e
Declare tokio async I/O setup
mikea
committed
9ceea86
Implement tokio stream reads
mikea
committed
fd1fca1
Implement tokio stream operations
mikea
committed
9043989
Authenticate accepted tokio peers
mikea
committed
0ce3be1
Implement tokio connection receivers
mikea
committed
7fd6753
Implement tokio network addresses
mikea
committed
fb48dd5
Prepare native descriptors for tokio
mikea
committed
9081c0b
Adapt native descriptors to tokio streams
mikea
committed
a7d8b4c
Implement tokio async I/O providers
mikea
committed
6af4bf8
Add peer address classification helpers
mikea
committed
38c865d
Parse peer filter rules
mikea
committed
fb872bf
Apply peer filtering rules
mikea
committed
57a2be1
Add file watcher platform dependencies
mikea
committed
c2bade8
Watch files with inotify
mikea
committed
cccf690
Watch files with kqueue
mikea
committed
e30552b
Add unsupported file watcher fallback
mikea
committed
8dd82b5
Expose cross-platform file watching
mikea
committed
7aa2044
Parse Unix network addresses
mikea
committed
a38b91e
Parse IP and hostname addresses
mikea
committed
db08e02
Connect and inspect tokio addresses
mikea
committed
8ee0990
Listen on tokio addresses
mikea
committed
eea9da9
Implement tokio network listeners
mikea
committed
f1d8787
Resolve hostnames on the tokio runtime
mikea
committed
b1a5234
Expose tokio network address operations
mikea
committed
cb7dc0b
Adapt owned sockets for Rust serving
mikea
committed
7eaa05e
Wrap connected native sockets
mikea
committed
1c64717
Wrap native listening sockets
mikea
committed
5d31dc1
Wrap connecting native sockets
mikea
committed
79cc0ac
Add Rust I/O test helpers
mikea
committed
f506c95
Add Rust serving test helpers
mikea
committed
e16cd72
Add Rust I/O test bridge
mikea
committed
c2ccc21
Test Capn Proto RPC over tokio I/O
mikea
committed
dd802e2
Test HTTP over tokio I/O
mikea
committed
5d54bed
Test tokio file watching
mikea
committed
822303d
Test Rust serving over KJ streams
mikea
committed
10aa007
Test tokio async I/O compatibility
mikea
committed
b836950
Define tokio stream variants
mikea
committed
827ed80
Add tokio stream constructors and readiness
mikea
committed
447e3a7
Read and write tokio streams
mikea
committed
c04503b
Detect tokio stream disconnection
mikea
committed
462bb5f
Shut down tokio stream writes
mikea
committed
67caf16
Access tokio stream socket options
mikea
committed
094be8c
Inspect tokio stream endpoints
mikea
committed
e4abdce
Consume tokio stream wrappers
mikea
committed
dab101e
Expose tokio stream bridge operations
mikea
committed
e3b9754
Wrap arbitrary native file descriptors
mikea
committed
2f3adbe
Read tokio input descriptors
mikea
committed
0508419
Write tokio output descriptors
mikea
committed
7e9be6e
Define Rust serving paths
mikea
committed
a9a1a4d
Define tokio serving streams
mikea
committed
636d0e3
Read tokio serving streams
mikea
committed
e0038a4
Write tokio serving streams
mikea
committed
d70078c
Represent served KJ streams
mikea
committed
89d07ab
Represent native socket extraction failures
mikea
committed
08b65ef
Extract native sockets from KJ streams
mikea
committed
203573d
Select native or pumped serving
mikea
committed
8fc0e48
Pump KJ streams through tokio duplexes
mikea
committed
1894dfd
Define Rust I/O bridge vocabulary
mikea
committed
e6c758a
Create the Rust I/O bridge
mikea
committed
2c2f03c
Bridge tokio stream operations
mikea
committed
a3d99c7
Bridge tokio network addresses
mikea
committed
7d7b926
Bridge tokio listeners
mikea
committed
0a158a7
Bridge native descriptor wrapping
mikea
committed
5ccd1b5
Bridge signals and descriptor readiness
mikea
committed
f995417
Bridge foreign KJ streams
mikea
committed
10bf249
Own native descriptors across the I/O bridge
mikea
committed
3ecf71c
Convert socket addresses across the I/O bridge
mikea
committed
5b6f86c
Read Unix socket options
mikea
committed
5dd05c9
Write Unix socket options
mikea
committed
e954771
Read Windows socket options
mikea
committed
e5657c0
Write Windows socket options
mikea
committed
246ce99
Bridge stream socket options
mikea
committed
ee9787a
Bridge listener socket options
mikea
committed
52087af
Split borrowed KJ streams safely
mikea
committed
fc671f0
Unwrap owned KJ streams
mikea
committed
b58f074
Expose tokio async I/O APIs
mikea
committed
6565c47
Add tokio event port test helpers
mikea
committed
bdb3581
Add tokio event port test bridge
mikea
committed
969c620
Test tokio event port behavior
mikea
committed
403c577
Test neutralized Rust wakers
mikea
committed
14b73ec
Test shared Rust future events
mikea
committed
cc2adc6
Add same-thread future waker cells
mikea
committed
759a252
Declare poll-scoped Rust wakers
mikea
committed
b9497b8
Attach retained waker cells to future events
mikea
committed
6fdb36f
Implement poll-scoped Rust wakers
mikea
committed
211bb45
Bridge retained future waker cells
mikea
committed
92fa53a
Add retained-cell Rust wakers
mikea
committed
ef1077b
Add poll-scoped Rust wakers
mikea
committed
d636eec
Poll Rust futures with same-thread wakers
mikea
committed
5ae2e1c
Build the tokio event port crate
mikea
committed
7009a0e
Build tokio event port tests
mikea
committed
82ae4b6
Build the tokio async I/O crate
mikea
committed
f652aaf
Build tokio async I/O tests
mikea
committed
469e471
Make bridged Rust futures eager
mikea
committed
d6259ef
Define Rust I/O backend build toggles
mikea
committed
670ba72
Trace forbidden native I/O dependencies
mikea
committed
a5b9d40
Report Rust I/O build hermeticity
mikea
committed
a850b29
Add the Rust I/O hermeticity rule
mikea
committed
8dbed51
Add selectable Rust I/O backend
mikea
committed
1a5d3cb
Provide inert Windows event-port symbols
mikea
committed
90bb95e
Provide inert Unix event-port symbols
mikea
committed
fdc2101
Adapt tokio I/O to the KJ setup API
mikea
committed
1a8f9b4
Add CLI I/O backend dependencies
mikea
committed
fdfaae0
Watch CLI files with inotify
mikea
committed
b49cc55
Watch CLI files with kqueue
mikea
committed
3769796
Add Windows CLI file watcher fallback
mikea
committed
4d532d4
Add portable CLI file watcher fallback
mikea
committed
4c111e1
Adapt tokio CLI file watching
mikea
committed
e0ac177
Select CLI signal and file watchers
mikea
committed
8c36223
Add backend-selectable async I/O setup
mikea
committed
ea68617
Isolate the legacy CLI file watcher
mikea
committed
b64830a
Route CLI I/O through the selected backend
mikea
committed
e6462bf
Enforce Rust I/O server dependencies
mikea
committed
1540626
Create the kj-rs bridge module
mikea
committed
cfc73ed
Bridge kj-rs Rust waker storage
mikea
committed
cf4061a
Bridge kj-rs C++ wakers
mikea
committed
b621663
Bridge KJ promise nodes
mikea
committed
59a545e
Bridge KJ promise awaiters
mikea
committed
9be94d2
Mark kj-rs FFI implementation islands
mikea
committed
b19f8a5
Add same-thread promise polling overloads
mikea
committed
d12a854
Preserve the legacy waker bridge during migration
mikea
committed
744959c
Move the kj-rs bridge into its FFI island
mikea
committed
975e544
Remove the embedded awaiter bridge
mikea
committed
15803b6
Remove the embedded waker bridge
mikea
committed
f3aafa2
Remove the embedded promise bridge
mikea
committed
f60cfb0
Remove the embedded bridge shell
mikea
committed
1a4e73f
Remove legacy Rust waker construction
mikea
committed
e121312
Remove the legacy Rust waker vtable
mikea
committed
57dabed
Remove the legacy waker bridge
mikea
committed
0753aa7
Use abstract async I/O dependencies
mikea
committed
1ec24d2
Use abstract async API dependencies
mikea
committed
7c7db0f
Link JSG against selected async I/O
mikea
committed
14bc149
Link workerd tests against selected I/O
mikea
committed
db83a6d
Select I/O backend for KJ tests
mikea
committed
a4835ac
Remove the legacy inotify CLI watcher
mikea
committed
80da17a
Remove the legacy kqueue CLI watcher
mikea
committed
57668ab
Remove the legacy Windows CLI watcher
mikea
committed
9256768
Remove the legacy portable CLI watcher
mikea
committed
4835bb5
Remove legacy CLI watcher dependencies
mikea
committed
9e84e46
Normalize tokio async I/O implementation
mikea
committed
5ac5881
Normalize tokio I/O error mapping
mikea
committed
3144b76
Normalize the tokio I/O bridge
mikea
committed
ae660d4
Normalize tokio file watching
mikea
committed
abd082c
Inline tokio network address parsing
mikea
committed
8e0b05f
Normalize tokio signal watching
mikea
committed
82c508c
Normalize tokio stream implementation
mikea
committed
00bf205
Normalize tokio event port bridge
mikea
committed
c129a3d
Normalize tokio event port implementation
mikea
committed
1d037a4
Normalize tokio setup shim
mikea
committed
02b3940
Document the Rust I/O crates
mikea
committed
bc7b5e5
Enforce kj-rs safety boundaries
mikea
committed
36e8639
Finalize promise bridge safety
mikea
committed
be5018f
Document eager Rust future conversion
mikea
committed
9a9325a
Finalize the kj-rs bridge
mikea
committed
9339080
Finalize kj-rs build dependencies
mikea
committed
4931bec
Convert future panics into KJ exceptions
mikea
committed
5b4a96d
Catch panics from fallible future polls
mikea
committed
2166b7a
Catch panics from infallible future polls
mikea
committed
47fe4d7
Guard fallible future destruction from unwinding
mikea
committed
ecece8c
Guard infallible future destruction from unwinding
mikea
committed
203f738
Document Rust future safety invariants
mikea
committed
7c3feda
Add weak links for promise awaiters
mikea
committed
d88db03
Use weak links when polling KJ promises
mikea
committed
630638b
Remove legacy promise polling
mikea
committed
13cd6ef
Remove legacy poll-scope implementation
mikea
committed
1297fea
Remove linked-group future polling
mikea
committed
38d02d5
Document promise awaiter weak links
mikea
committed
3822d13
Remove legacy atomic waker implementation
mikea
committed
881e8bb
Remove legacy lazy waker implementation
mikea
committed
64cebfe
Remove the legacy abstract waker
mikea
committed
32616a0
Remove the legacy waker promise node
mikea
committed
2d294f2
Remove the legacy atomic waker
mikea
committed
ffdd604
Remove the legacy lazy waker
mikea
committed
39b946c
Order retained waker declarations by dependency
mikea
committed
20f9792
Document future poll wake behavior
mikea
committed
173ad0d
Place borrowed waker support before owned cells
mikea
committed
dc682c3
Remove superseded borrowed waker declarations
mikea
committed
3e40d4b
Stop building linked-group tests
mikea
committed
24f591f
Remove obsolete linked-group tests
mikea
committed
de415d2
Remove obsolete linked-group documentation
mikea
committed
fe08290
Remove the obsolete linked-group mixin
mikea
committed
131a495
Remove obsolete linked-object documentation
mikea
committed
057c218
Remove obsolete linked-group proxies
mikea
committed
55d22e1
Remove the obsolete linked-object mixin
mikea
committed
4cdfc56
Remove the obsolete linked-group iterator
mikea
committed
ef405c9
Test future waker and panic handling
mikea
committed
4017d49
Test KJ exception descriptions across Rust FFI
mikea
committed
a17a064