10  * See the COPYING.LIB file in the top-level directory.
17 #include "qemu/error-report.h"
26 static __thread int id = -1;
41     data->cb(data->arg);  in ctx_run_bh_cb()
148      * is scheduled there is no guarantee that it will actually be woken up,  in test_multi_co_schedule_entry()
179     /* Guarantee that each AioContext is woken up from its last wait.  */  in test_multi_co_schedule()
201 /* CoMutex thread-safety.  */
205 static uint32_t counter;  variable
213         counter++;  in test_multi_co_mutex_entry()
218          * exits before the coroutine is woken up, causing a spurious  in test_multi_co_mutex_entry()
231     counter = 0;  in test_multi_co_mutex()
251     g_test_message("%d iterations/second", counter / seconds);  in test_multi_co_mutex()
252     g_assert_cmpint(counter, ==, atomic_counter);  in test_multi_co_mutex()
270  * case where the locker _can_ pick up a handoff is very rare, happening
297 static int mutex_head = -1;
303     nodes[id].next = -1;  in mcs_mutex_lock()
306     if (prev != -1) {  in mcs_mutex_lock()
315     if (qatomic_read(&nodes[id].next) == -1) {  in mcs_mutex_unlock()
317             qatomic_cmpxchg(&mutex_head, id, -1) == id) {  in mcs_mutex_unlock()
321         while (qatomic_read(&nodes[id].next) == -1) {  in mcs_mutex_unlock()
328     /* Wake up the next in line.  */  in mcs_mutex_unlock()
338         counter++;  in test_multi_fair_mutex_entry()
349     assert(mutex_head == -1);  in test_multi_fair_mutex()
350     counter = 0;  in test_multi_fair_mutex()
370     g_test_message("%d iterations/second", counter / seconds);  in test_multi_fair_mutex()
371     g_assert_cmpint(counter, ==, atomic_counter);  in test_multi_fair_mutex()
394         counter++;  in test_multi_mutex_entry()
406     counter = 0;  in test_multi_mutex()
426     g_test_message("%d iterations/second", counter / seconds);  in test_multi_mutex()
427     g_assert_cmpint(counter, ==, atomic_counter);  in test_multi_mutex()