submit/submitd.h

   1 /*
   2  *  The Submit Daemon
   3  *
   4  *  (c) 2007 Martin Mares <mj@ucw.cz>
   5  */
   6
   7 #ifndef _SUBMITD_H
   8 #define _SUBMITD_H
   9
  10 #include "lib/clists.h"
  11 #include "lib/ipaccess.h"
  12 #include "lib/fastbuf.h"
  13
  14 #include <gnutls/gnutls.h>
  15 #include <gnutls/x509.h>
  16
  17 struct access_rule {
  18   cnode n;
  19   struct ip_addrmask addrmask;
  20   uns allow_admin;
  21   uns plain_text;
  22   uns max_conn;
  23 };
  24
  25 struct conn {
  26   // Set up by the master process
  27   cnode n;
  28   u32 ip;
  29   byte *ip_string;                      // (xmalloced)
  30   pid_t pid;
  31   uns id;
  32   struct access_rule *rule;             // Rule matched by this connection
  33   int sk;                               // Client socket
  34   byte *cert_name;                      // Client name from the certificate (NULL if no TLS) (xmalloced)
  35
  36   // Used by the child process
  37   gnutls_session_t tls;                 // TLS session
  38   struct fastbuf rx_fb, tx_fb;          // Fastbufs for communication with the client (either plain-text or TLS)
  39   struct mempool *pool;
  40   struct odes *request;
  41   struct odes *reply;
  42   struct odes *task_status;
  43   int task_lock_fd;
  44   byte *user;
  45 };
  46
  47 extern uns max_request_size, max_attachment_size, trace_commands;
  48
  49 /* submitd.c */
  50
  51 void NONRET client_error(char *msg, ...);
  52
  53 /* commands.c */
  54
  55 int process_init(struct conn *c);
  56 int process_command(struct conn *c);
  57
  58 /* tasks.c */
  59
  60 struct task {
  61   cnode n;
  62   byte *name;
  63 };
  64
  65 extern clist task_list;
  66 extern struct cf_section tasks_conf;
  67
  68 struct task *task_find(byte *name);
  69 int user_exists_p(byte *user);
  70 void task_lock_status(struct conn *c);
  71 void task_unlock_status(struct conn *c, uns write_back);
  72 void task_submit(struct conn *c, struct task *t, struct fastbuf *fb, byte *filename);
  73 struct odes *task_status_find_task(struct conn *c, struct task *t);
  74
  75 #endif