diff --git a/Cargo.lock b/Cargo.lock index c1b7a17..3b1fbaf 100644 --- a/Cargo.lock +++ b/Cargo.lock @@ -1300,9 +1300,9 @@ dependencies = [ [[package]] name = "io-uring" -version = "0.5.13" +version = "0.6.0" source = "registry+https://github.com/rust-lang/crates.io-index" -checksum = "dd1e1a01cfb924fd8c5c43b6827965db394f5a3a16c599ce03452266e1cf984c" +checksum = "8b7b36074613a723279637061b40db993208908a94f10ccb14436ce735bc0f57" dependencies = [ "bitflags 1.3.2", "libc", diff --git a/aquatic_udp/Cargo.toml b/aquatic_udp/Cargo.toml index b23388d..4919209 100644 --- a/aquatic_udp/Cargo.toml +++ b/aquatic_udp/Cargo.toml @@ -36,7 +36,7 @@ getrandom = "0.2" hashbrown = { version = "0.13", default-features = false } hdrhistogram = "7" hex = "0.4" -io-uring = { version = "0.5", optional = true } +io-uring = { version = "0.6", optional = true } libc = "0.2" log = "0.4" metrics = { version = "0.20", optional = true } diff --git a/aquatic_udp/src/workers/socket/uring/buf_ring.rs b/aquatic_udp/src/workers/socket/uring/buf_ring.rs index 7862753..c2e1d27 100644 --- a/aquatic_udp/src/workers/socket/uring/buf_ring.rs +++ b/aquatic_udp/src/workers/socket/uring/buf_ring.rs @@ -744,8 +744,10 @@ impl RawBufRing { // can register, and unregister, the same way. let res = CurrentRing::with(|ring| { - ring.submitter() - .register_buf_ring(self.ring_addr as _, self.ring_entries(), bgid) + unsafe { + ring.submitter() + .register_buf_ring(self.ring_addr as _, self.ring_entries(), bgid) + } }); // println!("{}:{}: res {:?}", file!(), line!(), res);