602 static int thread_lookup_test(struct thread_data *tdata)  in thread_lookup_test()  argument
604 	unsigned int entries = tdata->entries;  in thread_lookup_test()
611 			.tid = tdata->id,  in thread_lookup_test()
615 		if (obj && (tdata->objs[i].value.id == TEST_INSERT_FAIL)) {  in thread_lookup_test()
618 		} else if (!obj && (tdata->objs[i].value.id != TEST_INSERT_FAIL)) {  in thread_lookup_test()
635 	struct thread_data *tdata = data;  in threadfunc()  local
639 		pr_err("  thread[%d]: down_interruptible failed\n", tdata->id);  in threadfunc()
641 	for (i = 0; i < tdata->entries; i++) {  in threadfunc()
642 		tdata->objs[i].value.id = i;  in threadfunc()
643 		tdata->objs[i].value.tid = tdata->id;  in threadfunc()
644 		err = insert_retry(&ht, &tdata->objs[i], test_rht_params);  in threadfunc()
649 			       tdata->id);  in threadfunc()
655 			tdata->id, insert_retries);  in threadfunc()
657 	err = thread_lookup_test(tdata);  in threadfunc()
660 		       tdata->id);  in threadfunc()
665 		for (i = 0; i < tdata->entries; i += step) {  in threadfunc()
666 			if (tdata->objs[i].value.id == TEST_INSERT_FAIL)  in threadfunc()
668 			err = rhashtable_remove_fast(&ht, &tdata->objs[i].node,  in threadfunc()
672 				       tdata->id);  in threadfunc()
675 			tdata->objs[i].value.id = TEST_INSERT_FAIL;  in threadfunc()
679 		err = thread_lookup_test(tdata);  in threadfunc()
682 			       tdata->id);  in threadfunc()
699 	struct thread_data *tdata;  in test_rht_init()  local
759 	tdata = vzalloc(array_size(tcount, sizeof(struct thread_data)));  in test_rht_init()
760 	if (!tdata)  in test_rht_init()
764 		vfree(tdata);  in test_rht_init()
774 		vfree(tdata);  in test_rht_init()
779 		tdata[i].id = i;  in test_rht_init()
780 		tdata[i].entries = entries;  in test_rht_init()
781 		tdata[i].objs = objs + i * entries;  in test_rht_init()
782 		tdata[i].task = kthread_run(threadfunc, &tdata[i],  in test_rht_init()
784 		if (IS_ERR(tdata[i].task))  in test_rht_init()
794 		if (IS_ERR(tdata[i].task))  in test_rht_init()
796 		if ((err = kthread_stop(tdata[i].task))) {  in test_rht_init()
803 	vfree(tdata);  in test_rht_init()