提交 6ebce3eb 编写于 作者: A Alex Kogan 提交者: Xie XiuQi

locking/qspinlock: Refactor the qspinlock slow path

hulk inclusion
category: feature
bugzilla: 13227
CVE: NA

-------------------------------------------------

Move some of the code manipulating the spin lock into separate functions.
This would allow easier integration of alternative ways to manipulate
that lock.
Signed-off-by: NAlex Kogan <alex.kogan@oracle.com>
Reviewed-by: NSteve Sistare <steven.sistare@oracle.com>
Signed-off-by: NWei Li <liwei391@huawei.com>
Signed-off-by: NYang Yingliang <yangyingliang@huawei.com>
上级 fea85437
...@@ -297,6 +297,36 @@ static __always_inline u32 __pv_wait_head_or_lock(struct qspinlock *lock, ...@@ -297,6 +297,36 @@ static __always_inline u32 __pv_wait_head_or_lock(struct qspinlock *lock,
#define queued_spin_lock_slowpath native_queued_spin_lock_slowpath #define queued_spin_lock_slowpath native_queued_spin_lock_slowpath
#endif #endif
/*
* set_locked_empty_mcs - Try to set the spinlock value to _Q_LOCKED_VAL,
* and by doing that unlock the MCS lock when its waiting queue is empty
* @lock: Pointer to queued spinlock structure
* @val: Current value of the lock
* @node: Pointer to the MCS node of the lock holder
*
* *,*,* -> 0,0,1
*/
static __always_inline bool __set_locked_empty_mcs(struct qspinlock *lock,
u32 val,
struct mcs_spinlock *node)
{
return atomic_try_cmpxchg_relaxed(&lock->val, &val, _Q_LOCKED_VAL);
}
/*
* pass_mcs_lock - pass the MCS lock to the next waiter
* @node: Pointer to the MCS node of the lock holder
* @next: Pointer to the MCS node of the first waiter in the MCS queue
*/
static __always_inline void __pass_mcs_lock(struct mcs_spinlock *node,
struct mcs_spinlock *next)
{
arch_mcs_spin_unlock_contended(&next->locked, 1);
}
#define set_locked_empty_mcs __set_locked_empty_mcs
#define pass_mcs_lock __pass_mcs_lock
#endif /* _GEN_PV_LOCK_SLOWPATH */ #endif /* _GEN_PV_LOCK_SLOWPATH */
/** /**
...@@ -531,7 +561,7 @@ void queued_spin_lock_slowpath(struct qspinlock *lock, u32 val) ...@@ -531,7 +561,7 @@ void queued_spin_lock_slowpath(struct qspinlock *lock, u32 val)
* necessary acquire semantics required for locking. * necessary acquire semantics required for locking.
*/ */
if (((val & _Q_TAIL_MASK) == tail) && if (((val & _Q_TAIL_MASK) == tail) &&
atomic_try_cmpxchg_relaxed(&lock->val, &val, _Q_LOCKED_VAL)) set_locked_empty_mcs(lock, val, node))
goto release; /* No contention */ goto release; /* No contention */
/* Either somebody is queued behind us or _Q_PENDING_VAL is set */ /* Either somebody is queued behind us or _Q_PENDING_VAL is set */
...@@ -543,7 +573,7 @@ void queued_spin_lock_slowpath(struct qspinlock *lock, u32 val) ...@@ -543,7 +573,7 @@ void queued_spin_lock_slowpath(struct qspinlock *lock, u32 val)
if (!next) if (!next)
next = smp_cond_load_relaxed(&node->next, (VAL)); next = smp_cond_load_relaxed(&node->next, (VAL));
arch_mcs_spin_unlock_contended(&next->locked, 1); pass_mcs_lock(node, next);
pv_kick_node(lock, next); pv_kick_node(lock, next);
release: release:
...@@ -568,6 +598,12 @@ EXPORT_SYMBOL(queued_spin_lock_slowpath); ...@@ -568,6 +598,12 @@ EXPORT_SYMBOL(queued_spin_lock_slowpath);
#undef pv_kick_node #undef pv_kick_node
#undef pv_wait_head_or_lock #undef pv_wait_head_or_lock
#undef set_locked_empty_mcs
#define set_locked_empty_mcs __set_locked_empty_mcs
#undef pass_mcs_lock
#define pass_mcs_lock __pass_mcs_lock
#undef queued_spin_lock_slowpath #undef queued_spin_lock_slowpath
#define queued_spin_lock_slowpath __pv_queued_spin_lock_slowpath #define queued_spin_lock_slowpath __pv_queued_spin_lock_slowpath
......
Markdown is supported
0% .
You are about to add 0 people to the discussion. Proceed with caution.
先完成此消息的编辑!
想要评论请 注册