Unverified Commit 99690bd5 authored by openeuler-ci-bot's avatar openeuler-ci-bot Committed by Gitee
Browse files

!8370 locking/ww_mutex/test: Fix potential workqueue corruption 

Merge Pull Request from: @ci-robot 
 
PR sync from: Xie XiuQi <xiexiuqi@huawei.com>
https://mailweb.openeuler.org/hyperkitty/list/kernel@openeuler.org/message/AT7NJMLNR6YBX4INEEYS6HXEB67NTOGF/ 
 
https://gitee.com/openeuler/kernel/issues/I9RFIG 
 
Link:https://gitee.com/openeuler/kernel/pulls/8370

 

Reviewed-by: default avatarWei Li <liwei391@huawei.com>
Signed-off-by: default avatarJialin Zhang <zhangjialin11@huawei.com>
parents 1e4c3382 d05662e9

kernel/locking/test-ww_mutex.c

+12 −8
Original line number Diff line number Diff line
@@ -426,7 +426,6 @@ static void stress_inorder_work(struct work_struct *work) 
	} while (!time_after(jiffies, stress->timeout));



	kfree(order);

	kfree(stress);

}



struct reorder_lock {
@@ -491,7 +490,6 @@ static void stress_reorder_work(struct work_struct *work) 
	list_for_each_entry_safe(ll, ln, &locks, link)

		kfree(ll);

	kfree(order);

	kfree(stress);

}



static void stress_one_work(struct work_struct *work)
@@ -512,8 +510,6 @@ static void stress_one_work(struct work_struct *work) 
			break;

		}

	} while (!time_after(jiffies, stress->timeout));



	kfree(stress);

}



#define STRESS_INORDER BIT(0)
@@ -524,15 +520,24 @@ static void stress_one_work(struct work_struct *work) 
static int stress(int nlocks, int nthreads, unsigned int flags)

{

	struct ww_mutex *locks;

	int n;

	struct stress *stress_array;

	int n, count;



	locks = kmalloc_array(nlocks, sizeof(*locks), GFP_KERNEL);

	if (!locks)

		return -ENOMEM;



	stress_array = kmalloc_array(nthreads, sizeof(*stress_array),

				     GFP_KERNEL);

	if (!stress_array) {

		kfree(locks);

		return -ENOMEM;

	}



	for (n = 0; n < nlocks; n++)

		ww_mutex_init(&locks[n], &ww_class);



	count = 0;

	for (n = 0; nthreads; n++) {

		struct stress *stress;

		void (*fn)(struct work_struct *work);
@@ -556,9 +561,7 @@ static int stress(int nlocks, int nthreads, unsigned int flags) 
		if (!fn)

			continue;



		stress = kmalloc(sizeof(*stress), GFP_KERNEL);

		if (!stress)

			break;

		stress = &stress_array[count++];



		INIT_WORK(&stress->work, fn);

		stress->locks = locks;
@@ -573,6 +576,7 @@ static int stress(int nlocks, int nthreads, unsigned int flags) 


	for (n = 0; n < nlocks; n++)

		ww_mutex_destroy(&locks[n]);

	kfree(stress_array);

	kfree(locks);



	return 0;