More buffer functions.
[apps/madmutt.git] / lib-sys / evtloop.h
1 /*
2  *  This program is free software; you can redistribute it and/or modify
3  *  it under the terms of the GNU General Public License as published by
4  *  the Free Software Foundation; either version 2 of the License, or (at
5  *  your option) any later version.
6  *
7  *  This program is distributed in the hope that it will be useful, but
8  *  WITHOUT ANY WARRANTY; without even the implied warranty of
9  *  MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the GNU
10  *  General Public License for more details.
11  *
12  *  You should have received a copy of the GNU General Public License
13  *  along with this program; if not, write to the Free Software
14  *  Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston,
15  *  MA 02110-1301, USA.
16  */
17 /*
18  *  Copyright © 2006 Pierre Habouzit
19  */
20
21 #ifndef MUTT_LIB_SYS_EVTLOOP_H
22 #define MUTT_LIB_SYS_EVTLOOP_H
23
24 #include <lib-lib/lib-lib.h>
25 #include <gnutls/gnutls.h>
26
27 typedef enum el_state {
28     EL_LLP_INIT,
29     EL_LLP_READY,
30     EL_LLP_FINI,
31 } el_state;
32
33 typedef enum el_mode {
34     EL_NEW     = 0,
35     EL_READING = 1,
36     EL_WRITING = 2,
37     EL_RDWR    = 3,
38     EL_IDLE    = 4,
39 } el_mode;
40
41 typedef enum el_status {
42     EL_SUCCESS,
43     EL_ERROR,
44     EL_KILLED,
45     EL_RDHUP,
46 } el_status;
47
48 typedef enum el_event {
49     EL_EVT_IN      = EL_READING,
50     EL_EVT_OUT     = EL_WRITING,
51     EL_EVT_INOUT   = EL_RDWR,
52     EL_EVT_RUNNING = 4,
53     EL_EVT_WAKEUP  = 5,
54 } el_event;
55
56 typedef struct job_t {
57     int fd;
58
59     gnutls_session_t session;
60
61     el_state state : 2;
62     el_mode  mode  : 3;
63     el_mode  emode : 3;
64
65     int (*llp)(struct job_t *);
66     const struct machine_t *m;
67     void *ptr;
68 } job_t;
69 DO_INIT(job_t, job);
70 DO_WIPE(job_t, job);
71 DO_NEW(job_t, job);
72 DO_DELETE(job_t, job);
73
74 typedef struct machine_t {
75     const char *name;
76     __must_check__ int (*setup)(job_t *w, void *);
77     int (*on_event)(job_t *w, el_event);
78     void (*finalize)(job_t *w, el_status);
79 } machine_t;
80
81 #define EL_JOB_CHECK(expr) \
82     do { if ((expr) < 0) return -1; } while (0)
83
84 __must_check__ int el_job_setmode(job_t *w, el_mode);
85 __must_check__ int el_job_release(job_t *j, el_status);
86 __must_check__ int el_job_connect(job_t *w, struct sockaddr *, socklen_t len,
87                                   int type, int proto);
88 __must_check__ ssize_t el_job_read(job_t *w, buffer_t *buf);
89
90 static inline job_t *el_job_start(const machine_t *m, void *cfg) {
91     job_t *w = job_new();
92     w->m = m;
93     return m->setup(w, cfg) < 0 ? NULL : w;
94 }
95
96 int el_dispatch(int timeout);
97
98 #endif