From: Zhao Liu <zhao1.liu@intel.com>
To: "Paolo Bonzini" <pbonzini@redhat.com>,
"Manos Pitsidianakis" <manos.pitsidianakis@linaro.org>,
"Marc-André Lureau" <marcandre.lureau@redhat.com>
Cc: Igor Mammedov <imammedo@redhat.com>,
qemu-devel@nongnu.org, qemu-rust@nongnu.org,
Zhao Liu <zhao1.liu@intel.com>
Subject: [PATCH 10/22] rust/hpet: Abstract HPETTimerRegisters struct
Date: Thu, 13 Nov 2025 13:19:25 +0800 [thread overview]
Message-ID: <20251113051937.4017675-11-zhao1.liu@intel.com> (raw)
In-Reply-To: <20251113051937.4017675-1-zhao1.liu@intel.com>
Place all timer N's registers in a HPETTimerRegisters struct.
This allows all Timer N registers to be grouped together with global
registers and managed using a single lock (BqlRefCell or Mutex) in
future. And this makes it easier to apply ToMigrationState macro.
Signed-off-by: Zhao Liu <zhao1.liu@intel.com>
---
rust/hw/timer/hpet/src/device.rs | 101 ++++++++++++++++++-------------
1 file changed, 60 insertions(+), 41 deletions(-)
diff --git a/rust/hw/timer/hpet/src/device.rs b/rust/hw/timer/hpet/src/device.rs
index 2105538cffe6..c7c0987aeb71 100644
--- a/rust/hw/timer/hpet/src/device.rs
+++ b/rust/hw/timer/hpet/src/device.rs
@@ -180,6 +180,18 @@ fn timer_handler(timer_cell: &BqlRefCell<HPETTimer>) {
timer_cell.borrow_mut().callback()
}
+#[repr(C)]
+#[derive(Debug, Default)]
+pub struct HPETTimerRegisters {
+ // Memory-mapped, software visible timer registers
+ /// Timer N Configuration and Capability Register
+ config: u64,
+ /// Timer N Comparator Value Register
+ cmp: u64,
+ /// Timer N FSB Interrupt Route Register
+ fsb: u64,
+}
+
/// HPET Timer Abstraction
#[repr(C)]
#[derive(Debug)]
@@ -191,14 +203,7 @@ pub struct HPETTimer {
/// timer block abstraction containing this timer
state: NonNull<HPETState>,
- // Memory-mapped, software visible timer registers
- /// Timer N Configuration and Capability Register
- config: u64,
- /// Timer N Comparator Value Register
- cmp: u64,
- /// Timer N FSB Interrupt Route Register
- fsb: u64,
-
+ regs: HPETTimerRegisters,
// Hidden register state
/// comparator (extended to counter width)
cmp64: u64,
@@ -223,9 +228,7 @@ fn new(index: u8, state: *const HPETState) -> HPETTimer {
// is initialized below.
qemu_timer: unsafe { Timer::new() },
state: NonNull::new(state.cast_mut()).unwrap(),
- config: 0,
- cmp: 0,
- fsb: 0,
+ regs: Default::default(),
cmp64: 0,
period: 0,
wrap_flag: 0,
@@ -252,32 +255,32 @@ fn is_int_active(&self) -> bool {
}
const fn is_fsb_route_enabled(&self) -> bool {
- self.config & (1 << HPET_TN_CFG_FSB_ENABLE_SHIFT) != 0
+ self.regs.config & (1 << HPET_TN_CFG_FSB_ENABLE_SHIFT) != 0
}
const fn is_periodic(&self) -> bool {
- self.config & (1 << HPET_TN_CFG_PERIODIC_SHIFT) != 0
+ self.regs.config & (1 << HPET_TN_CFG_PERIODIC_SHIFT) != 0
}
const fn is_int_enabled(&self) -> bool {
- self.config & (1 << HPET_TN_CFG_INT_ENABLE_SHIFT) != 0
+ self.regs.config & (1 << HPET_TN_CFG_INT_ENABLE_SHIFT) != 0
}
const fn is_32bit_mod(&self) -> bool {
- self.config & (1 << HPET_TN_CFG_32BIT_SHIFT) != 0
+ self.regs.config & (1 << HPET_TN_CFG_32BIT_SHIFT) != 0
}
const fn is_valset_enabled(&self) -> bool {
- self.config & (1 << HPET_TN_CFG_SETVAL_SHIFT) != 0
+ self.regs.config & (1 << HPET_TN_CFG_SETVAL_SHIFT) != 0
}
fn clear_valset(&mut self) {
- self.config &= !(1 << HPET_TN_CFG_SETVAL_SHIFT);
+ self.regs.config &= !(1 << HPET_TN_CFG_SETVAL_SHIFT);
}
/// True if timer interrupt is level triggered; otherwise, edge triggered.
const fn is_int_level_triggered(&self) -> bool {
- self.config & (1 << HPET_TN_CFG_INT_TYPE_SHIFT) != 0
+ self.regs.config & (1 << HPET_TN_CFG_INT_TYPE_SHIFT) != 0
}
/// calculate next value of the general counter that matches the
@@ -296,7 +299,7 @@ fn calculate_cmp64(&self, cur_tick: u64, target: u64) -> u64 {
}
const fn get_individual_route(&self) -> usize {
- ((self.config & HPET_TN_CFG_INT_ROUTE_MASK) >> HPET_TN_CFG_INT_ROUTE_SHIFT) as usize
+ ((self.regs.config & HPET_TN_CFG_INT_ROUTE_MASK) >> HPET_TN_CFG_INT_ROUTE_SHIFT) as usize
}
fn get_int_route(&self) -> usize {
@@ -334,8 +337,8 @@ fn set_irq(&self, set: bool) {
unsafe {
address_space_stl_le(
addr_of_mut!(address_space_memory),
- self.fsb >> 32, // Timer N FSB int addr
- self.fsb as u32, // Timer N FSB int value, truncate!
+ self.regs.fsb >> 32, // Timer N FSB int addr
+ self.regs.fsb as u32, // Timer N FSB int value, truncate!
MEMTXATTRS_UNSPECIFIED,
null_mut(),
);
@@ -375,7 +378,7 @@ fn set_timer(&mut self) {
let cur_tick: u64 = self.get_state().get_ticks();
self.wrap_flag = 0;
- self.cmp64 = self.calculate_cmp64(cur_tick, self.cmp);
+ self.cmp64 = self.calculate_cmp64(cur_tick, self.regs.cmp);
if self.is_32bit_mod() {
// HPET spec says in one-shot 32-bit mode, generate an interrupt when
// counter wraps in addition to an interrupt with comparator match.
@@ -403,25 +406,25 @@ fn del_timer(&self) {
/// Configuration and Capability Register
fn set_tn_cfg_reg(&mut self, shift: u32, len: u32, val: u64) {
// TODO: Add trace point - trace_hpet_ram_write_tn_cfg(addr & 4)
- let old_val: u64 = self.config;
+ let old_val: u64 = self.regs.config;
let mut new_val: u64 = old_val.deposit(shift, len, val);
new_val = hpet_fixup_reg(new_val, old_val, HPET_TN_CFG_WRITE_MASK);
// Switch level-type interrupt to edge-type.
if deactivating_bit(old_val, new_val, HPET_TN_CFG_INT_TYPE_SHIFT) {
- // Do this before changing timer.config; otherwise, if
+ // Do this before changing timer.regs.config; otherwise, if
// HPET_TN_FSB is set, update_irq will not lower the qemu_irq.
self.update_irq(false);
}
- self.config = new_val;
+ self.regs.config = new_val;
if activating_bit(old_val, new_val, HPET_TN_CFG_INT_ENABLE_SHIFT) && self.is_int_active() {
self.update_irq(true);
}
if self.is_32bit_mod() {
- self.cmp = u64::from(self.cmp as u32); // truncate!
+ self.regs.cmp = u64::from(self.regs.cmp as u32); // truncate!
self.period = u64::from(self.period as u32); // truncate!
}
@@ -447,7 +450,7 @@ fn set_tn_cmp_reg(&mut self, shift: u32, len: u32, val: u64) {
}
if !self.is_periodic() || self.is_valset_enabled() {
- self.cmp = self.cmp.deposit(shift, length, value);
+ self.regs.cmp = self.regs.cmp.deposit(shift, length, value);
}
if self.is_periodic() {
@@ -462,18 +465,19 @@ fn set_tn_cmp_reg(&mut self, shift: u32, len: u32, val: u64) {
/// FSB Interrupt Route Register
fn set_tn_fsb_route_reg(&mut self, shift: u32, len: u32, val: u64) {
- self.fsb = self.fsb.deposit(shift, len, val);
+ self.regs.fsb = self.regs.fsb.deposit(shift, len, val);
}
fn reset(&mut self) {
self.del_timer();
- self.cmp = u64::MAX; // Comparator Match Registers reset to all 1's.
- self.config = (1 << HPET_TN_CFG_PERIODIC_CAP_SHIFT) | (1 << HPET_TN_CFG_SIZE_CAP_SHIFT);
+ self.regs.cmp = u64::MAX; // Comparator Match Registers reset to all 1's.
+ self.regs.config =
+ (1 << HPET_TN_CFG_PERIODIC_CAP_SHIFT) | (1 << HPET_TN_CFG_SIZE_CAP_SHIFT);
if self.get_state().has_msi_flag() {
- self.config |= 1 << HPET_TN_CFG_FSB_CAP_SHIFT;
+ self.regs.config |= 1 << HPET_TN_CFG_FSB_CAP_SHIFT;
}
// advertise availability of ioapic int
- self.config |=
+ self.regs.config |=
(u64::from(self.get_state().int_route_cap)) << HPET_TN_CFG_INT_ROUTE_CAP_SHIFT;
self.period = 0;
self.wrap_flag = 0;
@@ -489,9 +493,9 @@ fn callback(&mut self) {
self.cmp64 += period;
}
if self.is_32bit_mod() {
- self.cmp = u64::from(self.cmp64 as u32); // truncate!
+ self.regs.cmp = u64::from(self.cmp64 as u32); // truncate!
} else {
- self.cmp = self.cmp64;
+ self.regs.cmp = self.cmp64;
}
self.arm_timer(self.cmp64);
} else if self.wrap_flag != 0 {
@@ -504,9 +508,9 @@ fn callback(&mut self) {
const fn read(&self, target: TimerRegister) -> u64 {
use TimerRegister::*;
match target {
- CFG => self.config, // including interrupt capabilities
- CMP => self.cmp, // comparator register
- ROUTE => self.fsb,
+ CFG => self.regs.config, // including interrupt capabilities
+ CMP => self.regs.cmp, // comparator register
+ ROUTE => self.regs.fsb,
}
}
@@ -865,7 +869,7 @@ fn post_load(&self, _version_id: u8) -> Result<(), migration::Infallible> {
for timer in self.timers.iter().take(self.num_timers) {
let mut t = timer.borrow_mut();
- t.cmp64 = t.calculate_cmp64(t.get_state().counter.get(), t.cmp);
+ t.cmp64 = t.calculate_cmp64(t.get_state().counter.get(), t.regs.cmp);
t.last = CLOCK_VIRTUAL.get_ns() - NANOSECONDS_PER_SECOND;
}
@@ -929,6 +933,22 @@ impl ObjectImpl for HPETState {
})
.build();
+// In fact, version_id and minimum_version_id for HPETTimerRegisters are
+// unrelated to HPETTimer's version IDs. Does not affect compatibility.
+impl_vmstate_struct!(
+ HPETTimerRegisters,
+ VMStateDescriptionBuilder::<HPETTimerRegisters>::new()
+ .name(c"hpet_timer/regs")
+ .version_id(1)
+ .minimum_version_id(1)
+ .fields(vmstate_fields! {
+ vmstate_of!(HPETTimerRegisters, config),
+ vmstate_of!(HPETTimerRegisters, cmp),
+ vmstate_of!(HPETTimerRegisters, fsb),
+ })
+ .build()
+);
+
const VMSTATE_HPET_TIMER: VMStateDescription<HPETTimer> =
VMStateDescriptionBuilder::<HPETTimer>::new()
.name(c"hpet_timer")
@@ -936,14 +956,13 @@ impl ObjectImpl for HPETState {
.minimum_version_id(1)
.fields(vmstate_fields! {
vmstate_of!(HPETTimer, index),
- vmstate_of!(HPETTimer, config),
- vmstate_of!(HPETTimer, cmp),
- vmstate_of!(HPETTimer, fsb),
+ vmstate_of!(HPETTimer, regs),
vmstate_of!(HPETTimer, period),
vmstate_of!(HPETTimer, wrap_flag),
vmstate_of!(HPETTimer, qemu_timer),
})
.build();
+
impl_vmstate_struct!(HPETTimer, VMSTATE_HPET_TIMER);
const VALIDATE_TIMERS_NAME: &CStr = c"num_timers must match";
--
2.34.1
next prev parent reply other threads:[~2025-11-13 5:03 UTC|newest]
Thread overview: 30+ messages / expand[flat|nested] mbox.gz Atom feed top
2025-11-13 5:19 [PATCH 00/22] rust/hpet: Move towards lockless IO, partly Zhao Liu
2025-11-13 5:19 ` [PATCH 01/22] rust/migration: Add Sync implementation for Migratable<> Zhao Liu
2025-11-13 5:19 ` [PATCH 02/22] rust/migration: Fix missing name in the VMSD of Migratable<> Zhao Liu
2025-11-13 5:19 ` [PATCH 03/22] rust/migration: Check name field in VMStateDescriptionBuilder Zhao Liu
2025-11-13 5:19 ` [PATCH 04/22] rust/bql: Add BqlGuard to provide BQL context Zhao Liu
2025-11-13 5:19 ` [PATCH 05/22] rust/bql: Ensure BQL locked early at BqlRefCell borrowing Zhao Liu
2025-11-13 5:19 ` [PATCH 06/22] rust/memory: Add enable_lockless_io binding Zhao Liu
2025-11-13 5:19 ` [PATCH 07/22] rust/hpet: Reduce unnecessary mutable self argument Zhao Liu
2025-11-13 5:19 ` [PATCH 08/22] rust/hpet: Rename HPETRegister to DecodedRegister Zhao Liu
2025-11-13 5:19 ` [PATCH 09/22] rust/hpet: Rename decoded "reg" enumeration to "target" Zhao Liu
2025-11-13 5:19 ` Zhao Liu [this message]
2025-11-13 11:24 ` [PATCH 10/22] rust/hpet: Abstract HPETTimerRegisters struct Paolo Bonzini
2025-11-14 4:37 ` Zhao Liu
2025-11-15 7:54 ` Paolo Bonzini
2025-11-13 5:19 ` [PATCH 11/22] rust/hpet: Make timer register accessors as methods of HPETTimerRegisters Zhao Liu
2025-11-13 5:19 ` [PATCH 12/22] rust/hpet: Abstract HPETRegisters struct Zhao Liu
2025-11-13 5:19 ` [PATCH 13/22] rust/hpet: Make global register accessors as methods of HPETRegisters Zhao Liu
2025-11-13 5:19 ` [PATCH 14/22] rust/hpet: Borrow HPETState.regs once in HPETState::post_load() Zhao Liu
2025-11-13 5:19 ` [PATCH 15/22] rust/hpet: Explicitly initialize complex fields in init() Zhao Liu
2025-11-13 5:19 ` [PATCH 16/22] rust/hpet: Pass &BqlRefCell<HPETRegisters> as argument during MMIO access Zhao Liu
2025-11-13 5:19 ` [PATCH 17/22] rust/hpet: Maintain HPETTimerRegisters in HPETRegisters Zhao Liu
2025-11-13 5:19 ` [PATCH 18/22] rust/hpet: Borrow BqlRefCell<HPETRegisters> at top level Zhao Liu
2025-11-13 5:19 ` [PATCH 19/22] rust/hpet: Rename hpet_regs variables to regs Zhao Liu
2025-11-13 5:19 ` [PATCH 20/22] rust/hpet: Apply Migratable<> wrapper and ToMigrationState for HPETRegisters Zhao Liu
2025-11-13 5:19 ` [PATCH 21/22] rust/hpet: Replace BqlRefCell<HPETRegisters> with Mutex<HPETRegisters> Zhao Liu
2025-11-13 9:31 ` Zhao Liu
2025-11-13 11:36 ` Zhao Liu
2025-11-13 5:19 ` [PATCH 22/22] rust/hpet: Enable lockless IO Zhao Liu
2025-11-13 14:29 ` Paolo Bonzini
2025-11-14 6:39 ` Zhao Liu
Reply instructions:
You may reply publicly to this message via plain-text email
using any one of the following methods:
* Save the following mbox file, import it into your mail client,
and reply-to-all from there: mbox
Avoid top-posting and favor interleaved quoting:
https://en.wikipedia.org/wiki/Posting_style#Interleaved_style
* Reply using the --to, --cc, and --in-reply-to
switches of git-send-email(1):
git send-email \
--in-reply-to=20251113051937.4017675-11-zhao1.liu@intel.com \
--to=zhao1.liu@intel.com \
--cc=imammedo@redhat.com \
--cc=manos.pitsidianakis@linaro.org \
--cc=marcandre.lureau@redhat.com \
--cc=pbonzini@redhat.com \
--cc=qemu-devel@nongnu.org \
--cc=qemu-rust@nongnu.org \
/path/to/YOUR_REPLY
https://kernel.org/pub/software/scm/git/docs/git-send-email.html
* If your mail client supports setting the In-Reply-To header
via mailto: links, try the mailto: link
Be sure your reply has a Subject: header at the top and a blank line
before the message body.
This is a public inbox, see mirroring instructions
for how to clone and mirror all data and code used for this inbox;
as well as URLs for NNTP newsgroup(s).