diff options
| author | Vsevolod Stakhov <vsevolod@rambler-co.ru> | 2009-09-22 20:22:31 +0400 |
|---|---|---|
| committer | Vsevolod Stakhov <vsevolod@rambler-co.ru> | 2009-09-22 20:22:31 +0400 |
| commit | 626a11ad9819593eadaca1e321192c75a32b51f3 (patch) | |
| tree | 7f062ddf5d6ec04d7e2f4009541aa417df1cfe59 /src/main.h | |
| parent | fe815ce580d3c455292e1acda406ddb4d371120a (diff) | |
| download | rspamd-626a11ad9819593eadaca1e321192c75a32b51f3.tar.gz rspamd-626a11ad9819593eadaca1e321192c75a32b51f3.zip | |
* Implement new system of async events handling (experimental)
Diffstat (limited to 'src/main.h')
| -rw-r--r-- | src/main.h | 3 |
1 files changed, 3 insertions, 0 deletions
diff --git a/src/main.h b/src/main.h index d31f09943..cb922252c 100644 --- a/src/main.h +++ b/src/main.h @@ -16,6 +16,7 @@ #include "filter.h" #include "buffer.h" #include "hash.h" +#include "events.h" #include "util.h" /* Default values */ @@ -147,6 +148,7 @@ struct controller_session { void (*other_handler)(struct controller_session *session, f_str_t *in); /**< other command handler to execute at the end of processing */ void *other_data; /**< and its data */ + struct rspamd_async_session* s; /**< async session object */ }; typedef void (*controller_func_t)(char **args, struct controller_session *session); @@ -181,6 +183,7 @@ struct worker_task { char *user; /**< user to deliver */ f_str_t *msg; /**< message buffer */ rspamd_io_dispatcher_t *dispatcher; /**< IO dispatcher object */ + struct rspamd_async_session* s; /**< async session object */ memcached_ctx_t *memc_ctx; /**< memcached context associated with task */ int parts_count; /**< mime parts count */ GMimeMessage *message; /**< message, parsed with GMime */ |