diff options
Diffstat (limited to 'src/eom-job-queue.c')
| -rw-r--r-- | src/eom-job-queue.c | 26 |
1 files changed, 13 insertions, 13 deletions
diff --git a/src/eom-job-queue.c b/src/eom-job-queue.c index 8452de5..007e0a3 100644 --- a/src/eom-job-queue.c +++ b/src/eom-job-queue.c @@ -25,8 +25,8 @@ #include "eom-jobs.h" #include "eom-job-queue.h" -static GCond render_cond; -static GMutex eom_queue_mutex; +static GCond *render_cond = NULL; +static GMutex *eom_queue_mutex = NULL; static GQueue *thumbnail_queue = NULL; static GQueue *load_queue = NULL; @@ -57,7 +57,7 @@ add_job_to_queue_locked (GQueue *queue, EomJob *job) { g_object_ref (job); g_queue_push_tail (queue, job); - g_cond_broadcast (&render_cond); + g_cond_broadcast (render_cond); } static gboolean @@ -131,15 +131,15 @@ eom_render_thread (gpointer data) while (TRUE) { EomJob *job; - g_mutex_lock (&eom_queue_mutex); + g_mutex_lock (eom_queue_mutex); if (no_jobs_available_unlocked ()) { - g_cond_wait (&render_cond, &eom_queue_mutex); + g_cond_wait (render_cond, eom_queue_mutex); } job = search_for_jobs_unlocked (); - g_mutex_unlock (&eom_queue_mutex); + g_mutex_unlock (eom_queue_mutex); /* Now that we have our job, we handle it */ if (job) { @@ -154,8 +154,8 @@ eom_render_thread (gpointer data) void eom_job_queue_init (void) { - g_cond_init (&render_cond); - g_mutex_init (&eom_queue_mutex); + render_cond = g_cond_new (); + eom_queue_mutex = g_mutex_new (); thumbnail_queue = g_queue_new (); load_queue = g_queue_new (); @@ -164,7 +164,7 @@ eom_job_queue_init (void) save_queue = g_queue_new (); copy_queue = g_queue_new (); - g_thread_new ("EomJobQueue", eom_render_thread, NULL); + g_thread_create (eom_render_thread, NULL, FALSE, NULL); } static GQueue * @@ -198,11 +198,11 @@ eom_job_queue_add_job (EomJob *job) queue = find_queue (job); - g_mutex_lock (&eom_queue_mutex); + g_mutex_lock (eom_queue_mutex); add_job_to_queue_locked (queue, job); - g_mutex_unlock (&eom_queue_mutex); + g_mutex_unlock (eom_queue_mutex); } gboolean @@ -212,7 +212,7 @@ eom_job_queue_remove_job (EomJob *job) g_return_val_if_fail (EOM_IS_JOB (job), FALSE); - g_mutex_lock (&eom_queue_mutex); + g_mutex_lock (eom_queue_mutex); if (EOM_IS_JOB_THUMBNAIL (job)) { retval = remove_job_from_queue (thumbnail_queue, job); @@ -230,7 +230,7 @@ eom_job_queue_remove_job (EomJob *job) g_assert_not_reached (); } - g_mutex_unlock (&eom_queue_mutex); + g_mutex_unlock (eom_queue_mutex); return retval; } |