YGGverse/aquatic
1
0
Fork 0
mirror of https://github.com/YGGverse/aquatic.git synced 2026-03-31 17:55:36 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions

Run cargo fmt

Browse source
This commit is contained in:
Joakim Frostegård 2023-04-10 01:05:23 +02:00
parent e237f76ca7
commit 4dba6f92cd
1 changed files with 3 additions and 5 deletions
Download patch file Download diff file Expand all files Collapse all files

8
aquatic_udp/src/workers/socket/uring/buf_ring.rs
View file

@ -743,11 +743,9 @@ impl RawBufRing {
// Future: move to separate public function so other buf_ring implementations // Future: move to separate public function so other buf_ring implementations
// can register, and unregister, the same way. // can register, and unregister, the same way.
let res = CurrentRing::with(|ring| { let res = CurrentRing::with(|ring| unsafe {
unsafe { ring.submitter()
ring.submitter() .register_buf_ring(self.ring_addr as _, self.ring_entries(), bgid)
.register_buf_ring(self.ring_addr as _, self.ring_entries(), bgid)
}
}); });
// println!("{}:{}: res {:?}", file!(), line!(), res); // println!("{}:{}: res {:?}", file!(), line!(), res);