From patchwork Mon Jun 10 19:20:18 2024 Content-Type: text/plain; charset="utf-8" MIME-Version: 1.0 Content-Transfer-Encoding: 7bit X-Patchwork-Submitter: Qais Yousef X-Patchwork-Id: 13692380 Return-Path: X-Spam-Checker-Version: SpamAssassin 3.4.0 (2014-02-07) on aws-us-west-2-korg-lkml-1.web.codeaurora.org Received: from kanga.kvack.org (kanga.kvack.org [205.233.56.17]) by smtp.lore.kernel.org (Postfix) with ESMTP id B4AF6C27C65 for ; Mon, 10 Jun 2024 19:20:32 +0000 (UTC) Received: by kanga.kvack.org (Postfix) id 945116B009E; Mon, 10 Jun 2024 15:20:29 -0400 (EDT) Received: by kanga.kvack.org (Postfix, from userid 40) id 8CD556B009F; Mon, 10 Jun 2024 15:20:29 -0400 (EDT) X-Delivered-To: int-list-linux-mm@kvack.org Received: by kanga.kvack.org (Postfix, from userid 63042) id 6A9496B00A0; Mon, 10 Jun 2024 15:20:29 -0400 (EDT) X-Delivered-To: linux-mm@kvack.org Received: from relay.hostedemail.com (smtprelay0010.hostedemail.com [216.40.44.10]) by kanga.kvack.org (Postfix) with ESMTP id 4365F6B009E for ; Mon, 10 Jun 2024 15:20:29 -0400 (EDT) Received: from smtpin26.hostedemail.com (a10.router.float.18 [10.200.18.1]) by unirelay04.hostedemail.com (Postfix) with ESMTP id D15E21A02B6 for ; Mon, 10 Jun 2024 19:20:28 +0000 (UTC) X-FDA: 82215945336.26.C60A7AA Received: from mail-wr1-f50.google.com (mail-wr1-f50.google.com [209.85.221.50]) by imf01.hostedemail.com (Postfix) with ESMTP id E34F840003 for ; Mon, 10 Jun 2024 19:20:26 +0000 (UTC) Authentication-Results: imf01.hostedemail.com; dkim=pass header.d=layalina-io.20230601.gappssmtp.com header.s=20230601 header.b="mZa/+u2L"; spf=pass (imf01.hostedemail.com: domain of qyousef@layalina.io designates 209.85.221.50 as permitted sender) smtp.mailfrom=qyousef@layalina.io; dmarc=none ARC-Message-Signature: i=1; a=rsa-sha256; c=relaxed/relaxed; d=hostedemail.com; s=arc-20220608; t=1718047227; h=from:from:sender:reply-to:subject:subject:date:date: message-id:message-id:to:to:cc:cc:mime-version:mime-version: content-type:content-transfer-encoding:content-transfer-encoding: in-reply-to:in-reply-to:references:references:dkim-signature; bh=7+BUyWTb5ejwb40scgMVV37IExcyB94GWmaml8ACZ5M=; b=ZZtlm7NgT/9RdRIW6OnKQmZvaBtRXYZjrBRchIvjBsabMDeZTqqEGHaHJl0GZvfnMbjUAy 2RnYJrhnDUa2dTgXkRdhUkoPpMPhlIaEJXTv+POxpaRa7dnTNF+e9IQ8aa7IG5qmx8c8R3 ORWDq7RrXKDH1sP/I0nr2nsNI6g8xOM= ARC-Seal: i=1; s=arc-20220608; d=hostedemail.com; t=1718047227; a=rsa-sha256; cv=none; b=rhVJDllBdRgMBfgYfSOJsZOZXNKQ1RXTPDHrfuUt0LH+ztLAvWo0bHo6NS523B1BZvqtMb waiorAf9DGu1b5DIx2w1Ib1U9M1aQXHhdNiaOV5VSLmFd4FYKb7xKIeVhJjI7RTTWQdEu8 hlAR2KpfbzwlFGJ0SdvS17k/dDT+ujE= ARC-Authentication-Results: i=1; imf01.hostedemail.com; dkim=pass header.d=layalina-io.20230601.gappssmtp.com header.s=20230601 header.b="mZa/+u2L"; spf=pass (imf01.hostedemail.com: domain of qyousef@layalina.io designates 209.85.221.50 as permitted sender) smtp.mailfrom=qyousef@layalina.io; dmarc=none Received: by mail-wr1-f50.google.com with SMTP id ffacd0b85a97d-35f2bca1f33so73110f8f.0 for ; Mon, 10 Jun 2024 12:20:26 -0700 (PDT) DKIM-Signature: v=1; a=rsa-sha256; c=relaxed/relaxed; d=layalina-io.20230601.gappssmtp.com; s=20230601; t=1718047225; x=1718652025; darn=kvack.org; h=content-transfer-encoding:mime-version:references:in-reply-to :message-id:date:subject:cc:to:from:from:to:cc:subject:date :message-id:reply-to; bh=7+BUyWTb5ejwb40scgMVV37IExcyB94GWmaml8ACZ5M=; b=mZa/+u2Lqs7lL5PCKJzBTFYRGnHMLhHgMebCFTEzpymCVw2YFcEoAVdTHzISmfHGM2 nLYwqbvEUA7m/FX8q6P1knkhdGvyqwGjYXuDoCI/Xg0vW1tg3mXc9V6Ea7VraKZZQbXV Qkrbgfy7wc7L3cDbfNkQ6Ch5cDc98xzCSoFs9VrHds02JDe/GqFkaPv++p9i7NmtKkan kXsIOQHaVmSkaYcXTX1nqkCEyHMz+GNDxkFi23o7VMaH5VTITsTrI/+V/YMh+JUXnEj2 w9DJ+kBMTDYGOHjMuZNoi7E0I5X7GHVfHlkmMJRwDAfeCvv8/8/3wLlGw6+CEhQZg/Q5 rXkw== X-Google-DKIM-Signature: v=1; a=rsa-sha256; c=relaxed/relaxed; d=1e100.net; s=20230601; t=1718047225; x=1718652025; h=content-transfer-encoding:mime-version:references:in-reply-to :message-id:date:subject:cc:to:from:x-gm-message-state:from:to:cc :subject:date:message-id:reply-to; bh=7+BUyWTb5ejwb40scgMVV37IExcyB94GWmaml8ACZ5M=; b=mkv+DNfw6QklC2OxOA8xAZsn0zW0haKQO3hh8RmFwGdjfqHpCKjf9ZXeKEqSgDcq+n 8a7Y/rlrdGzl+dVRu0h1V4iwtyLw5+7ei6sq/l7LXEFvFNlezWws+KuaZVzOc690UGgt w/j7y7WZxtJ8Ri13xHFLF6ac+E9VF0ocNzODqvm3jcH3HgFAAW6k9DhmdeSO3U5/2m2q 4yCt2eShhc0peu+x1YrxNlEv2hDtchtwuEi7Gf88X2+N7qM/bOIMvXTSGJysJzZLhyph S9vBI8jqoY6u9Sf71nJ5qi543d5FK0YXAykNEuqZwW+++Ddomy/ypxUZnS2+w3KC7fbP tLqw== X-Forwarded-Encrypted: i=1; AJvYcCVaYun/7R/cQh2cygy9qwqxUvxK5FJaSSVY7N+T7wVKqfjboi7BZ/vW2qMz46Tq2w/tKLkYotjuEsKzFA8KOYtGQpE= X-Gm-Message-State: AOJu0YwZe6tcCR4D43W5Aw4p/f2ms1tWFAwmY3DVOP5XnK+1U12lIIoo +jdviSa7xghFEoyTUXPXNc2K7Yd2erXmFe184iKQQ90/5KMQnpaOc80/qg9vICM= X-Google-Smtp-Source: AGHT+IFEmccaDRTErf+/IywJcGZdVGcKvF9RKr33D7xwLfXpEeid9aCnSjIIdSDXO7wD+fLR4ulleA== X-Received: by 2002:adf:f38b:0:b0:354:e4da:ba52 with SMTP id ffacd0b85a97d-35f2b27ede7mr548597f8f.10.1718047225355; Mon, 10 Jun 2024 12:20:25 -0700 (PDT) Received: from airbuntu.. (host81-157-90-255.range81-157.btcentralplus.com. [81.157.90.255]) by smtp.gmail.com with ESMTPSA id ffacd0b85a97d-35f1f30c3ccsm4988326f8f.7.2024.06.10.12.20.24 (version=TLS1_3 cipher=TLS_AES_256_GCM_SHA384 bits=256/256); Mon, 10 Jun 2024 12:20:25 -0700 (PDT) From: Qais Yousef To: Ingo Molnar , Peter Zijlstra , Juri Lelli , Steven Rostedt Cc: Vincent Guittot , Daniel Bristot de Oliveira , Thomas Gleixner , Sebastian Andrzej Siewior , Alexander Viro , Christian Brauner , Andrew Morton , Jens Axboe , Metin Kaya , linux-kernel@vger.kernel.org, linux-fsdevel@vger.kernel.org, linux-trace-kernel@vger.kernel.org, linux-mm@kvack.org, Qais Yousef Subject: [PATCH v6 3/3] sched/rt: Rename realtime_{prio, task}() to rt_or_dl_{prio, task}() Date: Mon, 10 Jun 2024 20:20:18 +0100 Message-Id: <20240610192018.1567075-4-qyousef@layalina.io> X-Mailer: git-send-email 2.34.1 In-Reply-To: <20240610192018.1567075-1-qyousef@layalina.io> References: <20240610192018.1567075-1-qyousef@layalina.io> MIME-Version: 1.0 X-Rspamd-Queue-Id: E34F840003 X-Rspam-User: X-Rspamd-Server: rspam08 X-Stat-Signature: 3t9dxxx1rbwoi1r3qjmtx1ixfbckiwos X-HE-Tag: 1718047226-25338 X-HE-Meta: U2FsdGVkX1/pI/JgQCTPklSITw9uRCyydkWVK3KDfsT/hVZyCJ5zBvkXrlJaCfdGCUgtVmMs8CVIFNfT+2vVDJGaOMZYXY6ATZh8Wzx0a0iDWXi+ABTRDyxwTxN9Ygd06yGHEgChiqKR1/aqpUngpnkbiaymTo0BFVC+xrYSIPywL//dXWdg0+DmFz+yhlJJyB2ltIXLKxFaESMitn61s5ZtLuc9M+POKEtL0oHuOP8gMfI+mhI5YnrN5EqpL81tfu7XWoSinWCsc7NxP0QzEw2gH6lKzbmXVMRxvPNsO2UO2jSOOhiGLc9aCRcpeE01EJcJm17faTlDIduLY8emmWjCBh5sy0++XYxFlEVUtC9lZw7HxMHUaRmXXQ6GrLuIbtxX6tyAFOG+3rVFIpr4dQ37ar4a7CnB7pS86qa8fTfGwS5Tlq59YaWPRwce+utM1qer3GKu4BQojp9kBnjOtKaMZWGwoaVLWeSA2FvLZYSJMyY3RMtUKxlzGj5nuEG4yEk3xLMVdv+1kkt6PO7WnmhE7U1j9BYFUg5z1U4Lw2yMWIdeI7V9xNOr1pvswvK9xaVu3XwXD2e5fO+ZDjI8MgjfaK7w6YNZlaRu336JKir597C9f+IFz3gzA2bFCxDlXiTIgbizdK3IOuC3H3RTEux55ch+To42Bu1hpoRBFQvG6rtRQwplNC9A9siIdS+munkH7C1vquJ0YqsJwtLsWJPGXcBWZCcU9RLUS73oNCUr8DomMZuZW9qdnWkyjV1RY0J1db8r4n0E73HdSymvnDZSmdAvLsvo10bkgEDp7QTXOeBy2nTQXRorBb7ml1Sk3O0xcl8GLP4VIVp8w5vXIFupTQK+FQHzGu8X/GAkRvcUhP30wcReW3aulEX3t12CYqIM22NXlYcewJ7/U0FDJnJAquMYLrpnM5/BPr5fIsKjajWVxLUshYHWkWNLb1Voqg4PCVgEVjFxM33Uxfh TZ974tMr EyCQo65+wn/npv0VRgpnfzqJrThaDEnyc1JMkb6Bn77yz+OnDJA/kgdHQTFGjcwoeprZlQSd/l2TVi3tTFLl+HQ45992DeuPcEDwUyLY7e1FTTmxtq6ifH5apRS4Xqc5MLBm0PKhDpbyIpqRhF1aI21XPcde/LER///P03WR3ollTmYEL385LEPCHJ8gKyIAQl8hWvGwR9tHhPQoT1drHKpmM22kQiReV7rBU/koRWwcr42WeTeNdS1zrgb+CNxhgcSmyoRYyOM9OJvkQjrRDrDuLKY4LvX6qzyxTumWPrAkCWmrFmLbE0FvYFKplHWACYhwm2aGkrHxP/4WzYrXruE0ac8VFNW1eWtXtzcLgzLuX4l4= X-Bogosity: Ham, tests=bogofilter, spamicity=0.000000, version=1.2.4 Sender: owner-linux-mm@kvack.org Precedence: bulk X-Loop: owner-majordomo@kvack.org List-ID: List-Subscribe: List-Unsubscribe: Some find the name realtime overloaded. Use rt_or_dl() as an alternative, hopefully better, name. Suggested-by: Daniel Bristot de Oliveira Signed-off-by: Qais Yousef --- fs/bcachefs/six.c | 2 +- fs/select.c | 2 +- include/linux/ioprio.h | 2 +- include/linux/sched/rt.h | 10 +++++----- kernel/locking/rtmutex.c | 4 ++-- kernel/locking/rwsem.c | 4 ++-- kernel/locking/ww_mutex.h | 2 +- kernel/sched/core.c | 4 ++-- kernel/sched/syscalls.c | 2 +- kernel/time/hrtimer.c | 6 +++--- kernel/trace/trace_sched_wakeup.c | 2 +- mm/page-writeback.c | 4 ++-- mm/page_alloc.c | 2 +- 13 files changed, 23 insertions(+), 23 deletions(-) diff --git a/fs/bcachefs/six.c b/fs/bcachefs/six.c index b30870bf7e4a..9cbd3c14c94f 100644 --- a/fs/bcachefs/six.c +++ b/fs/bcachefs/six.c @@ -335,7 +335,7 @@ static inline bool six_owner_running(struct six_lock *lock) */ rcu_read_lock(); struct task_struct *owner = READ_ONCE(lock->owner); - bool ret = owner ? owner_on_cpu(owner) : !realtime_task(current); + bool ret = owner ? owner_on_cpu(owner) : !rt_or_dl_task(current); rcu_read_unlock(); return ret; diff --git a/fs/select.c b/fs/select.c index 8d5c1419416c..73fce145eb72 100644 --- a/fs/select.c +++ b/fs/select.c @@ -82,7 +82,7 @@ u64 select_estimate_accuracy(struct timespec64 *tv) * Realtime tasks get a slack of 0 for obvious reasons. */ - if (realtime_task(current)) + if (rt_or_dl_task(current)) return 0; ktime_get_ts64(&now); diff --git a/include/linux/ioprio.h b/include/linux/ioprio.h index 75859b78d540..b25377b6ea98 100644 --- a/include/linux/ioprio.h +++ b/include/linux/ioprio.h @@ -40,7 +40,7 @@ static inline int task_nice_ioclass(struct task_struct *task) { if (task->policy == SCHED_IDLE) return IOPRIO_CLASS_IDLE; - else if (realtime_task_policy(task)) + else if (rt_or_dl_task_policy(task)) return IOPRIO_CLASS_RT; else return IOPRIO_CLASS_BE; diff --git a/include/linux/sched/rt.h b/include/linux/sched/rt.h index 91ef1ef2019f..4e3338103654 100644 --- a/include/linux/sched/rt.h +++ b/include/linux/sched/rt.h @@ -11,7 +11,7 @@ static inline bool rt_prio(int prio) return unlikely(prio < MAX_RT_PRIO && prio >= MAX_DL_PRIO); } -static inline bool realtime_prio(int prio) +static inline bool rt_or_dl_prio(int prio) { return unlikely(prio < MAX_RT_PRIO); } @@ -27,19 +27,19 @@ static inline bool rt_task(struct task_struct *p) /* * Returns true if a task has a priority that belongs to RT or DL classes. - * PI-boosted tasks will return true. Use realtime_task_policy() to ignore + * PI-boosted tasks will return true. Use rt_or_dl_task_policy() to ignore * PI-boosted tasks. */ -static inline bool realtime_task(struct task_struct *p) +static inline bool rt_or_dl_task(struct task_struct *p) { - return realtime_prio(p->prio); + return rt_or_dl_prio(p->prio); } /* * Returns true if a task has a policy that belongs to RT or DL classes. * PI-boosted tasks will return false. */ -static inline bool realtime_task_policy(struct task_struct *tsk) +static inline bool rt_or_dl_task_policy(struct task_struct *tsk) { int policy = tsk->policy; diff --git a/kernel/locking/rtmutex.c b/kernel/locking/rtmutex.c index 55c9dab37f33..c2a530d704b4 100644 --- a/kernel/locking/rtmutex.c +++ b/kernel/locking/rtmutex.c @@ -347,7 +347,7 @@ static __always_inline int __waiter_prio(struct task_struct *task) { int prio = task->prio; - if (!realtime_prio(prio)) + if (!rt_or_dl_prio(prio)) return DEFAULT_PRIO; return prio; @@ -435,7 +435,7 @@ static inline bool rt_mutex_steal(struct rt_mutex_waiter *waiter, * Note that RT tasks are excluded from same priority (lateral) * steals to prevent the introduction of an unbounded latency. */ - if (realtime_prio(waiter->tree.prio)) + if (rt_or_dl_prio(waiter->tree.prio)) return false; return rt_waiter_node_equal(&waiter->tree, &top_waiter->tree); diff --git a/kernel/locking/rwsem.c b/kernel/locking/rwsem.c index ad8d4438bc91..dcbd7b45359a 100644 --- a/kernel/locking/rwsem.c +++ b/kernel/locking/rwsem.c @@ -631,7 +631,7 @@ static inline bool rwsem_try_write_lock(struct rw_semaphore *sem, * if it is an RT task or wait in the wait queue * for too long. */ - if (has_handoff || (!realtime_task(waiter->task) && + if (has_handoff || (!rt_or_dl_task(waiter->task) && !time_after(jiffies, waiter->timeout))) return false; @@ -914,7 +914,7 @@ static bool rwsem_optimistic_spin(struct rw_semaphore *sem) if (owner_state != OWNER_WRITER) { if (need_resched()) break; - if (realtime_task(current) && + if (rt_or_dl_task(current) && (prev_owner_state != OWNER_WRITER)) break; } diff --git a/kernel/locking/ww_mutex.h b/kernel/locking/ww_mutex.h index fa4b416a1f62..76d204b7d29c 100644 --- a/kernel/locking/ww_mutex.h +++ b/kernel/locking/ww_mutex.h @@ -237,7 +237,7 @@ __ww_ctx_less(struct ww_acquire_ctx *a, struct ww_acquire_ctx *b) int a_prio = a->task->prio; int b_prio = b->task->prio; - if (realtime_prio(a_prio) || realtime_prio(b_prio)) { + if (rt_or_dl_prio(a_prio) || rt_or_dl_prio(b_prio)) { if (a_prio > b_prio) return true; diff --git a/kernel/sched/core.c b/kernel/sched/core.c index 22c7efed83b4..001da474518e 100644 --- a/kernel/sched/core.c +++ b/kernel/sched/core.c @@ -163,7 +163,7 @@ static inline int __task_prio(const struct task_struct *p) if (p->sched_class == &stop_sched_class) /* trumps deadline */ return -2; - if (realtime_prio(p->prio)) /* includes deadline */ + if (rt_or_dl_prio(p->prio)) return p->prio; /* [-1, 99] */ if (p->sched_class == &idle_sched_class) @@ -8522,7 +8522,7 @@ void normalize_rt_tasks(void) schedstat_set(p->stats.sleep_start, 0); schedstat_set(p->stats.block_start, 0); - if (!realtime_task(p)) { + if (!rt_or_dl_task(p)) { /* * Renice negative nice level userspace * tasks back to 0: diff --git a/kernel/sched/syscalls.c b/kernel/sched/syscalls.c index 6d60326d73e4..60e70c889d91 100644 --- a/kernel/sched/syscalls.c +++ b/kernel/sched/syscalls.c @@ -57,7 +57,7 @@ static int effective_prio(struct task_struct *p) * keep the priority unchanged. Otherwise, update priority * to the normal priority: */ - if (!realtime_prio(p->prio)) + if (!rt_or_dl_prio(p->prio)) return p->normal_prio; return p->prio; } diff --git a/kernel/time/hrtimer.c b/kernel/time/hrtimer.c index 89d4da59059d..a4319131d4d0 100644 --- a/kernel/time/hrtimer.c +++ b/kernel/time/hrtimer.c @@ -1973,7 +1973,7 @@ static void __hrtimer_init_sleeper(struct hrtimer_sleeper *sl, * expiry. */ if (IS_ENABLED(CONFIG_PREEMPT_RT)) { - if (realtime_task_policy(current) && !(mode & HRTIMER_MODE_SOFT)) + if (rt_or_dl_task_policy(current) && !(mode & HRTIMER_MODE_SOFT)) mode |= HRTIMER_MODE_HARD; } @@ -2073,7 +2073,7 @@ long hrtimer_nanosleep(ktime_t rqtp, const enum hrtimer_mode mode, u64 slack; slack = current->timer_slack_ns; - if (realtime_task(current)) + if (rt_or_dl_task(current)) slack = 0; hrtimer_init_sleeper_on_stack(&t, clockid, mode); @@ -2278,7 +2278,7 @@ schedule_hrtimeout_range_clock(ktime_t *expires, u64 delta, * Override any slack passed by the user if under * rt contraints. */ - if (realtime_task(current)) + if (rt_or_dl_task(current)) delta = 0; hrtimer_init_sleeper_on_stack(&t, clock_id, mode); diff --git a/kernel/trace/trace_sched_wakeup.c b/kernel/trace/trace_sched_wakeup.c index 19d737742e29..3477fd858491 100644 --- a/kernel/trace/trace_sched_wakeup.c +++ b/kernel/trace/trace_sched_wakeup.c @@ -545,7 +545,7 @@ probe_wakeup(void *ignore, struct task_struct *p) * - wakeup_dl handles tasks belonging to sched_dl class only. */ if (tracing_dl || (wakeup_dl && !dl_task(p)) || - (wakeup_rt && !realtime_task(p)) || + (wakeup_rt && !rt_or_dl_task(p)) || (!dl_task(p) && (p->prio >= wakeup_prio || p->prio >= current->prio))) return; diff --git a/mm/page-writeback.c b/mm/page-writeback.c index d9464af1d992..43c189456cef 100644 --- a/mm/page-writeback.c +++ b/mm/page-writeback.c @@ -418,7 +418,7 @@ static void domain_dirty_limits(struct dirty_throttle_control *dtc) if (bg_thresh >= thresh) bg_thresh = thresh / 2; tsk = current; - if (realtime_task(tsk)) { + if (rt_or_dl_task(tsk)) { bg_thresh += bg_thresh / 4 + global_wb_domain.dirty_limit / 32; thresh += thresh / 4 + global_wb_domain.dirty_limit / 32; } @@ -468,7 +468,7 @@ static unsigned long node_dirty_limit(struct pglist_data *pgdat) else dirty = vm_dirty_ratio * node_memory / 100; - if (realtime_task(tsk)) + if (rt_or_dl_task(tsk)) dirty += dirty / 4; return dirty; diff --git a/mm/page_alloc.c b/mm/page_alloc.c index 807dd6aa3edb..623df61834be 100644 --- a/mm/page_alloc.c +++ b/mm/page_alloc.c @@ -3962,7 +3962,7 @@ gfp_to_alloc_flags(gfp_t gfp_mask, unsigned int order) */ if (alloc_flags & ALLOC_MIN_RESERVE) alloc_flags &= ~ALLOC_CPUSET; - } else if (unlikely(realtime_task(current)) && in_task()) + } else if (unlikely(rt_or_dl_task(current)) && in_task()) alloc_flags |= ALLOC_MIN_RESERVE; alloc_flags = gfp_to_alloc_flags_cma(gfp_mask, alloc_flags);