Job.hh

Go to the documentation of this file.

#ifndef COSA_JOB_HH
#define COSA_JOB_HH

#include "Cosa/Types.h"
#include "Cosa/Linkage.hh"

class Job : public Link {
public:
  class Scheduler {
  public:
    Scheduler() : m_queue() {}

    virtual bool start(Job* job);

    virtual bool stop(Job* job);

    virtual void dispatch();

    virtual uint32_t time() = 0;

  protected:
    Head m_queue;
  };

  Job(Scheduler* scheduler) :
    Link(),
    m_expires(0L),
    m_scheduler(scheduler)
  {}

  void expire_at(uint32_t time)
  {
    m_expires = time;
  }

  void expire_after(uint32_t time)
  {
    m_expires += time;
  }

  uint32_t expire_at() const
  {
    return (m_expires);
  }

  int32_t expire_after() const
  {
    if (m_scheduler != NULL) return (m_expires - m_scheduler->time());
    return (m_expires);
  }

  uint32_t time() const
  {
    if (m_scheduler != NULL) return (m_scheduler->time());
    return (0UL);
  }

  bool is_started() const
    __attribute__((always_inline))
  {
    return (pred() != this);
  }

  bool start()
  {
    if (UNLIKELY(m_scheduler == NULL)) return (false);
    return (m_scheduler->start(this));
  }

  bool stop()
  {
    if (UNLIKELY(m_scheduler == NULL)) return (true);
    return (m_scheduler->stop(this));
  }

  virtual void on_expired()
  {
    Event::push(Event::TIMEOUT_TYPE, this);
  }

  virtual void on_event(uint8_t type, uint16_t value)
  {
    UNUSED(value);
    if (type == Event::TIMEOUT_TYPE) run();
  }

  virtual void run() {}

protected:
  uint32_t m_expires;

  Scheduler* m_scheduler;
};
#endif