gint io_priority;
GCancellable *cancellable;
+ gulong cancellable_id;
GMainContext *context;
};
g_io_job_free (GIOSchedulerJob *job)
{
if (job->cancellable)
- g_object_unref (job->cancellable);
+ {
+ if (job->cancellable_id)
+ g_cancellable_disconnect (job->cancellable, job->cancellable_id);
+ g_object_unref (job->cancellable);
+ }
g_main_context_unref (job->context);
g_free (job);
}
}
static void
-remove_active_job (GIOSchedulerJob *job)
+on_job_canceled (GCancellable *cancellable,
+ gpointer user_data)
{
- GIOSchedulerJob *other_job;
- GList *l;
- gboolean resort_jobs;
-
- G_LOCK (active_jobs);
- active_jobs = g_list_delete_link (active_jobs, job->active_link);
-
- resort_jobs = FALSE;
- for (l = active_jobs; l != NULL; l = l->next)
- {
- other_job = l->data;
- if (other_job->io_priority >= 0 &&
- g_cancellable_is_cancelled (other_job->cancellable))
- {
- other_job->io_priority = -1;
- resort_jobs = TRUE;
- }
- }
- G_UNLOCK (active_jobs);
-
- if (resort_jobs &&
- job_thread_pool != NULL)
+ GIOSchedulerJob *job = user_data;
+
+ job->io_priority = -1;
+ job->cancellable_id = 0;
+
+ if (job_thread_pool != NULL)
g_thread_pool_set_sort_function (job_thread_pool,
g_io_job_compare,
NULL);
-
}
static void
if (job->destroy_notify)
job->destroy_notify (job->data);
- remove_active_job (job);
+ G_LOCK (active_jobs);
+ active_jobs = g_list_delete_link (active_jobs, job->active_link);
+ G_UNLOCK (active_jobs);
g_io_job_free (job);
}
job->io_priority = io_priority;
if (cancellable)
- job->cancellable = g_object_ref (cancellable);
+ {
+ job->cancellable = g_object_ref (cancellable);
+ job->cancellable_id = g_cancellable_connect (job->cancellable, (GCallback)on_job_canceled,
+ job, NULL);
+ }
job->context = g_main_context_ref_thread_default ();