58     struct TestTaskData *data = opaque;  in task_callback()  local
60     data->source = qio_task_get_source(task);  in task_callback()
61     qio_task_propagate_error(task, &data->err);  in task_callback()
70     struct TestTaskData data = { NULL, NULL, false };  in test_task_complete()  local
72     task = qio_task_new(obj, task_callback, &data, NULL);  in test_task_complete()
81     g_assert(data.source == obj);  in test_task_complete()
82     g_assert(data.err == NULL);  in test_task_complete()
83     g_assert(data.freed == false);  in test_task_complete()
89     struct TestTaskData *data = opaque;  in task_data_free()  local
91     data->freed = true;  in task_data_free()
99     struct TestTaskData data = { NULL, NULL, false };  in test_task_data_free()  local
101     task = qio_task_new(obj, task_callback, &data, task_data_free);  in test_task_data_free()
107     g_assert(data.source == obj);  in test_task_data_free()
108     g_assert(data.err == NULL);  in test_task_data_free()
109     g_assert(data.freed == true);  in test_task_data_free()
117     struct TestTaskData data = { NULL, NULL, false };  in test_task_failure()  local
120     task = qio_task_new(obj, task_callback, &data, NULL);  in test_task_failure()
129     g_assert(data.source == obj);  in test_task_failure()
130     g_assert(data.err == err);  in test_task_failure()
131     g_assert(data.freed == false);  in test_task_failure()
132     error_free(data.err);  in test_task_failure()
148     struct TestThreadWorkerData *data = opaque;  in test_task_thread_worker()  local
150     data->worker = g_thread_self();  in test_task_thread_worker()
152     if (data->fail) {  in test_task_thread_worker()
163     struct TestThreadWorkerData *data = opaque;  in test_task_thread_callback()  local
165     data->source = qio_task_get_source(task);  in test_task_thread_callback()
166     qio_task_propagate_error(task, &data->err);  in test_task_thread_callback()
168     data->complete = g_thread_self();  in test_task_thread_callback()
170     g_main_loop_quit(data->loop);  in test_task_thread_callback()
178     struct TestThreadWorkerData data = { 0 };  in test_task_thread_complete()  local
181     data.loop = g_main_loop_new(g_main_context_default(),  in test_task_thread_complete()
186                         &data,  in test_task_thread_complete()
191                            &data,  in test_task_thread_complete()
195     g_main_loop_run(data.loop);  in test_task_thread_complete()
197     g_main_loop_unref(data.loop);  in test_task_thread_complete()
200     g_assert(data.source == obj);  in test_task_thread_complete()
201     g_assert(data.err == NULL);  in test_task_thread_complete()
207     g_assert(data.worker != self);  in test_task_thread_complete()
211     g_assert(data.complete == self);  in test_task_thread_complete()
219     struct TestThreadWorkerData data = { 0 };  in test_task_thread_failure()  local
222     data.loop = g_main_loop_new(g_main_context_default(),  in test_task_thread_failure()
224     data.fail = true;  in test_task_thread_failure()
228                         &data,  in test_task_thread_failure()
233                            &data,  in test_task_thread_failure()
237     g_main_loop_run(data.loop);  in test_task_thread_failure()
239     g_main_loop_unref(data.loop);  in test_task_thread_failure()
242     g_assert(data.source == obj);  in test_task_thread_failure()
243     error_free_or_abort(&data.err);  in test_task_thread_failure()
249     g_assert(data.worker != self);  in test_task_thread_failure()
253     g_assert(data.complete == self);  in test_task_thread_failure()