Lines Matching refs:tdata
587 static int thread_lookup_test(struct thread_data *tdata) in thread_lookup_test() argument
589 unsigned int entries = tdata->entries; in thread_lookup_test()
596 .tid = tdata->id, in thread_lookup_test()
600 if (obj && (tdata->objs[i].value.id == TEST_INSERT_FAIL)) { in thread_lookup_test()
603 } else if (!obj && (tdata->objs[i].value.id != TEST_INSERT_FAIL)) { in thread_lookup_test()
620 struct thread_data *tdata = data; in threadfunc() local
625 pr_err(" thread[%d]: interrupted\n", tdata->id); in threadfunc()
629 for (i = 0; i < tdata->entries; i++) { in threadfunc()
630 tdata->objs[i].value.id = i; in threadfunc()
631 tdata->objs[i].value.tid = tdata->id; in threadfunc()
632 err = insert_retry(&ht, &tdata->objs[i], test_rht_params); in threadfunc()
637 tdata->id); in threadfunc()
643 tdata->id, insert_retries); in threadfunc()
645 err = thread_lookup_test(tdata); in threadfunc()
648 tdata->id); in threadfunc()
653 for (i = 0; i < tdata->entries; i += step) { in threadfunc()
654 if (tdata->objs[i].value.id == TEST_INSERT_FAIL) in threadfunc()
656 err = rhashtable_remove_fast(&ht, &tdata->objs[i].node, in threadfunc()
660 tdata->id); in threadfunc()
663 tdata->objs[i].value.id = TEST_INSERT_FAIL; in threadfunc()
667 err = thread_lookup_test(tdata); in threadfunc()
670 tdata->id); in threadfunc()
687 struct thread_data *tdata; in test_rht_init() local
747 tdata = vzalloc(array_size(tcount, sizeof(struct thread_data))); in test_rht_init()
748 if (!tdata) in test_rht_init()
752 vfree(tdata); in test_rht_init()
762 vfree(tdata); in test_rht_init()
767 tdata[i].id = i; in test_rht_init()
768 tdata[i].entries = entries; in test_rht_init()
769 tdata[i].objs = objs + i * entries; in test_rht_init()
770 tdata[i].task = kthread_run(threadfunc, &tdata[i], in test_rht_init()
772 if (IS_ERR(tdata[i].task)) { in test_rht_init()
785 if (IS_ERR(tdata[i].task)) in test_rht_init()
787 if ((err = kthread_stop(tdata[i].task))) { in test_rht_init()
794 vfree(tdata); in test_rht_init()