ev-job-scheduler.h File Reference

#include <glib.h>
#include "ev-jobs.h"

Include dependency graph for ev-job-scheduler.h:

This graph shows which files directly or indirectly include this file:

Go to the source code of this file.

Enumerations
enum	EvJobPriority {   EV_JOB_PRIORITY_URGENT, EV_JOB_PRIORITY_HIGH, EV_JOB_PRIORITY_LOW, EV_JOB_PRIORITY_NONE,   EV_JOB_N_PRIORITIES }

Functions
void	ev_job_scheduler_push_job (EvJob *job, EvJobPriority priority)
void	ev_job_scheduler_update_job (EvJob *job, EvJobPriority priority)
EvJob *	ev_job_scheduler_get_running_thread_job (void)

Enumeration Type Documentation

enum EvJobPriority

Enumerator
EV_JOB_PRIORITY_URGENT
EV_JOB_PRIORITY_HIGH
EV_JOB_PRIORITY_LOW
EV_JOB_PRIORITY_NONE
EV_JOB_N_PRIORITIES

Definition at line 33 of file ev-job-scheduler.h.

             {
    EV_JOB_PRIORITY_URGENT, /* Rendering current page range */
    EV_JOB_PRIORITY_HIGH,   /* Rendering current thumbnail range */
    EV_JOB_PRIORITY_LOW,    /* Rendering pages not in current range */
    EV_JOB_PRIORITY_NONE,   /* Any other job: load, save, print, ... */
    EV_JOB_N_PRIORITIES
} EvJobPriority;

Function Documentation

EvJob* ev_job_scheduler_get_running_thread_job

(

void

)

ev_job_scheduler_get_running_thread_job:

Returns: (transfer none): an EvJob

Definition at line 316 of file ev-job-scheduler.c.

{
        return g_atomic_pointer_get (&running_job);
}

Here is the caller graph for this function:

void ev_job_scheduler_push_job	(	EvJob *	job,
		EvJobPriority	priority
	)

Definition at line 225 of file ev-job-scheduler.c.

{
    static GOnce once_init = G_ONCE_INIT;
    EvSchedulerJob *s_job;

    g_once (&once_init, ev_job_scheduler_init, NULL);

    ev_debug_message (DEBUG_JOBS, "%s pirority %d", EV_GET_TYPE_NAME (job), priority);

    s_job = g_new0 (EvSchedulerJob, 1);
    s_job->job = g_object_ref (job);
    s_job->priority = priority;

    ev_scheduler_job_list_add (s_job);
    
    switch (ev_job_get_run_mode (job)) {
    case EV_JOB_RUN_THREAD:
        g_signal_connect_swapped (job->cancellable, "cancelled",
                      G_CALLBACK (ev_scheduler_thread_job_cancelled),
                      s_job);
        ev_job_queue_push (s_job, priority);
        break;
    case EV_JOB_RUN_MAIN_LOOP:
        g_signal_connect_swapped (job, "finished",
                      G_CALLBACK (ev_scheduler_job_destroy),
                      s_job);
        g_signal_connect_swapped (job, "cancelled",
                      G_CALLBACK (ev_scheduler_job_destroy),
                      s_job);
        g_idle_add_full (G_PRIORITY_DEFAULT_IDLE,
                 (GSourceFunc)ev_job_idle,
                 g_object_ref (job),
                 (GDestroyNotify)g_object_unref);
        break;
    default:
        g_assert_not_reached ();
    }
}

Here is the caller graph for this function:

void ev_job_scheduler_update_job	(	EvJob *	job,
		EvJobPriority	priority
	)

Definition at line 266 of file ev-job-scheduler.c.

{
    GSList         *l;
    EvSchedulerJob *s_job = NULL;
    gboolean        need_resort = FALSE;

    /* Main loop jobs are scheduled inmediately */
    if (ev_job_get_run_mode (job) == EV_JOB_RUN_MAIN_LOOP)
        return;

    ev_debug_message (DEBUG_JOBS, "%s pirority %d", EV_GET_TYPE_NAME (job), priority);
    
    G_LOCK (job_list);

    for (l = job_list; l; l = l->next) {
        s_job = (EvSchedulerJob *)l->data;

        if (s_job->job == job) {
            need_resort = (s_job->priority != priority);
            break;
        }
    }
    
    G_UNLOCK (job_list);

    if (need_resort) {
        GList *list;
    
        g_mutex_lock (&job_queue_mutex);
        
        list = g_queue_find (job_queue[s_job->priority], s_job);
        if (list) {
            ev_debug_message (DEBUG_JOBS, "Moving job %s from pirority %d to %d",
                      EV_GET_TYPE_NAME (job), s_job->priority, priority);
            g_queue_delete_link (job_queue[s_job->priority], list);
            g_queue_push_tail (job_queue[priority], s_job);
            g_cond_broadcast (&job_queue_cond);
        }
        
        g_mutex_unlock (&job_queue_mutex);
    }
}

Here is the caller graph for this function: