Ecosyste.ms: OpenCollective
An open API service for software projects hosted on Open Collective.
github.com/tokio-rs/tokio-uring
An io_uring backed runtime for Rust
https://github.com/tokio-rs/tokio-uring
Co-authored-by: ollie <[email protected]>
a69d4bf57776a085a6516f4c022e2bf5d1814762 authored 12 months ago by Taiki Endo <[email protected]>
This fixes CI failure
https://github.com/tokio-rs/tokio-uring/actions/runs/7437161507/job/20234...
Signed-off-by: Li Zhanhui <[email protected]>
d5e90539bd6d1c518e848298564a098c300866bc authored over 1 year ago by Zhanhui Li <[email protected]>Removes loads of dependencies for dependent libraries.
34b27ab64e6d588aee7d43c2d7f9855b072f61ab authored over 1 year ago by Icelk <[email protected]>
Box msghdr in `SendMsgZc` struct to ensure it is stable through the
lifetime of the op.
This enables socket configuration for the listener.
ee8318d817487fae8c62964d68271e2427e81186 authored over 1 year ago by Icelk <[email protected]>Fixes bug as found in #263
78b269b212d24581e808ba1921563fc418e2b6cf authored over 1 year ago by Icelk <[email protected]>Fixes #261
47fbddf1e4e5cb308e2a5ab41e6b0d45b89ad39e authored over 1 year ago by Icelk <[email protected]>
The iovec array must be stable until either:
- Operation completion, or
- not doing IORING_...
Adds the missing `recvmsg` function to the udp socket.
the level of duplication required vs `...
f562364ecb28cb7cd59a2fe87ee8eb25aeaf375f authored almost 2 years ago by ollie <[email protected]>d8ae38b910f32419181be5989433f083858edfbc authored almost 2 years ago by FrankReh <[email protected]>
This change adds a new API for creating and submitting oneshot
operations. This new API is inte...
And remove the io-uring "unstable" features dependency as it is
deprecated.
Add an async API to get buffers out of `FixedBufPool`. This is another
way in which `FixedBufPo...
And add File::writev_at_all as the first user facing example.
The writev_all function will ca...
6695b9a007dbc627423096f4ddae1b3baec263ad authored almost 2 years ago by FrankReh <[email protected]>Add a builder for the statx command, tokio_uring::fs::StatxBuilder.
Also adds a tokio_uring::...
c4320fa2e7b146b28ad921ae25b552a0894c9697 authored almost 2 years ago by FrankReh <[email protected]>Because sendmsg(2) can be used on connected sockets without msg_name.
UDP send_to remains the...
e05ca593658e28c57efe222526d1339ac75204eb authored almost 2 years ago by Maxim Ivanov <[email protected]>
This allows a 'file.close.wait' to return a true close return value. And
it fixes the problem o...
uring, therefore async, versions of create_dir_all and DirBuilder.
afab7f2de5892759f816d03b3df4a20c1ac85fa9 authored almost 2 years ago by FrankReh <[email protected]>The io-uring MkDirAt defaults to creating directories with mode 0.
Fix our fs::create_dir, wh...
1f5dd378d4a56b707cf4bd74025e5fc2106f609c authored almost 2 years ago by FrankReh <[email protected]>
Some of the more recently introduced API IO calls used the original
IoBuf and IoBufMut traits w...
Updates method documentation to use indicative mood. This is not a
huge change, as most public ...
Extends both registries to accept any `Iter` of `IoBufMut`, instead of Vec<u8>.
This is motiv...
0acb432faea66385702809b1600ac78bdf3a6399 authored almost 2 years ago by ollie <[email protected]>
Add support for the IORING_OP_SENDMSG_ZC opcode added in Linux
6.1 with a new sendmsg_zc functi...
Add support for both the `IORING_OP_FALLOCATE` and the
`IORING_OP_STATX` opcodes, and extends `...
Removes FuturesUnordered from benchmarks and alters timing to ignore
task spawning, as to hone ...
This adds a `create_dir` function call to `tokio_uring::fs` and
partially fixes #48.
I also ...
d6496526bf1ef1a129c9b8e977fb04e0181e6f68 authored about 2 years ago by Kai Mast <[email protected]>
#196 broke the ability to populate a collection of fixed buffers
off-runtime and then have it r...
This cleans up a few different pieces and is a followup change from
#196.
Provide a generic, safe way to copy data into a buffer, possibly
advancing the initialized leng...
This opens up a lot of further cleanup opportunities, especially around
shutdown logic. It also...
Use the convenient socket2::SockRef::from to get a socket reference
which can then be shutdown....
No need for this crate to maintain its own any longer.
There was recent activity in the stand...
f6cb0ed0f05b99a492974e6c2c423954ec42d4ce authored about 2 years ago by FrankReh <[email protected]>The type UdpSocket gets methods local_addr, read_fixed and write_fixed.
local_addr is useful ...
002c94f533e8d27ad3d1ba285009f642328d6479 authored about 2 years ago by FrankReh <[email protected]>
Define write_all functions that take fixed buffers.
Adds write_fixed_all for TCP and Unix...
Make the internal infrastructure for fixed buffers more flexible,
allowing `FixedBuf` handles t...
Exposes `net::TcpStream::set_nodelay` like in `tokio::net` and
`std::net`.
Co-authored-by: N...
026d57aabd3cdaa7d9134fa6c072c59beb69aa61 authored about 2 years ago by Kai Mast <[email protected]>e257f73ca7872914e4e6e3a80dc0c97ce1cb13c6 authored about 2 years ago by FrankReh <[email protected]>
This makes it easier to build abstractions on top of the `FixedBufferRegistry`.
0572c11c21e9aca935564afaf91fb0deaa39c528 authored about 2 years ago by Oskar Nehlin <[email protected]>
Add infrastructure to manage pre-registered buffers, and operation
methods `File::read_fixed_at...
This change renames the top-level driver module to "io" and moves the
driver and Op to a driver...
Introduce new traits, `BoundedBuf` and `BoundedBufMut`, taking the
`slice` method and related i...
Signed-off-by: wanglei01 <[email protected]>
f99f214421853ecd50567efa2af760281178de1c authored about 2 years ago by wanglei01 <[email protected]>d1de1a929742eb42f06cb5f332b8d4782ed7de0d authored about 2 years ago by Zhanhui Li <[email protected]>
Somewhere, in the myriad of refactorings that occurred in #123, I
dropped the marker type. This...
Linux 6.0 introduced `IORING_OP_SEND_ZC`. This PR introduces the
function `send_zc` on udp (tod...
This PR is a light refactoring, which moves the special case handling
for `SharedFd` which fall...
f5f1724140550a4a39e4ef2c579221ad90ccd068 authored about 2 years ago by ollie <[email protected]>
Current API and abstractions make it possible to write these helper
methods.
Fixes #41
a904aa9b0e188003eff894d7616ba44058c50010 authored about 2 years ago by 李冬冬 <[email protected]># 0.4.0 (November 5th, 2022)
### Fixed
- Fix panic in Deref/DerefMut for Slice extending i...
a98b29237e0f43aae6f0abbaf5e8771ce99b0e5c authored about 2 years ago by FrankReh <[email protected]>This fixes an immediate issue where ops like Accept can cause runtime shutdown to hang.
Unfor...
4b0e07e9cdd9f6cd941ee2c2abedc099961be045 authored about 2 years ago by Noah Kennedy <[email protected]>This fixes an issue where we would try and spawn a separate background task on the `LocalSet` fo...
046d09b4eaa6c0f0bbca2f4a380ca096a64c9e4b authored about 2 years ago by Noah Kennedy <[email protected]>Co-authored-by: ollie-etl <Oliver [email protected]>
b0e973a95ca82f1311f574d126decf0cee9c093a authored about 2 years ago by ollie <[email protected]>rt: refactor drop logic
This shouldn't change any functionality, but it does use ManuallyDrop...
8725b81b862cc480be93b1a11c80b9990d51d890 authored about 2 years ago by Noah Kennedy <[email protected]>507186d1ab6854470ee746cb64c6f2d0cf9604f7 authored about 2 years ago by Noah Kennedy <[email protected]>
In the driver drop code, don't assume the call to wait for
a completion will always succeed. Th...
io-uring v0.5.8 handles the overflow of the cqueue so this bump on the
dependancy fixes hangs c...
* Add writev to TcpStream
Co-authored-by: FrankReh <[email protected]>
4a10a9caded9c468a03fc762cbd8a581a10345af authored about 2 years ago by amos <[email protected]>* Add Marker SingleCqe
This is used to parameterize Op<T, CqeType>. It is now possible to
sp...
This change refactors the runtime to not use reference counting directly in the ops themselves. ...
c069cc638a222c56275a83b198ec907ed92741e5 authored about 2 years ago by Noah Kennedy <[email protected]>Co-authored-by: ollie-etl <Oliver [email protected]>
cb189fa25a91bc8d97611f350a75e7c36c6dfea1 authored about 2 years ago by ollie <[email protected]>Co-authored-by: ollie-etl <Oliver [email protected]>
2297ed75203f175e2517c672b0e803969062dd1b authored about 2 years ago by ollie <[email protected]>Co-authored-by: ollie-etl <Oliver [email protected]>
c6b884ea103997369ef88fe5eaec9920707896d6 authored about 2 years ago by ollie <[email protected]>Fixes #145. A data race was observed in Pr #144, where with high concurrency in user-space, and ...
13f740988de40f6ef99f11b870985cd051e7b5ef authored about 2 years ago by ollie <[email protected]>Co-authored-by: ollie-etl <Oliver [email protected]>
5f8ddb490e76ec96120faef540daf75f061b6378 authored about 2 years ago by ollie <[email protected]>Co-authored-by: ollie-etl <Oliver [email protected]>
7adeacb88ce6fb93ce17645de1d2040ba50a36e5 authored about 2 years ago by ollie <[email protected]>
A few features have been added to one or the other. This brings them
back to parity with each o...
52c7cd96bd0a24646cd2c0e217aebf2bcd99004b authored about 2 years ago by FrankReh <[email protected]>
d4d88c2d6c49cff32141a2352ac80507d7a19543 authored about 2 years ago by ollie <[email protected]>
79647c1dfbe0686dd354fcaa5978c578ceac1ba6 authored about 2 years ago by Divy Srivastava <[email protected]>
Implements mode() and custom_flags() of std::os::unix::fs::OpenOptionsExt for OpenOptions.
cust...
5eb58ec17870f384bec39e5667f571957955715b authored about 2 years ago by Divy Srivastava <[email protected]>
a42af774e3cf83b5cd7811482cc2397c80dbb46a authored about 2 years ago by amos <[email protected]>
1c0a2bff4a5f8fdc34e91cac30b74305c3486e88 authored about 2 years ago by FrankReh <[email protected]>
Setting the env variable RUST_TEST_THREADS to 1 in the local
.cargo/config.toml avoids a race d...
Two places try_join! was used to have a socket accept and a socket
connect performed concurrent...
As a first step towards implementing cancellation of in-flight operations, we need to move the p...
913aa14c567cfae026b7d4f88a5155921cfb9575 authored over 2 years ago by Noah Kennedy <[email protected]>Add a Builder API as an option to start the tokio_uring runtime.
The preexisting tokio_uring:...
20da163283dda1767fbc84f3ef632ef4d3222f27 authored over 2 years ago by FrankReh <[email protected]>Add an async write_all method for the TcpStream type.
Also a doc example and a rework of the ...
402653919b6c010468fdd94ce0a7ea3347de103a authored over 2 years ago by FrankReh <[email protected]>Closes #106.
587c9c3b3d86e5a9a435a86bbf08af4f4e840a68 authored over 2 years ago by FrankReh <[email protected]>f80207b127b66c03155fbe9cd06ce3bb6a8b84c5 authored over 2 years ago by Jiang Liu <[email protected]>
[Rendered](https://github.com/tokio-rs/tokio-uring/blob/design-doc/DESIGN.md)
The RFC propose...
c3571255ca0e10dfa26485c47b997e2440f6695f authored over 2 years ago by Carl Lerche <[email protected]>01c8bb8d35df74c4b5b3cdfe6df296f809855589 authored over 2 years ago by Noah Kennedy <[email protected]>
d6bfa95ada2b0393d155c9db7734c194bb3a1332 authored over 2 years ago by Noah Kennedy <[email protected]>
Implement the `rename` operation for `fs`.
This operation uses `IORING_OP_RENAMEAT` as the opco...
0e323e9a2138133b87bb32203103a81068d06fa5 authored over 2 years ago by Dawid Ciężarkiewicz <[email protected]>
Add a CI check which passes as soon as all required checks do. This allows us to set one require...
89a9bd7034573690977cb004223ba8a5ab37ed28 authored over 2 years ago by Noah Kennedy <[email protected]>
Implement FromRawFd for File, so we could convert a normal file into
tokio-uring File.
Signe...
9b9c500548722f7942ecdb216b8ebf6689a4d93a authored over 2 years ago by Jiang Liu <[email protected]>105595809d1e60acbb5374dbe1f7f8d8ea1febb0 authored over 2 years ago by Taiki Endo <[email protected]>
I wanted the ability to have finer grained control over which socket
options where set when cre...
So the docs show that `bytes::Bytes` implements `IoBuf` (#43)
08fbe188f8c5834e576f22784dc9c1919be2931b authored over 2 years ago by Aaron O'Mullan <[email protected]>Batch submit requests for fun and profit
0fdc0c2a25e20e3dcf11cd39ab9f5627c3b93e56 authored over 2 years ago by Noah Kennedy <[email protected]>
When the slice extends into the uninitialized part of the buffer,
the byte slice returned by th...
7d7913c02dc4c633cfff632c2f6f138d53783192 authored almost 3 years ago by Noah Kennedy <[email protected]>
56d1882eb13f4f73037ea800ed3c43d502f3efb9 authored almost 3 years ago by Noah Kennedy <[email protected]>
31761492f2fcd985c869fdca0c5d62fc1b1d165d authored almost 3 years ago by jon-chuang <[email protected]>
523dae04969d64a7d6f2da1ff7d53005f661086e authored almost 3 years ago by LinkTed <[email protected]>
3692f63e4d40158824512e3535656049ff13e43d authored almost 3 years ago by Noah Kennedy <[email protected]>
db8fc340b5c4c733426cb8c7da842ab4338891ba authored almost 3 years ago by Noah Kennedy <[email protected]>
After https://github.com/rust-lang/rust/pull/85746 , `ErrorKind::Other`
is not what it used to....