summaryrefslogtreecommitdiff
path: root/src/eom-job-queue.c
diff options
context:
space:
mode:
Diffstat (limited to 'src/eom-job-queue.c')
-rw-r--r--src/eom-job-queue.c26
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;
}