Job_Scheduler.cpp

Go to the documentation of this file.

#include "Cosa/Job.hh"

bool
Job::Scheduler::start(Job* job)
{
  // Check that the job is not already started
  if (job->is_started()) return (false);

  // Insert the job into the scheduler job queue
  synchronized {
    Linkage* succ = &m_queue;
    Linkage* curr;
    while ((curr = succ->pred()) != &m_queue) {
      int32_t diff = ((Job*) curr)->m_expires - job->m_expires;
      if (diff < 0) break;
      succ = curr;
    }
    succ->attach(job);
  }
  return (true);
}

bool
Job::Scheduler::stop(Job* job)
{
  // Check that the job is started
  if (!job->is_started()) return (false);
  job->detach();
  return (true);
}

void
Job::Scheduler::dispatch()
{
  // Check if the queue is empty
  if (m_queue.is_empty()) return;

  // Run all jobs that have expired
  Job* job = (Job*) m_queue.succ();
  while ((Linkage*) job != &m_queue) {
    uint32_t now = time();
    int32_t diff = now - job->expire_at();
    if (diff < 0) return;
    Job* succ = (Job*) job->succ();
    ((Link*) job)->detach();
    job->on_expired();
    job = succ;
  }
}