X-Git-Url: http://git.madism.org/?p=apps%2Fmadmutt.git;a=blobdiff_plain;f=lib-sys%2Fevtloop.h;h=48bc86a105b8c1e353a20cc880ed721d34d14766;hp=84f2eb05ff116b773ad284f939a3bd915643c147;hb=4d71119a25f96043c5d27cf46a732b216172708f;hpb=7489084cbae92559260659c8606eea91d70e8f3b diff --git a/lib-sys/evtloop.h b/lib-sys/evtloop.h index 84f2eb0..48bc86a 100644 --- a/lib-sys/evtloop.h +++ b/lib-sys/evtloop.h @@ -15,7 +15,7 @@ * MA 02110-1301, USA. */ /* - * Copyright © 2006 Pierre Habouzit + * Copyright © 2007 Pierre Habouzit */ #ifndef MUTT_LIB_SYS_EVTLOOP_H @@ -23,6 +23,8 @@ #include #include +#include +#include "account.h" typedef enum el_state { EL_LLP_INIT, @@ -46,35 +48,39 @@ typedef enum el_status { } el_status; typedef enum el_event { + EL_EVT_RUNNING = 0, EL_EVT_IN = EL_READING, EL_EVT_OUT = EL_WRITING, EL_EVT_INOUT = EL_RDWR, - EL_EVT_RUNNING = 4, EL_EVT_WAKEUP = 5, } el_event; typedef struct job_t { int fd; + int ssf; - gnutls_session_t session; - + unsigned cond : 1; el_state state : 2; el_mode mode : 3; el_mode emode : 3; + gnutls_session_t session; + gnutls_certificate_credentials_t xcred; + + struct timeval mru; int (*llp)(struct job_t *); const struct machine_t *m; void *ptr; } job_t; DO_INIT(job_t, job); -DO_WIPE(job_t, job); +void job_wipe(job_t *w); DO_NEW(job_t, job); DO_DELETE(job_t, job); typedef struct machine_t { const char *name; __must_check__ int (*setup)(job_t *w, void *); - int (*on_event)(job_t *w, el_event); + __must_check__ int (*on_event)(job_t *w, el_event); void (*finalize)(job_t *w, el_status); } machine_t; @@ -82,17 +88,23 @@ typedef struct machine_t { do { if ((expr) < 0) return -1; } while (0) __must_check__ int el_job_setmode(job_t *w, el_mode); +__must_check__ job_t *el_job_start(const machine_t *m, void *cfg); __must_check__ int el_job_release(job_t *j, el_status); + __must_check__ int el_job_connect(job_t *w, struct sockaddr *, socklen_t len, - int type, int proto); + int type, int proto, int ssl); +__must_check__ int el_job_connect2(job_t *w, const ACCOUNT *); +__must_check__ int el_job_starttls(job_t *w); __must_check__ ssize_t el_job_read(job_t *w, buffer_t *buf); +__must_check__ ssize_t el_job_write(job_t *w, buffer_t *buf); -static inline job_t *el_job_start(const machine_t *m, void *cfg) { - job_t *w = job_new(); - w->m = m; - return m->setup(w, cfg) < 0 ? NULL : w; -} +void el_lock(void); +void el_unlock(void); +void el_wait(volatile job_t *w); int el_dispatch(int timeout); +void el_initialize(void); +void el_shutdown(void); + #endif