rio
rio copied to clipboard
spacejam
pure rust io_uring library, built on libc, thread & async friendly, misuse resistant
I am new to this library and I am trying to figure out how does this library help batching syscalls for network I/O. my use case is I am trying...
If the user calls submit_all() directly, the submitted atomic is not updated. Leading to a crash. I suspect most users rely on waiting on a completion to implicitly submit so...
I am currently transforming [KuiBaDB](https://github.com/KuiBaDB/KuiBaDB) into a fully asynchronous database, and want to use RIO as the underlying implementation of asynchronous IO. But it seems that `IORING_SETUP_SQPOLL` can not work...
hello, I was wondering if you could offer advice about how to store pending `Completion` instances while you are waiting for them to be completed, potentially doing other work in...
This is code that I used in https://gitlab.com/putget-io/capra to auto-detect whether the kernel had the features I wanted -- sharing code in case this of interest to others. It does...
I found weird situation: if I constantly use `fsync` application works steadily, but if I change it on `fsyncdata`, it sometimes returns error: `Bad file descriptor (os error 9)`. In...
https://github.com/spacejam/rio/blob/319f7fb04014aa88540c3539bd97d5a0006a1eb9/src/io_uring/uring.rs#L733-L752 This code assumes that the layout of `std::net::SocketAddrV{4,6}` matches `libc::sockaddr`, but std makes no such promise. See rust-lang/rust#78802 for more details. Example fixes: tokio-rs/mio#1388, rust-lang/socket2#120.
Hello, I'm getting this vulnerability when building my application Does anyone know how to solve it?
This was setting sqe.len to iov_len, but the sqe.addr was set to a msghdr location in InFlight::insert -- consequentially callers to recv got nothing in their buffer, and a heap...
`AtomicBool::compare_and_swap` was deprecated since `1.50.0`. Replace it with `AtomicBool::compare_exchange`.
