71 	struct prbtest_data *test_data;  member
117 	kunit_info(tr->test_data->test, "start thread %03lu (writer)\n", tr->num);  in prbtest_writer()
146 		if (prb_reserve(&e, tr->test_data->ringbuffer, &r)) {  in prbtest_writer()
156 			wake_up_interruptible(&tr->test_data->new_record_wait);  in prbtest_writer()
166 	kunit_info(tr->test_data->test, "end thread %03lu: wrote=%lu\n", tr->num, count);  in prbtest_writer()
184 static int prbtest_reader(struct prbtest_data *test_data, unsigned long timeout_ms)  in prbtest_reader()  argument
199 	kunit_info(test_data->test, "start reader\n");  in prbtest_reader()
201 	while (!wait_event_interruptible(test_data->new_record_wait,  in prbtest_reader()
202 					 prb_read_valid(test_data->ringbuffer, seq, &r))) {  in prbtest_reader()
205 			KUNIT_FAIL(test_data->test, "BAD SEQ READ: request=%llu read=%llu\n",  in prbtest_reader()
209 			prbtest_fail_record(test_data->test,  in prbtest_reader()
221 	kunit_info(test_data->test, "end reader: read=%lu seq=%llu\n", count, info.seq);  in prbtest_reader()
257 	struct prbtest_data *test_data;  in test_readerwriter()  local
285 	test_data = kunit_kmalloc(test, sizeof(*test_data), GFP_KERNEL);  in test_readerwriter()
286 	KUNIT_ASSERT_NOT_NULL(test, test_data);  in test_readerwriter()
287 	test_data->test = test;  in test_readerwriter()
288 	test_data->ringbuffer = &test_rb;  in test_readerwriter()
289 	init_waitqueue_head(&test_data->new_record_wait);  in test_readerwriter()
296 		thread_data->test_data = test_data;  in test_readerwriter()
308 	prbtest_reader(test_data, runtime_ms);  in test_readerwriter()