32 static void wait_until_inactive(EventNotifierTestData *data)  in wait_until_inactive()  argument
34     while (data->active > 0) {  in wait_until_inactive()
58     BHTestData *data = opaque;  in bh_test_cb()  local
59     if (++data->n < data->max) {  in bh_test_cb()
60         qemu_bh_schedule(data->bh);  in bh_test_cb()
66     TimerTestData *data = opaque;  in timer_test_cb()  local
67     if (++data->n < data->max) {  in timer_test_cb()
68         timer_mod(&data->timer,  in timer_test_cb()
69                   qemu_clock_get_ns(data->clock_type) + data->ns);  in timer_test_cb()
79     BHTestData *data = opaque;  in bh_delete_cb()  local
80     if (++data->n < data->max) {  in bh_delete_cb()
81         qemu_bh_schedule(data->bh);  in bh_delete_cb()
83         qemu_bh_delete(data->bh);  in bh_delete_cb()
84         data->bh = NULL;  in bh_delete_cb()
90     EventNotifierTestData *data = container_of(e, EventNotifierTestData, e);  in event_ready_cb()  local
92     data->n++;  in event_ready_cb()
93     if (data->active > 0) {  in event_ready_cb()
94         data->active--;  in event_ready_cb()
96     if (data->auto_set && data->active) {  in event_ready_cb()
111     BHTestData data = { .n = 0 };  in test_bh_schedule()  local
112     data.bh = aio_bh_new(ctx, bh_test_cb, &data);  in test_bh_schedule()
114     qemu_bh_schedule(data.bh);  in test_bh_schedule()
115     g_assert_cmpint(data.n, ==, 0);  in test_bh_schedule()
118     g_assert_cmpint(data.n, ==, 1);  in test_bh_schedule()
121     g_assert_cmpint(data.n, ==, 1);  in test_bh_schedule()
122     qemu_bh_delete(data.bh);  in test_bh_schedule()
127     BHTestData data = { .n = 0, .max = 10 };  in test_bh_schedule10()  local
128     data.bh = aio_bh_new(ctx, bh_test_cb, &data);  in test_bh_schedule10()
130     qemu_bh_schedule(data.bh);  in test_bh_schedule10()
131     g_assert_cmpint(data.n, ==, 0);  in test_bh_schedule10()
134     g_assert_cmpint(data.n, ==, 1);  in test_bh_schedule10()
137     g_assert_cmpint(data.n, ==, 2);  in test_bh_schedule10()
139     while (data.n < 10) {  in test_bh_schedule10()
142     g_assert_cmpint(data.n, ==, 10);  in test_bh_schedule10()
145     g_assert_cmpint(data.n, ==, 10);  in test_bh_schedule10()
146     qemu_bh_delete(data.bh);  in test_bh_schedule10()
151     BHTestData data = { .n = 0 };  in test_bh_cancel()  local
152     data.bh = aio_bh_new(ctx, bh_test_cb, &data);  in test_bh_cancel()
154     qemu_bh_schedule(data.bh);  in test_bh_cancel()
155     g_assert_cmpint(data.n, ==, 0);  in test_bh_cancel()
157     qemu_bh_cancel(data.bh);  in test_bh_cancel()
158     g_assert_cmpint(data.n, ==, 0);  in test_bh_cancel()
161     g_assert_cmpint(data.n, ==, 0);  in test_bh_cancel()
162     qemu_bh_delete(data.bh);  in test_bh_cancel()
167     BHTestData data = { .n = 0 };  in test_bh_delete()  local
168     data.bh = aio_bh_new(ctx, bh_test_cb, &data);  in test_bh_delete()
170     qemu_bh_schedule(data.bh);  in test_bh_delete()
171     g_assert_cmpint(data.n, ==, 0);  in test_bh_delete()
173     qemu_bh_delete(data.bh);  in test_bh_delete()
174     g_assert_cmpint(data.n, ==, 0);  in test_bh_delete()
177     g_assert_cmpint(data.n, ==, 0);  in test_bh_delete()
244     BHTestData data = { .n = 0 };  in test_bh_flush()  local
245     data.bh = aio_bh_new(ctx, bh_test_cb, &data);  in test_bh_flush()
247     qemu_bh_schedule(data.bh);  in test_bh_flush()
248     g_assert_cmpint(data.n, ==, 0);  in test_bh_flush()
251     g_assert_cmpint(data.n, ==, 1);  in test_bh_flush()
254     g_assert_cmpint(data.n, ==, 1);  in test_bh_flush()
255     qemu_bh_delete(data.bh);  in test_bh_flush()
260     EventNotifierTestData data = { .n = 0, .active = 0 };  in test_set_event_notifier()  local
261     event_notifier_init(&data.e, false);  in test_set_event_notifier()
262     set_event_notifier(ctx, &data.e, event_ready_cb);  in test_set_event_notifier()
264     g_assert_cmpint(data.n, ==, 0);  in test_set_event_notifier()
266     set_event_notifier(ctx, &data.e, NULL);  in test_set_event_notifier()
268     g_assert_cmpint(data.n, ==, 0);  in test_set_event_notifier()
269     event_notifier_cleanup(&data.e);  in test_set_event_notifier()
274     EventNotifierTestData data = { .n = 0, .active = 1 };  in test_wait_event_notifier()  local
275     event_notifier_init(&data.e, false);  in test_wait_event_notifier()
276     set_event_notifier(ctx, &data.e, event_ready_cb);  in test_wait_event_notifier()
278     g_assert_cmpint(data.n, ==, 0);  in test_wait_event_notifier()
279     g_assert_cmpint(data.active, ==, 1);  in test_wait_event_notifier()
281     event_notifier_set(&data.e);  in test_wait_event_notifier()
283     g_assert_cmpint(data.n, ==, 1);  in test_wait_event_notifier()
284     g_assert_cmpint(data.active, ==, 0);  in test_wait_event_notifier()
287     g_assert_cmpint(data.n, ==, 1);  in test_wait_event_notifier()
288     g_assert_cmpint(data.active, ==, 0);  in test_wait_event_notifier()
290     set_event_notifier(ctx, &data.e, NULL);  in test_wait_event_notifier()
292     g_assert_cmpint(data.n, ==, 1);  in test_wait_event_notifier()
294     event_notifier_cleanup(&data.e);  in test_wait_event_notifier()
299     EventNotifierTestData data = { .n = 0, .active = 10, .auto_set = true };  in test_flush_event_notifier()  local
300     event_notifier_init(&data.e, false);  in test_flush_event_notifier()
301     set_event_notifier(ctx, &data.e, event_ready_cb);  in test_flush_event_notifier()
303     g_assert_cmpint(data.n, ==, 0);  in test_flush_event_notifier()
304     g_assert_cmpint(data.active, ==, 10);  in test_flush_event_notifier()
306     event_notifier_set(&data.e);  in test_flush_event_notifier()
308     g_assert_cmpint(data.n, ==, 1);  in test_flush_event_notifier()
309     g_assert_cmpint(data.active, ==, 9);  in test_flush_event_notifier()
312     wait_until_inactive(&data);  in test_flush_event_notifier()
313     g_assert_cmpint(data.n, ==, 10);  in test_flush_event_notifier()
314     g_assert_cmpint(data.active, ==, 0);  in test_flush_event_notifier()
317     set_event_notifier(ctx, &data.e, NULL);  in test_flush_event_notifier()
319     event_notifier_cleanup(&data.e);  in test_flush_event_notifier()
324     EventNotifierTestData data = { .n = 0 };  in test_wait_event_notifier_noflush()  local
327     event_notifier_init(&data.e, false);  in test_wait_event_notifier_noflush()
328     set_event_notifier(ctx, &data.e, event_ready_cb);  in test_wait_event_notifier_noflush()
331     g_assert_cmpint(data.n, ==, 0);  in test_wait_event_notifier_noflush()
335     event_notifier_set(&data.e);  in test_wait_event_notifier_noflush()
337     data.n = 0;  in test_wait_event_notifier_noflush()
343     event_notifier_set(&data.e);  in test_wait_event_notifier_noflush()
345     g_assert_cmpint(data.n, ==, 1);  in test_wait_event_notifier_noflush()
347     g_assert_cmpint(data.n, ==, 1);  in test_wait_event_notifier_noflush()
349     event_notifier_set(&data.e);  in test_wait_event_notifier_noflush()
351     g_assert_cmpint(data.n, ==, 2);  in test_wait_event_notifier_noflush()
353     g_assert_cmpint(data.n, ==, 2);  in test_wait_event_notifier_noflush()
357     g_assert_cmpint(data.n, ==, 2);  in test_wait_event_notifier_noflush()
364     set_event_notifier(ctx, &data.e, NULL);  in test_wait_event_notifier_noflush()
366     g_assert_cmpint(data.n, ==, 2);  in test_wait_event_notifier_noflush()
368     event_notifier_cleanup(&data.e);  in test_wait_event_notifier_noflush()
373     TimerTestData data = { .n = 0, .ctx = ctx, .ns = SCALE_MS * 750LL,  in test_timer_schedule()  local
385     aio_timer_init(ctx, &data.timer, data.clock_type,  in test_timer_schedule()
386                    SCALE_NS, timer_test_cb, &data);  in test_timer_schedule()
387     timer_mod(&data.timer,  in test_timer_schedule()
388               qemu_clock_get_ns(data.clock_type) +  in test_timer_schedule()
389               data.ns);  in test_timer_schedule()
391     g_assert_cmpint(data.n, ==, 0);  in test_timer_schedule()
399     g_assert_cmpint(data.n, ==, 0);  in test_timer_schedule()
402     g_assert_cmpint(data.n, ==, 0);  in test_timer_schedule()
405     g_assert_cmpint(data.n, ==, 1);  in test_timer_schedule()
411     g_assert_cmpint(data.n, ==, 1);  in test_timer_schedule()
414     g_assert_cmpint(data.n, ==, 2);  in test_timer_schedule()
419     g_assert_cmpint(data.n, ==, 2);  in test_timer_schedule()
424     timer_del(&data.timer);  in test_timer_schedule()
450     BHTestData data = { .n = 0 };  in test_source_bh_schedule()  local
451     data.bh = aio_bh_new(ctx, bh_test_cb, &data);  in test_source_bh_schedule()
453     qemu_bh_schedule(data.bh);  in test_source_bh_schedule()
454     g_assert_cmpint(data.n, ==, 0);  in test_source_bh_schedule()
457     g_assert_cmpint(data.n, ==, 1);  in test_source_bh_schedule()
460     g_assert_cmpint(data.n, ==, 1);  in test_source_bh_schedule()
461     qemu_bh_delete(data.bh);  in test_source_bh_schedule()
466     BHTestData data = { .n = 0, .max = 10 };  in test_source_bh_schedule10()  local
467     data.bh = aio_bh_new(ctx, bh_test_cb, &data);  in test_source_bh_schedule10()
469     qemu_bh_schedule(data.bh);  in test_source_bh_schedule10()
470     g_assert_cmpint(data.n, ==, 0);  in test_source_bh_schedule10()
473     g_assert_cmpint(data.n, ==, 1);  in test_source_bh_schedule10()
476     g_assert_cmpint(data.n, ==, 2);  in test_source_bh_schedule10()
479     g_assert_cmpint(data.n, ==, 10);  in test_source_bh_schedule10()
482     g_assert_cmpint(data.n, ==, 10);  in test_source_bh_schedule10()
483     qemu_bh_delete(data.bh);  in test_source_bh_schedule10()
488     BHTestData data = { .n = 0 };  in test_source_bh_cancel()  local
489     data.bh = aio_bh_new(ctx, bh_test_cb, &data);  in test_source_bh_cancel()
491     qemu_bh_schedule(data.bh);  in test_source_bh_cancel()
492     g_assert_cmpint(data.n, ==, 0);  in test_source_bh_cancel()
494     qemu_bh_cancel(data.bh);  in test_source_bh_cancel()
495     g_assert_cmpint(data.n, ==, 0);  in test_source_bh_cancel()
498     g_assert_cmpint(data.n, ==, 0);  in test_source_bh_cancel()
499     qemu_bh_delete(data.bh);  in test_source_bh_cancel()
504     BHTestData data = { .n = 0 };  in test_source_bh_delete()  local
505     data.bh = aio_bh_new(ctx, bh_test_cb, &data);  in test_source_bh_delete()
507     qemu_bh_schedule(data.bh);  in test_source_bh_delete()
508     g_assert_cmpint(data.n, ==, 0);  in test_source_bh_delete()
510     qemu_bh_delete(data.bh);  in test_source_bh_delete()
511     g_assert_cmpint(data.n, ==, 0);  in test_source_bh_delete()
514     g_assert_cmpint(data.n, ==, 0);  in test_source_bh_delete()
575     BHTestData data = { .n = 0 };  in test_source_bh_flush()  local
576     data.bh = aio_bh_new(ctx, bh_test_cb, &data);  in test_source_bh_flush()
578     qemu_bh_schedule(data.bh);  in test_source_bh_flush()
579     g_assert_cmpint(data.n, ==, 0);  in test_source_bh_flush()
582     g_assert_cmpint(data.n, ==, 1);  in test_source_bh_flush()
585     g_assert_cmpint(data.n, ==, 1);  in test_source_bh_flush()
586     qemu_bh_delete(data.bh);  in test_source_bh_flush()
591     EventNotifierTestData data = { .n = 0, .active = 0 };  in test_source_set_event_notifier()  local
592     event_notifier_init(&data.e, false);  in test_source_set_event_notifier()
593     set_event_notifier(ctx, &data.e, event_ready_cb);  in test_source_set_event_notifier()
595     g_assert_cmpint(data.n, ==, 0);  in test_source_set_event_notifier()
597     set_event_notifier(ctx, &data.e, NULL);  in test_source_set_event_notifier()
599     g_assert_cmpint(data.n, ==, 0);  in test_source_set_event_notifier()
600     event_notifier_cleanup(&data.e);  in test_source_set_event_notifier()
605     EventNotifierTestData data = { .n = 0, .active = 1 };  in test_source_wait_event_notifier()  local
606     event_notifier_init(&data.e, false);  in test_source_wait_event_notifier()
607     set_event_notifier(ctx, &data.e, event_ready_cb);  in test_source_wait_event_notifier()
609     g_assert_cmpint(data.n, ==, 0);  in test_source_wait_event_notifier()
610     g_assert_cmpint(data.active, ==, 1);  in test_source_wait_event_notifier()
612     event_notifier_set(&data.e);  in test_source_wait_event_notifier()
614     g_assert_cmpint(data.n, ==, 1);  in test_source_wait_event_notifier()
615     g_assert_cmpint(data.active, ==, 0);  in test_source_wait_event_notifier()
618     g_assert_cmpint(data.n, ==, 1);  in test_source_wait_event_notifier()
619     g_assert_cmpint(data.active, ==, 0);  in test_source_wait_event_notifier()
621     set_event_notifier(ctx, &data.e, NULL);  in test_source_wait_event_notifier()
623     g_assert_cmpint(data.n, ==, 1);  in test_source_wait_event_notifier()
625     event_notifier_cleanup(&data.e);  in test_source_wait_event_notifier()
630     EventNotifierTestData data = { .n = 0, .active = 10, .auto_set = true };  in test_source_flush_event_notifier()  local
631     event_notifier_init(&data.e, false);  in test_source_flush_event_notifier()
632     set_event_notifier(ctx, &data.e, event_ready_cb);  in test_source_flush_event_notifier()
634     g_assert_cmpint(data.n, ==, 0);  in test_source_flush_event_notifier()
635     g_assert_cmpint(data.active, ==, 10);  in test_source_flush_event_notifier()
637     event_notifier_set(&data.e);  in test_source_flush_event_notifier()
639     g_assert_cmpint(data.n, ==, 1);  in test_source_flush_event_notifier()
640     g_assert_cmpint(data.active, ==, 9);  in test_source_flush_event_notifier()
644     g_assert_cmpint(data.n, ==, 10);  in test_source_flush_event_notifier()
645     g_assert_cmpint(data.active, ==, 0);  in test_source_flush_event_notifier()
648     set_event_notifier(ctx, &data.e, NULL);  in test_source_flush_event_notifier()
650     event_notifier_cleanup(&data.e);  in test_source_flush_event_notifier()
655     EventNotifierTestData data = { .n = 0 };  in test_source_wait_event_notifier_noflush()  local
658     event_notifier_init(&data.e, false);  in test_source_wait_event_notifier_noflush()
659     set_event_notifier(ctx, &data.e, event_ready_cb);  in test_source_wait_event_notifier_noflush()
662     g_assert_cmpint(data.n, ==, 0);  in test_source_wait_event_notifier_noflush()
666     event_notifier_set(&data.e);  in test_source_wait_event_notifier_noflush()
668     data.n = 0;  in test_source_wait_event_notifier_noflush()
674     event_notifier_set(&data.e);  in test_source_wait_event_notifier_noflush()
676     g_assert_cmpint(data.n, ==, 1);  in test_source_wait_event_notifier_noflush()
678     g_assert_cmpint(data.n, ==, 1);  in test_source_wait_event_notifier_noflush()
680     event_notifier_set(&data.e);  in test_source_wait_event_notifier_noflush()
682     g_assert_cmpint(data.n, ==, 2);  in test_source_wait_event_notifier_noflush()
684     g_assert_cmpint(data.n, ==, 2);  in test_source_wait_event_notifier_noflush()
688     g_assert_cmpint(data.n, ==, 2);  in test_source_wait_event_notifier_noflush()
695     set_event_notifier(ctx, &data.e, NULL);  in test_source_wait_event_notifier_noflush()
697     g_assert_cmpint(data.n, ==, 2);  in test_source_wait_event_notifier_noflush()
699     event_notifier_cleanup(&data.e);  in test_source_wait_event_notifier_noflush()
704     TimerTestData data = { .n = 0, .ctx = ctx, .ns = SCALE_MS * 750LL,  in test_source_timer_schedule()  local
717     aio_timer_init(ctx, &data.timer, data.clock_type,  in test_source_timer_schedule()
718                    SCALE_NS, timer_test_cb, &data);  in test_source_timer_schedule()
719     expiry = qemu_clock_get_ns(data.clock_type) +  in test_source_timer_schedule()
720         data.ns;  in test_source_timer_schedule()
721     timer_mod(&data.timer, expiry);  in test_source_timer_schedule()
723     g_assert_cmpint(data.n, ==, 0);  in test_source_timer_schedule()
726     g_assert_cmpint(data.n, ==, 0);  in test_source_timer_schedule()
729     g_assert_cmpint(data.n, ==, 1);  in test_source_timer_schedule()
730     expiry += data.ns;  in test_source_timer_schedule()
732     while (data.n < 2) {  in test_source_timer_schedule()
736     g_assert_cmpint(data.n, ==, 2);  in test_source_timer_schedule()
737     g_assert(qemu_clock_get_ns(data.clock_type) > expiry);  in test_source_timer_schedule()
742     timer_del(&data.timer);  in test_source_timer_schedule()
761     ChainData *data = opaque;  in chain()  local
763     for (data->i = 0; data->i < data->max; data->i++) {  in chain()
765         aio_co_enter(ctx, data->other);  in chain()