39 __mutex_init(struct mutex *lock, const char *name, struct lock_class_key *key)  in __mutex_init()  argument
41 	atomic_long_set(&lock->owner, 0);  in __mutex_init()
42 	spin_lock_init(&lock->wait_lock);  in __mutex_init()
43 	INIT_LIST_HEAD(&lock->wait_list);  in __mutex_init()
45 	osq_lock_init(&lock->osq);  in __mutex_init()
48 	debug_mutex_init(lock, name, key);  in __mutex_init()
80 static inline struct task_struct *__mutex_trylock_or_owner(struct mutex *lock)  in __mutex_trylock_or_owner()  argument
84 	owner = atomic_long_read(&lock->owner);  in __mutex_trylock_or_owner()
110 		old = atomic_long_cmpxchg_acquire(&lock->owner, owner, curr | flags);  in __mutex_trylock_or_owner()
123 static inline bool __mutex_trylock(struct mutex *lock)  in __mutex_trylock()  argument
125 	return !__mutex_trylock_or_owner(lock);  in __mutex_trylock()
139 static __always_inline bool __mutex_trylock_fast(struct mutex *lock)  in __mutex_trylock_fast()  argument
144 	if (atomic_long_try_cmpxchg_acquire(&lock->owner, &zero, curr))  in __mutex_trylock_fast()
150 static __always_inline bool __mutex_unlock_fast(struct mutex *lock)  in __mutex_unlock_fast()  argument
154 	if (atomic_long_cmpxchg_release(&lock->owner, curr, 0UL) == curr)  in __mutex_unlock_fast()
161 static inline void __mutex_set_flag(struct mutex *lock, unsigned long flag)  in __mutex_set_flag()  argument
163 	atomic_long_or(flag, &lock->owner);  in __mutex_set_flag()
166 static inline void __mutex_clear_flag(struct mutex *lock, unsigned long flag)  in __mutex_clear_flag()  argument
168 	atomic_long_andnot(flag, &lock->owner);  in __mutex_clear_flag()
171 static inline bool __mutex_waiter_is_first(struct mutex *lock, struct mutex_waiter *waiter)  in __mutex_waiter_is_first()  argument
173 	return list_first_entry(&lock->wait_list, struct mutex_waiter, list) == waiter;  in __mutex_waiter_is_first()
181 __mutex_add_waiter(struct mutex *lock, struct mutex_waiter *waiter,  in __mutex_add_waiter()  argument
184 	debug_mutex_add_waiter(lock, waiter, current);  in __mutex_add_waiter()
187 	if (__mutex_waiter_is_first(lock, waiter))  in __mutex_add_waiter()
188 		__mutex_set_flag(lock, MUTEX_FLAG_WAITERS);  in __mutex_add_waiter()
197 static void __mutex_handoff(struct mutex *lock, struct task_struct *task)  in __mutex_handoff()  argument
199 	unsigned long owner = atomic_long_read(&lock->owner);  in __mutex_handoff()
214 		old = atomic_long_cmpxchg_release(&lock->owner, owner, new);  in __mutex_handoff()
229 static void __sched __mutex_lock_slowpath(struct mutex *lock);
252 void __sched mutex_lock(struct mutex *lock)  in mutex_lock()  argument
256 	if (!__mutex_trylock_fast(lock))  in mutex_lock()
257 		__mutex_lock_slowpath(lock);  in mutex_lock()
340 __ww_mutex_die(struct mutex *lock, struct mutex_waiter *waiter,  in __ww_mutex_die()  argument
348 		debug_mutex_wake_waiter(lock, waiter);  in __ww_mutex_die()
362 static bool __ww_mutex_wound(struct mutex *lock,  in __ww_mutex_wound()  argument
366 	struct task_struct *owner = __mutex_owner(lock);  in __ww_mutex_wound()
368 	lockdep_assert_held(&lock->wait_lock);  in __ww_mutex_wound()
417 __ww_mutex_check_waiters(struct mutex *lock, struct ww_acquire_ctx *ww_ctx)  in __ww_mutex_check_waiters()  argument
421 	lockdep_assert_held(&lock->wait_lock);  in __ww_mutex_check_waiters()
423 	list_for_each_entry(cur, &lock->wait_list, list) {  in __ww_mutex_check_waiters()
427 		if (__ww_mutex_die(lock, cur, ww_ctx) ||  in __ww_mutex_check_waiters()
428 		    __ww_mutex_wound(lock, cur->ww_ctx, ww_ctx))  in __ww_mutex_check_waiters()
438 ww_mutex_set_context_fastpath(struct ww_mutex *lock, struct ww_acquire_ctx *ctx)  in ww_mutex_set_context_fastpath()  argument
440 	ww_mutex_lock_acquired(lock, ctx);  in ww_mutex_set_context_fastpath()
460 	if (likely(!(atomic_long_read(&lock->base.owner) & MUTEX_FLAG_WAITERS)))  in ww_mutex_set_context_fastpath()
467 	spin_lock(&lock->base.wait_lock);  in ww_mutex_set_context_fastpath()
468 	__ww_mutex_check_waiters(&lock->base, ctx);  in ww_mutex_set_context_fastpath()
469 	spin_unlock(&lock->base.wait_lock);  in ww_mutex_set_context_fastpath()
475 bool ww_mutex_spin_on_owner(struct mutex *lock, struct ww_acquire_ctx *ww_ctx,  in ww_mutex_spin_on_owner()  argument
480 	ww = container_of(lock, struct ww_mutex, base);  in ww_mutex_spin_on_owner()
503 	if (!waiter && (atomic_long_read(&lock->owner) & MUTEX_FLAG_WAITERS))  in ww_mutex_spin_on_owner()
510 	if (waiter && !__mutex_waiter_is_first(lock, waiter))  in ww_mutex_spin_on_owner()
523 bool mutex_spin_on_owner(struct mutex *lock, struct task_struct *owner,  in mutex_spin_on_owner()  argument
529 	while (__mutex_owner(lock) == owner) {  in mutex_spin_on_owner()
547 		if (ww_ctx && !ww_mutex_spin_on_owner(lock, ww_ctx, waiter)) {  in mutex_spin_on_owner()
562 static inline int mutex_can_spin_on_owner(struct mutex *lock)  in mutex_can_spin_on_owner()  argument
571 	owner = __mutex_owner(lock);  in mutex_can_spin_on_owner()
611 mutex_optimistic_spin(struct mutex *lock, struct ww_acquire_ctx *ww_ctx,  in mutex_optimistic_spin()  argument
622 		if (!mutex_can_spin_on_owner(lock))  in mutex_optimistic_spin()
630 		if (!osq_lock(&lock->osq))  in mutex_optimistic_spin()
638 		owner = __mutex_trylock_or_owner(lock);  in mutex_optimistic_spin()
646 		if (!mutex_spin_on_owner(lock, owner, ww_ctx, waiter))  in mutex_optimistic_spin()
659 		osq_unlock(&lock->osq);  in mutex_optimistic_spin()
666 		osq_unlock(&lock->osq);  in mutex_optimistic_spin()
687 mutex_optimistic_spin(struct mutex *lock, struct ww_acquire_ctx *ww_ctx,  in mutex_optimistic_spin()  argument
694 static noinline void __sched __mutex_unlock_slowpath(struct mutex *lock, unsigned long ip);
707 void __sched mutex_unlock(struct mutex *lock)  in mutex_unlock()  argument
710 	if (__mutex_unlock_fast(lock))  in mutex_unlock()
713 	__mutex_unlock_slowpath(lock, _RET_IP_);  in mutex_unlock()
728 void __sched ww_mutex_unlock(struct ww_mutex *lock)  in ww_mutex_unlock()  argument
734 	if (lock->ctx) {  in ww_mutex_unlock()
736 		DEBUG_LOCKS_WARN_ON(!lock->ctx->acquired);  in ww_mutex_unlock()
738 		if (lock->ctx->acquired > 0)  in ww_mutex_unlock()
739 			lock->ctx->acquired--;  in ww_mutex_unlock()
740 		lock->ctx = NULL;  in ww_mutex_unlock()
743 	mutex_unlock(&lock->base);  in ww_mutex_unlock()
749 __ww_mutex_kill(struct mutex *lock, struct ww_acquire_ctx *ww_ctx)  in __ww_mutex_kill()  argument
755 		ww = container_of(lock, struct ww_mutex, base);  in __ww_mutex_kill()
778 __ww_mutex_check_kill(struct mutex *lock, struct mutex_waiter *waiter,  in __ww_mutex_check_kill()  argument
781 	struct ww_mutex *ww = container_of(lock, struct ww_mutex, base);  in __ww_mutex_check_kill()
790 			return __ww_mutex_kill(lock, ctx);  in __ww_mutex_check_kill()
796 		return __ww_mutex_kill(lock, ctx);  in __ww_mutex_check_kill()
803 	list_for_each_entry_continue_reverse(cur, &lock->wait_list, list) {  in __ww_mutex_check_kill()
807 		return __ww_mutex_kill(lock, ctx);  in __ww_mutex_check_kill()
826 		      struct mutex *lock,  in __ww_mutex_add_waiter()  argument
834 		__mutex_add_waiter(lock, waiter, &lock->wait_list);  in __ww_mutex_add_waiter()
847 	pos = &lock->wait_list;  in __ww_mutex_add_waiter()
848 	list_for_each_entry_reverse(cur, &lock->wait_list, list) {  in __ww_mutex_add_waiter()
859 				int ret = __ww_mutex_kill(lock, ww_ctx);  in __ww_mutex_add_waiter()
871 		__ww_mutex_die(lock, cur, ww_ctx);  in __ww_mutex_add_waiter()
874 	__mutex_add_waiter(lock, waiter, pos);  in __ww_mutex_add_waiter()
881 		struct ww_mutex *ww = container_of(lock, struct ww_mutex, base);  in __ww_mutex_add_waiter()
889 		__ww_mutex_wound(lock, ww_ctx, ww->ctx);  in __ww_mutex_add_waiter()
899 __mutex_lock_common(struct mutex *lock, long state, unsigned int subclass,  in __mutex_lock_common()  argument
910 	ww = container_of(lock, struct ww_mutex, base);  in __mutex_lock_common()
925 	mutex_acquire_nest(&lock->dep_map, subclass, 0, nest_lock, ip);  in __mutex_lock_common()
927 	if (__mutex_trylock(lock) ||  in __mutex_lock_common()
928 	    mutex_optimistic_spin(lock, ww_ctx, use_ww_ctx, NULL)) {  in __mutex_lock_common()
930 		lock_acquired(&lock->dep_map, ip);  in __mutex_lock_common()
937 	spin_lock(&lock->wait_lock);  in __mutex_lock_common()
941 	if (__mutex_trylock(lock)) {  in __mutex_lock_common()
943 			__ww_mutex_check_waiters(lock, ww_ctx);  in __mutex_lock_common()
948 	debug_mutex_lock_common(lock, &waiter);  in __mutex_lock_common()
950 	lock_contended(&lock->dep_map, ip);  in __mutex_lock_common()
954 		__mutex_add_waiter(lock, &waiter, &lock->wait_list);  in __mutex_lock_common()
965 		ret = __ww_mutex_add_waiter(&waiter, lock, ww_ctx);  in __mutex_lock_common()
982 		if (__mutex_trylock(lock))  in __mutex_lock_common()
996 			ret = __ww_mutex_check_kill(lock, &waiter, ww_ctx);  in __mutex_lock_common()
1001 		spin_unlock(&lock->wait_lock);  in __mutex_lock_common()
1009 			first = __mutex_waiter_is_first(lock, &waiter);  in __mutex_lock_common()
1011 				__mutex_set_flag(lock, MUTEX_FLAG_HANDOFF);  in __mutex_lock_common()
1020 		if (__mutex_trylock(lock) ||  in __mutex_lock_common()
1021 		    (first && mutex_optimistic_spin(lock, ww_ctx, use_ww_ctx, &waiter)))  in __mutex_lock_common()
1024 		spin_lock(&lock->wait_lock);  in __mutex_lock_common()
1026 	spin_lock(&lock->wait_lock);  in __mutex_lock_common()
1036 		    !__mutex_waiter_is_first(lock, &waiter))  in __mutex_lock_common()
1037 			__ww_mutex_check_waiters(lock, ww_ctx);  in __mutex_lock_common()
1040 	mutex_remove_waiter(lock, &waiter, current);  in __mutex_lock_common()
1041 	if (likely(list_empty(&lock->wait_list)))  in __mutex_lock_common()
1042 		__mutex_clear_flag(lock, MUTEX_FLAGS);  in __mutex_lock_common()
1048 	lock_acquired(&lock->dep_map, ip);  in __mutex_lock_common()
1053 	spin_unlock(&lock->wait_lock);  in __mutex_lock_common()
1059 	mutex_remove_waiter(lock, &waiter, current);  in __mutex_lock_common()
1061 	spin_unlock(&lock->wait_lock);  in __mutex_lock_common()
1063 	mutex_release(&lock->dep_map, 1, ip);  in __mutex_lock_common()
1069 __mutex_lock(struct mutex *lock, long state, unsigned int subclass,  in __mutex_lock()  argument
1072 	return __mutex_lock_common(lock, state, subclass, nest_lock, ip, NULL, false);  in __mutex_lock()
1076 __ww_mutex_lock(struct mutex *lock, long state, unsigned int subclass,  in __ww_mutex_lock()  argument
1080 	return __mutex_lock_common(lock, state, subclass, nest_lock, ip, ww_ctx, true);  in __ww_mutex_lock()
1085 mutex_lock_nested(struct mutex *lock, unsigned int subclass)  in mutex_lock_nested()  argument
1087 	__mutex_lock(lock, TASK_UNINTERRUPTIBLE, subclass, NULL, _RET_IP_);  in mutex_lock_nested()
1093 _mutex_lock_nest_lock(struct mutex *lock, struct lockdep_map *nest)  in _mutex_lock_nest_lock()  argument
1095 	__mutex_lock(lock, TASK_UNINTERRUPTIBLE, 0, nest, _RET_IP_);  in _mutex_lock_nest_lock()
1100 mutex_lock_killable_nested(struct mutex *lock, unsigned int subclass)  in mutex_lock_killable_nested()  argument
1102 	return __mutex_lock(lock, TASK_KILLABLE, subclass, NULL, _RET_IP_);  in mutex_lock_killable_nested()
1107 mutex_lock_interruptible_nested(struct mutex *lock, unsigned int subclass)  in mutex_lock_interruptible_nested()  argument
1109 	return __mutex_lock(lock, TASK_INTERRUPTIBLE, subclass, NULL, _RET_IP_);  in mutex_lock_interruptible_nested()
1114 mutex_lock_io_nested(struct mutex *lock, unsigned int subclass)  in mutex_lock_io_nested()  argument
1121 	__mutex_lock_common(lock, TASK_UNINTERRUPTIBLE,  in mutex_lock_io_nested()
1128 ww_mutex_deadlock_injection(struct ww_mutex *lock, struct ww_acquire_ctx *ctx)  in ww_mutex_deadlock_injection()  argument
1142 		ctx->contending_lock = lock;  in ww_mutex_deadlock_injection()
1144 		ww_mutex_unlock(lock);  in ww_mutex_deadlock_injection()
1154 ww_mutex_lock(struct ww_mutex *lock, struct ww_acquire_ctx *ctx)  in ww_mutex_lock()  argument
1159 	ret =  __ww_mutex_lock(&lock->base, TASK_UNINTERRUPTIBLE,  in ww_mutex_lock()
1163 		return ww_mutex_deadlock_injection(lock, ctx);  in ww_mutex_lock()
1170 ww_mutex_lock_interruptible(struct ww_mutex *lock, struct ww_acquire_ctx *ctx)  in ww_mutex_lock_interruptible()  argument
1175 	ret = __ww_mutex_lock(&lock->base, TASK_INTERRUPTIBLE,  in ww_mutex_lock_interruptible()
1180 		return ww_mutex_deadlock_injection(lock, ctx);  in ww_mutex_lock_interruptible()
1191 static noinline void __sched __mutex_unlock_slowpath(struct mutex *lock, unsigned long ip)  in __mutex_unlock_slowpath()  argument
1197 	mutex_release(&lock->dep_map, 1, ip);  in __mutex_unlock_slowpath()
1206 	owner = atomic_long_read(&lock->owner);  in __mutex_unlock_slowpath()
1218 		old = atomic_long_cmpxchg_release(&lock->owner, owner,  in __mutex_unlock_slowpath()
1230 	spin_lock(&lock->wait_lock);  in __mutex_unlock_slowpath()
1231 	debug_mutex_unlock(lock);  in __mutex_unlock_slowpath()
1232 	if (!list_empty(&lock->wait_list)) {  in __mutex_unlock_slowpath()
1235 			list_first_entry(&lock->wait_list,  in __mutex_unlock_slowpath()
1240 		debug_mutex_wake_waiter(lock, waiter);  in __mutex_unlock_slowpath()
1245 		__mutex_handoff(lock, next);  in __mutex_unlock_slowpath()
1247 	spin_unlock(&lock->wait_lock);  in __mutex_unlock_slowpath()
1258 __mutex_lock_killable_slowpath(struct mutex *lock);
1261 __mutex_lock_interruptible_slowpath(struct mutex *lock);
1275 int __sched mutex_lock_interruptible(struct mutex *lock)  in mutex_lock_interruptible()  argument
1279 	if (__mutex_trylock_fast(lock))  in mutex_lock_interruptible()
1282 	return __mutex_lock_interruptible_slowpath(lock);  in mutex_lock_interruptible()
1299 int __sched mutex_lock_killable(struct mutex *lock)  in mutex_lock_killable()  argument
1303 	if (__mutex_trylock_fast(lock))  in mutex_lock_killable()
1306 	return __mutex_lock_killable_slowpath(lock);  in mutex_lock_killable()
1320 void __sched mutex_lock_io(struct mutex *lock)  in mutex_lock_io()  argument
1325 	mutex_lock(lock);  in mutex_lock_io()
1331 __mutex_lock_slowpath(struct mutex *lock)  in __mutex_lock_slowpath()  argument
1333 	__mutex_lock(lock, TASK_UNINTERRUPTIBLE, 0, NULL, _RET_IP_);  in __mutex_lock_slowpath()
1337 __mutex_lock_killable_slowpath(struct mutex *lock)  in __mutex_lock_killable_slowpath()  argument
1339 	return __mutex_lock(lock, TASK_KILLABLE, 0, NULL, _RET_IP_);  in __mutex_lock_killable_slowpath()
1343 __mutex_lock_interruptible_slowpath(struct mutex *lock)  in __mutex_lock_interruptible_slowpath()  argument
1345 	return __mutex_lock(lock, TASK_INTERRUPTIBLE, 0, NULL, _RET_IP_);  in __mutex_lock_interruptible_slowpath()
1349 __ww_mutex_lock_slowpath(struct ww_mutex *lock, struct ww_acquire_ctx *ctx)  in __ww_mutex_lock_slowpath()  argument
1351 	return __ww_mutex_lock(&lock->base, TASK_UNINTERRUPTIBLE, 0, NULL,  in __ww_mutex_lock_slowpath()
1356 __ww_mutex_lock_interruptible_slowpath(struct ww_mutex *lock,  in __ww_mutex_lock_interruptible_slowpath()  argument
1359 	return __ww_mutex_lock(&lock->base, TASK_INTERRUPTIBLE, 0, NULL,  in __ww_mutex_lock_interruptible_slowpath()
1379 int __sched mutex_trylock(struct mutex *lock)  in mutex_trylock()  argument
1381 	bool locked = __mutex_trylock(lock);  in mutex_trylock()
1384 		mutex_acquire(&lock->dep_map, 0, 1, _RET_IP_);  in mutex_trylock()
1392 ww_mutex_lock(struct ww_mutex *lock, struct ww_acquire_ctx *ctx)  in ww_mutex_lock()  argument
1396 	if (__mutex_trylock_fast(&lock->base)) {  in ww_mutex_lock()
1398 			ww_mutex_set_context_fastpath(lock, ctx);  in ww_mutex_lock()
1402 	return __ww_mutex_lock_slowpath(lock, ctx);  in ww_mutex_lock()
1407 ww_mutex_lock_interruptible(struct ww_mutex *lock, struct ww_acquire_ctx *ctx)  in ww_mutex_lock_interruptible()  argument
1411 	if (__mutex_trylock_fast(&lock->base)) {  in ww_mutex_lock_interruptible()
1413 			ww_mutex_set_context_fastpath(lock, ctx);  in ww_mutex_lock_interruptible()
1417 	return __ww_mutex_lock_interruptible_slowpath(lock, ctx);  in ww_mutex_lock_interruptible()
1430 int atomic_dec_and_mutex_lock(atomic_t *cnt, struct mutex *lock)  in atomic_dec_and_mutex_lock()  argument
1436 	mutex_lock(lock);  in atomic_dec_and_mutex_lock()
1439 		mutex_unlock(lock);  in atomic_dec_and_mutex_lock()