Lines Matching refs:test_data_mpsc
61 } test_data_mpsc; variable
67 int *producer_timelines = test_data_mpsc.producer_timelines; in mpsc_producer_thread()
68 int consumer_timeline = test_data_mpsc.consumer_timeline; in mpsc_producer_thread()
69 int iterations = test_data_mpsc.iterations; in mpsc_producer_thread()
93 pthread_mutex_lock(&test_data_mpsc.lock); in mpsc_producer_thread()
94 test_data_mpsc.counter++; in mpsc_producer_thread()
95 pthread_mutex_unlock(&test_data_mpsc.lock); in mpsc_producer_thread()
109 int *producer_timelines = test_data_mpsc.producer_timelines; in mpcs_consumer_thread()
110 int consumer_timeline = test_data_mpsc.consumer_timeline; in mpcs_consumer_thread()
111 int iterations = test_data_mpsc.iterations; in mpcs_consumer_thread()
112 int n = test_data_mpsc.threads; in mpcs_consumer_thread()
140 ASSERT(test_data_mpsc.counter == n * it, in mpcs_consumer_thread()
166 test_data_mpsc.producer_timelines = producer_timelines; in test_consumer_stress_multi_producer_single_consumer()
167 test_data_mpsc.consumer_timeline = consumer_timeline; in test_consumer_stress_multi_producer_single_consumer()
168 test_data_mpsc.iterations = iterations; in test_consumer_stress_multi_producer_single_consumer()
169 test_data_mpsc.threads = n; in test_consumer_stress_multi_producer_single_consumer()
170 test_data_mpsc.counter = 0; in test_consumer_stress_multi_producer_single_consumer()
171 pthread_mutex_init(&test_data_mpsc.lock, NULL); in test_consumer_stress_multi_producer_single_consumer()