Skip to content

Commit 11a41bd

Browse files
committed
refactor: better used_ring method names
Update methods that set values in the `used_ring` to be more descriptive and coherent. Signed-off-by: Egor Lazarchuk <[email protected]>
1 parent 0980eb0 commit 11a41bd

File tree

1 file changed

+8
-8
lines changed

1 file changed

+8
-8
lines changed

src/vmm/src/devices/virtio/queue.rs

Lines changed: 8 additions & 8 deletions
Original file line numberDiff line numberDiff line change
@@ -452,7 +452,7 @@ impl Queue {
452452
// This fence ensures all descriptor writes are visible before the index update is.
453453
fence(Ordering::Release);
454454

455-
self.set_next_used(self.next_used.0, mem);
455+
self.set_used_ring_idx(self.next_used.0, mem);
456456
Ok(())
457457
}
458458

@@ -519,7 +519,7 @@ impl Queue {
519519
}
520520

521521
/// Helper method that writes `val` to the `avail_event` field of the used ring.
522-
fn set_avail_event<M: GuestMemory>(&mut self, val: u16, mem: &M) {
522+
pub fn set_used_ring_avail_event<M: GuestMemory>(&mut self, val: u16, mem: &M) {
523523
debug_assert!(self.is_layout_valid(mem));
524524

525525
// Used ring has layout:
@@ -540,7 +540,7 @@ impl Queue {
540540
mem.write_obj(val, avail_event_addr).unwrap();
541541
}
542542

543-
pub fn set_next_used<M: GuestMemory>(&mut self, val: u16, mem: &M) {
543+
pub fn set_used_ring_idx<M: GuestMemory>(&mut self, val: u16, mem: &M) {
544544
debug_assert!(self.is_layout_valid(mem));
545545

546546
// Used ring has layout:
@@ -552,8 +552,8 @@ impl Queue {
552552
// }
553553
// We calculate offset into `idx` field.
554554
let idx_offset = std::mem::size_of::<u16>();
555-
let next_used_addr = self.used_ring.unchecked_add(usize_to_u64(idx_offset));
556-
mem.write_obj(val, next_used_addr).unwrap();
555+
let idx_addr = self.used_ring.unchecked_add(usize_to_u64(idx_offset));
556+
mem.write_obj(val, idx_addr).unwrap();
557557
}
558558

559559
/// Try to enable notification events from the guest driver. Returns true if notifications were
@@ -588,7 +588,7 @@ impl Queue {
588588
}
589589

590590
// Set the next expected avail_idx as avail_event.
591-
self.set_avail_event(self.next_avail.0, mem);
591+
self.set_used_ring_avail_event(self.next_avail.0, mem);
592592

593593
// Make sure all subsequent reads are performed after `set_avail_event`.
594594
fence(Ordering::SeqCst);
@@ -1482,10 +1482,10 @@ mod tests {
14821482
let mut q = vq.create_queue();
14831483
assert_eq!(vq.used.event.get(), 0);
14841484

1485-
q.set_avail_event(10, m);
1485+
q.set_used_ring_avail_event(10, m);
14861486
assert_eq!(vq.used.event.get(), 10);
14871487

1488-
q.set_avail_event(u16::MAX, m);
1488+
q.set_used_ring_avail_event(u16::MAX, m);
14891489
assert_eq!(vq.used.event.get(), u16::MAX);
14901490
}
14911491

0 commit comments

Comments
 (0)