aboutsummaryrefslogtreecommitdiffstats
path: root/src/rspamd.h
diff options
context:
space:
mode:
authorVsevolod Stakhov <vsevolod@highsecure.ru>2019-06-16 09:57:21 +0100
committerVsevolod Stakhov <vsevolod@highsecure.ru>2019-06-22 10:57:29 +0100
commit71e0dbf9608026c347279886097790e51e9e5506 (patch)
tree1243e079b7c6fcb6a12707a67536ef1d62a638dc /src/rspamd.h
parentbb3a48e42835fdbb456fdf0d0f74050fa61ff7d5 (diff)
downloadrspamd-71e0dbf9608026c347279886097790e51e9e5506.tar.gz
rspamd-71e0dbf9608026c347279886097790e51e9e5506.zip
[Project] Remove libfann, gd and other unsupported stuff
Diffstat (limited to 'src/rspamd.h')
-rw-r--r--src/rspamd.h10
1 files changed, 8 insertions, 2 deletions
diff --git a/src/rspamd.h b/src/rspamd.h
index 9af78e904..375cba13f 100644
--- a/src/rspamd.h
+++ b/src/rspamd.h
@@ -62,6 +62,12 @@ enum rspamd_worker_flags {
RSPAMD_WORKER_CONTROLLER = (1 << 6),
};
+struct rspamd_worker_accept_event {
+ ev_io accept_ev;
+ ev_timer throttling_ev;
+ struct ev_loop *event_loop;
+ struct rspamd_worker_accept_event *prev, *next;
+};
/**
* Worker process structure
@@ -77,7 +83,7 @@ struct rspamd_worker {
struct rspamd_main *srv; /**< pointer to server structure */
GQuark type; /**< process type */
GHashTable *signal_events; /**< signal events */
- GList *accept_events; /**< socket events */
+ struct rspamd_worker_accept_event *accept_events; /**< socket events */
struct rspamd_worker_conf *cf; /**< worker config data */
gpointer ctx; /**< worker's specific data */
enum rspamd_worker_flags flags; /**< worker's flags */
@@ -85,7 +91,7 @@ struct rspamd_worker {
[1] is used by a worker */
gint srv_pipe[2]; /**< used by workers to request something from the
main process. [0] - main, [1] - worker */
- struct event srv_ev; /**< used by main for read workers' requests */
+ ev_io srv_ev; /**< used by main for read workers' requests */
gpointer control_data; /**< used by control protocol to handle commands */
gpointer tmp_data; /**< used to avoid race condition to deal with control messages */
GPtrArray *finish_actions; /**< called when worker is terminated */