lib/task.c

   1 #include "libautomation.h"
   2
   3 void atm_call_in(ev_tstamp seconds, void *f) {
   4         ev_once(EV_A_ -1, 0, seconds, f, NULL);
   5 }
   6
   7 void atm_task_cb(EV_P_ ev_timer *w, int revents) {
   8         struct ATM_TASK *task = (struct ATM_TASK *) w;
   9         ev_tstamp delay;
  10         int ret;
  11
  12         atm_time = atm_timestamp();
  13
  14         ret = task->dsgrp.policy(&task->dsgrp);
  15         if (ret > 0) {
  16                 ev_timer_stop(EV_A_ w);
  17                 ev_timer_set(w, ret * ATM_TIMER_RES, w->repeat);
  18                 ev_timer_start(EV_A_ w);
  19
  20                 return;
  21         }
  22
  23         task->task();
  24 }
  25
  26 void atm_task_init(struct ATM_TASK *task, ev_tstamp interval) {
  27         ev_timer_init(&task->watcher, atm_task_cb, 0.1, interval);
  28         atm_dsgrp_init(&task->dsgrp);
  29         task->task = atm_do_nothing;
  30 }