Skip to content

Commit 21927fc

Browse files
anna-marialxKAGA-KOKO
authored andcommitted
timers: Retrieve next expiry of pinned/non-pinned timers separately
For the conversion of the NOHZ timer placement to a pull at expiry time model it's required to have separate expiry times for the pinned and the non-pinned (movable) timers. Therefore struct timer_events is introduced. No functional change Originally-by: Richard Cochran (linutronix GmbH) <richardcochran@gmail.com> Signed-off-by: Anna-Maria Behnsen <anna-maria@linutronix.de> Signed-off-by: Thomas Gleixner <tglx@linutronix.de> Reviewed-by: Frederic Weisbecker <frederic@kernel.org> Link: https://lore.kernel.org/r/20240221090548.36600-12-anna-maria@linutronix.de
1 parent 83a665d commit 21927fc

1 file changed

Lines changed: 31 additions & 4 deletions

File tree

kernel/time/timer.c

Lines changed: 31 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -266,6 +266,11 @@ struct timer_base {
266266

267267
static DEFINE_PER_CPU(struct timer_base, timer_bases[NR_BASES]);
268268

269+
struct timer_events {
270+
u64 local;
271+
u64 global;
272+
};
273+
269274
#ifdef CONFIG_NO_HZ_COMMON
270275

271276
static DEFINE_STATIC_KEY_FALSE(timers_nohz_active);
@@ -2031,10 +2036,11 @@ static unsigned long next_timer_interrupt(struct timer_base *base,
20312036
static inline u64 __get_next_timer_interrupt(unsigned long basej, u64 basem,
20322037
bool *idle)
20332038
{
2039+
struct timer_events tevt = { .local = KTIME_MAX, .global = KTIME_MAX };
20342040
unsigned long nextevt, nextevt_local, nextevt_global;
20352041
struct timer_base *base_local, *base_global;
2036-
u64 expires = KTIME_MAX;
20372042
bool local_first;
2043+
u64 expires;
20382044

20392045
/*
20402046
* Pretend that there is no timer pending if the cpu is offline.
@@ -2043,7 +2049,7 @@ static inline u64 __get_next_timer_interrupt(unsigned long basej, u64 basem,
20432049
if (cpu_is_offline(smp_processor_id())) {
20442050
if (idle)
20452051
*idle = true;
2046-
return expires;
2052+
return tevt.local;
20472053
}
20482054

20492055
base_local = this_cpu_ptr(&timer_bases[BASE_LOCAL]);
@@ -2059,13 +2065,32 @@ static inline u64 __get_next_timer_interrupt(unsigned long basej, u64 basem,
20592065

20602066
nextevt = local_first ? nextevt_local : nextevt_global;
20612067

2062-
if (base_local->timers_pending || base_global->timers_pending) {
2068+
/*
2069+
* If the @nextevt is at max. one tick away, use @nextevt and store
2070+
* it in the local expiry value. The next global event is irrelevant in
2071+
* this case and can be left as KTIME_MAX.
2072+
*/
2073+
if (time_before_eq(nextevt, basej + 1)) {
20632074
/* If we missed a tick already, force 0 delta */
20642075
if (time_before(nextevt, basej))
20652076
nextevt = basej;
2066-
expires = basem + (u64)(nextevt - basej) * TICK_NSEC;
2077+
tevt.local = basem + (u64)(nextevt - basej) * TICK_NSEC;
2078+
goto forward;
20672079
}
20682080

2081+
/*
2082+
* Update tevt.* values:
2083+
*
2084+
* If the local queue expires first, then the global event can be
2085+
* ignored. If the global queue is empty, nothing to do either.
2086+
*/
2087+
if (!local_first && base_global->timers_pending)
2088+
tevt.global = basem + (u64)(nextevt_global - basej) * TICK_NSEC;
2089+
2090+
if (base_local->timers_pending)
2091+
tevt.local = basem + (u64)(nextevt_local - basej) * TICK_NSEC;
2092+
2093+
forward:
20692094
/*
20702095
* We have a fresh next event. Check whether we can forward the
20712096
* base.
@@ -2096,6 +2121,8 @@ static inline u64 __get_next_timer_interrupt(unsigned long basej, u64 basem,
20962121
raw_spin_unlock(&base_global->lock);
20972122
raw_spin_unlock(&base_local->lock);
20982123

2124+
expires = min_t(u64, tevt.local, tevt.global);
2125+
20992126
return cmp_next_hrtimer_event(basem, expires);
21002127
}
21012128

0 commit comments

Comments
 (0)