diff options
author | Vsevolod Stakhov <vsevolod@highsecure.ru> | 2015-05-26 11:37:48 +0100 |
---|---|---|
committer | Vsevolod Stakhov <vsevolod@highsecure.ru> | 2015-05-26 11:37:48 +0100 |
commit | b1575711e78b96cd8560d4bebcebcfa92e2d14a7 (patch) | |
tree | 9f4961a083214173d883a0825d5fccb6918372bc /src/libmime | |
parent | 9f4ebd97d0fbc2bffba13ec945de5e785b15b371 (diff) | |
download | rspamd-b1575711e78b96cd8560d4bebcebcfa92e2d14a7.tar.gz rspamd-b1575711e78b96cd8560d4bebcebcfa92e2d14a7.zip |
Remove threading support at all.
Diffstat (limited to 'src/libmime')
-rw-r--r-- | src/libmime/filter.c | 18 | ||||
-rw-r--r-- | src/libmime/filter.h | 6 |
2 files changed, 0 insertions, 24 deletions
diff --git a/src/libmime/filter.c b/src/libmime/filter.c index 70e5c3c6b..e23bb8f87 100644 --- a/src/libmime/filter.c +++ b/src/libmime/filter.c @@ -746,24 +746,6 @@ rspamd_process_statistics (struct rspamd_task *task) rspamd_make_composites (task); } -void -rspamd_process_statistic_threaded (gpointer data, gpointer user_data) -{ - struct rspamd_task *task = (struct rspamd_task *)data; - struct lua_locked_state *nL = user_data; - - if (RSPAMD_TASK_IS_SKIPPED (task)) { - remove_async_thread (task->s); - return; - } - - /* TODO: handle err here */ - rspamd_mutex_lock (nL->m); - rspamd_stat_classify (task, nL->L, NULL); - rspamd_mutex_unlock (nL->m); - remove_async_thread (task->s); -} - static void insert_metric_header (gpointer metric_name, gpointer metric_value, gpointer data) diff --git a/src/libmime/filter.h b/src/libmime/filter.h index f763c3b8a..67dc60010 100644 --- a/src/libmime/filter.h +++ b/src/libmime/filter.h @@ -109,12 +109,6 @@ gint rspamd_process_filters (struct rspamd_task *task); void rspamd_process_statistics (struct rspamd_task *task); /** - * Process message with statfiles threaded - * @param data worker's task that present message from user - */ -void rspamd_process_statistic_threaded (gpointer data, gpointer user_data); - -/** * Insert a result to task * @param task worker's task that present message from user * @param metric_name metric's name to which we need to insert result |