Lines Matching +full:- +full:e
10 * See the COPYING.LIB file in the top-level directory.
18 #include "qemu/error-report.h"
19 #include "qemu/coroutine-core.h"
20 #include "qemu/main-loop.h"
25 EventNotifier e; member
34 while (data->active > 0) { in wait_until_inactive()
59 if (++data->n < data->max) { in bh_test_cb()
60 qemu_bh_schedule(data->bh); in bh_test_cb()
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()
73 static void dummy_io_handler_read(EventNotifier *e) in dummy_io_handler_read() argument
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()
88 static void event_ready_cb(EventNotifier *e) in event_ready_cb() argument
90 EventNotifierTestData *data = container_of(e, EventNotifierTestData, e); in event_ready_cb()
91 g_assert(event_notifier_test_and_clear(e)); in event_ready_cb()
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()
97 event_notifier_set(e); in event_ready_cb()
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()
266 set_event_notifier(ctx, &data.e, NULL); in test_set_event_notifier()
269 event_notifier_cleanup(&data.e); in test_set_event_notifier()
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()
281 event_notifier_set(&data.e); in test_wait_event_notifier()
290 set_event_notifier(ctx, &data.e, NULL); in test_wait_event_notifier()
294 event_notifier_cleanup(&data.e); in test_wait_event_notifier()
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()
306 event_notifier_set(&data.e); 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()
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()
335 event_notifier_set(&data.e); in test_wait_event_notifier_noflush()
340 event_notifier_init(&dummy.e, false); in test_wait_event_notifier_noflush()
341 set_event_notifier(ctx, &dummy.e, event_ready_cb); in test_wait_event_notifier_noflush()
343 event_notifier_set(&data.e); in test_wait_event_notifier_noflush()
349 event_notifier_set(&data.e); in test_wait_event_notifier_noflush()
355 event_notifier_set(&dummy.e); in test_wait_event_notifier_noflush()
361 set_event_notifier(ctx, &dummy.e, NULL); in test_wait_event_notifier_noflush()
362 event_notifier_cleanup(&dummy.e); in test_wait_event_notifier_noflush()
364 set_event_notifier(ctx, &data.e, NULL); in test_wait_event_notifier_noflush()
368 event_notifier_cleanup(&data.e); in test_wait_event_notifier_noflush()
376 EventNotifier e; in test_timer_schedule() local
381 event_notifier_init(&e, false); in test_timer_schedule()
382 set_event_notifier(ctx, &e, dummy_io_handler_read); in test_timer_schedule()
421 set_event_notifier(ctx, &e, NULL); in test_timer_schedule()
422 event_notifier_cleanup(&e); in test_timer_schedule()
430 * - sometimes both the AioContext and the glib main loop wake
433 * - there is no exact replacement for a blocking wait.
436 * non-blocking loop like "while (g_main_context_iteration(NULL, false)"
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()
597 set_event_notifier(ctx, &data.e, NULL); in test_source_set_event_notifier()
600 event_notifier_cleanup(&data.e); in test_source_set_event_notifier()
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()
612 event_notifier_set(&data.e); in test_source_wait_event_notifier()
621 set_event_notifier(ctx, &data.e, NULL); in test_source_wait_event_notifier()
625 event_notifier_cleanup(&data.e); in test_source_wait_event_notifier()
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()
637 event_notifier_set(&data.e); 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()
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()
666 event_notifier_set(&data.e); in test_source_wait_event_notifier_noflush()
671 event_notifier_init(&dummy.e, false); in test_source_wait_event_notifier_noflush()
672 set_event_notifier(ctx, &dummy.e, event_ready_cb); in test_source_wait_event_notifier_noflush()
674 event_notifier_set(&data.e); in test_source_wait_event_notifier_noflush()
680 event_notifier_set(&data.e); in test_source_wait_event_notifier_noflush()
686 event_notifier_set(&dummy.e); in test_source_wait_event_notifier_noflush()
692 set_event_notifier(ctx, &dummy.e, NULL); in test_source_wait_event_notifier_noflush()
693 event_notifier_cleanup(&dummy.e); in test_source_wait_event_notifier_noflush()
695 set_event_notifier(ctx, &data.e, NULL); in test_source_wait_event_notifier_noflush()
699 event_notifier_cleanup(&data.e); in test_source_wait_event_notifier_noflush()
707 EventNotifier e; in test_source_timer_schedule() local
713 event_notifier_init(&e, false); in test_source_timer_schedule()
714 set_event_notifier(ctx, &e, dummy_io_handler_read); in test_source_timer_schedule()
739 set_event_notifier(ctx, &e, NULL); in test_source_timer_schedule()
740 event_notifier_cleanup(&e); in test_source_timer_schedule()
763 for (data->i = 0; data->i < data->max; data->i++) { in chain()
765 aio_co_enter(ctx, data->other); in chain()
784 g_assert_cmpint(data_b.i, ==, data_b.max - 1); in test_queue_chaining()
842 g_test_add_func("/aio/bh/callback-delete/one", test_bh_delete_from_cb); in main()
843 g_test_add_func("/aio/bh/callback-delete/many", test_bh_delete_from_cb_many); in main()
845 g_test_add_func("/aio/event/add-remove", test_set_event_notifier); in main()
847 g_test_add_func("/aio/event/wait/no-flush-cb", test_wait_event_notifier_noflush); in main()
851 g_test_add_func("/aio/coroutine/queue-chaining", test_queue_chaining); in main()
852 g_test_add_func("/aio/coroutine/worker-thread-co-enter", test_worker_thread_co_enter); in main()
854 g_test_add_func("/aio-gsource/flush", test_source_flush); in main()
855 g_test_add_func("/aio-gsource/bh/schedule", test_source_bh_schedule); in main()
856 g_test_add_func("/aio-gsource/bh/schedule10", test_source_bh_schedule10); in main()
857 g_test_add_func("/aio-gsource/bh/cancel", test_source_bh_cancel); in main()
858 g_test_add_func("/aio-gsource/bh/delete", test_source_bh_delete); in main()
859 g_test_add_func("/aio-gsource/bh/callback-delete/one", test_source_bh_delete_from_cb); in main()
860 g_test_add_func("/aio-gsource/bh/callback-delete/many", test_source_bh_delete_from_cb_many); in main()
861 g_test_add_func("/aio-gsource/bh/flush", test_source_bh_flush); in main()
862 g_test_add_func("/aio-gsource/event/add-remove", test_source_set_event_notifier); in main()
863 g_test_add_func("/aio-gsource/event/wait", test_source_wait_event_notifier); in main()
864 … g_test_add_func("/aio-gsource/event/wait/no-flush-cb", test_source_wait_event_notifier_noflush); in main()
865 g_test_add_func("/aio-gsource/event/flush", test_source_flush_event_notifier); in main()
866 g_test_add_func("/aio-gsource/timer/schedule", test_source_timer_schedule); in main()