job.h

   1 /* job.h - a job in the queue */
   2
   3 /* Copyright (C) 2007 Keith Rarick and Philotic Inc.
   4
   5  * This program is free software: you can redistribute it and/or modify
   6  * it under the terms of the GNU General Public License as published by
   7  * the Free Software Foundation, either version 3 of the License, or
   8  * (at your option) any later version.
   9
  10  * This program is distributed in the hope that it will be useful,
  11  * but WITHOUT ANY WARRANTY; without even the implied warranty of
  12  * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
  13  * GNU General Public License for more details.
  14
  15  * You should have received a copy of the GNU General Public License
  16  * along with this program.  If not, see <http://www.gnu.org/licenses/>.
  17  */
  18
  19 #ifndef job_h
  20 #define job_h
  21
  22 #include <time.h>
  23
  24 typedef struct job *job;
  25 typedef int(*job_cmp_fn)(job, job);
  26
  27 #include "tube.h"
  28
  29 #define JOB_STATE_INVALID 0
  30 #define JOB_STATE_READY 1
  31 #define JOB_STATE_RESERVED 2
  32 #define JOB_STATE_BURIED 3
  33 #define JOB_STATE_DELAYED 4
  34
  35 struct job {
  36     job prev, next; /* linked list of jobs */
  37     unsigned long long int id;
  38     unsigned int pri;
  39     unsigned int delay;
  40     unsigned int ttr;
  41     int body_size;
  42     time_t creation;
  43     time_t deadline;
  44     unsigned int timeout_ct;
  45     unsigned int release_ct;
  46     unsigned int bury_ct;
  47     unsigned int kick_ct;
  48     tube tube;
  49     void *reserver;
  50     void *binlog;
  51     char state;
  52     job ht_next; /* Next job in a hash table list */
  53     size_t heap_index; /* where is this job in a heap */
  54     char body[];
  55 };
  56
  57 #define make_job(pri,delay,ttr,body_size,tube) make_job_with_id(pri,delay,ttr,body_size,tube,0)
  58
  59 job allocate_job(int body_size);
  60 job make_job_with_id(unsigned int pri, unsigned int delay, unsigned int ttr,
  61              int body_size, tube tube, unsigned long long id);
  62 void job_free(job j);
  63
  64 /* Lookup a job by job ID */
  65 job job_find(unsigned long long int job_id);
  66
  67 int job_pri_cmp(job a, job b);
  68 int job_delay_cmp(job a, job b);
  69
  70 job job_copy(job j);
  71
  72 const char * job_state(job j);
  73
  74 int job_list_any_p(job head);
  75 job job_remove(job j);
  76 void job_insert(job head, job j);
  77
  78 unsigned long long int total_jobs();
  79
  80 void job_init();
  81
  82 #endif /*job_h*/