Lines Matching refs:tdata
601 static int thread_lookup_test(struct thread_data *tdata)
603 unsigned int entries = tdata->entries;
610 .tid = tdata->id,
614 if (obj && (tdata->objs[i].value.id == TEST_INSERT_FAIL)) {
617 } else if (!obj && (tdata->objs[i].value.id != TEST_INSERT_FAIL)) {
634 struct thread_data *tdata = data;
639 pr_err(" thread[%d]: interrupted\n", tdata->id);
643 for (i = 0; i < tdata->entries; i++) {
644 tdata->objs[i].value.id = i;
645 tdata->objs[i].value.tid = tdata->id;
646 err = insert_retry(&ht, &tdata->objs[i], test_rht_params);
651 tdata->id);
657 tdata->id, insert_retries);
659 err = thread_lookup_test(tdata);
662 tdata->id);
667 for (i = 0; i < tdata->entries; i += step) {
668 if (tdata->objs[i].value.id == TEST_INSERT_FAIL)
670 err = rhashtable_remove_fast(&ht, &tdata->objs[i].node,
674 tdata->id);
677 tdata->objs[i].value.id = TEST_INSERT_FAIL;
681 err = thread_lookup_test(tdata);
684 tdata->id);
701 struct thread_data *tdata;
761 tdata = vzalloc(array_size(tcount, sizeof(struct thread_data)));
762 if (!tdata)
766 vfree(tdata);
776 vfree(tdata);
781 tdata[i].id = i;
782 tdata[i].entries = entries;
783 tdata[i].objs = objs + i * entries;
784 tdata[i].task = kthread_run(threadfunc, &tdata[i],
786 if (IS_ERR(tdata[i].task)) {
799 if (IS_ERR(tdata[i].task))
801 if ((err = kthread_stop(tdata[i].task))) {
808 vfree(tdata);