prot.h

   1 /* prot.h - protocol implementation header */
   2
   3 #ifndef prot_h
   4 #define prot_h
   5
   6 #include "job.h"
   7 #include "conn.h"
   8
   9 /* space for 16 Mi jobs */
  10 #define HEAP_SIZE 16 * 1024 * 1024
  11
  12 #define URGENT_THRESHOLD 1024
  13
  14 /* measured in seconds */
  15 #define RESERVATION_TIMEOUT 120
  16
  17 #define MSG_RESERVED "RESERVED"
  18
  19 void prot_init();
  20
  21 void reply(conn c, char *line, int len, int state);
  22 void reply_job(conn c, job j, const char *word);
  23
  24 void enqueue_waiting_conn(conn c);
  25
  26 int enqueue_job(job j);
  27 void bury_job(job j);
  28 int kick_job();
  29 void process_queue();
  30
  31 job peek_job(unsigned long long int id);
  32
  33 unsigned int get_ready_job_ct();
  34 unsigned int get_buried_job_ct();
  35 unsigned int get_urgent_job_ct();
  36
  37 #endif /*prot_h*/