Add quarks to events to determine source of event inside rspamd.

Another try to fix threading.

2 files changed, 3 insertions, 3 deletions

diff --git a/src/plugins/fuzzy_check.c b/src/plugins/fuzzy_check.c
index ef88cab6b..4f66a5731 100644
--- a/src/plugins/fuzzy_check.c
+++ b/src/plugins/fuzzy_check.c
@@ -640,7 +640,7 @@ register_fuzzy_call (struct worker_task *task, fuzzy_hash_t *h)
 			session->fd = sock;
 			session->server = selected;
 			event_add (&session->ev, &session->tv);
-			register_async_event (task->s, fuzzy_io_fin, session, FALSE);
+			register_async_event (task->s, fuzzy_io_fin, session, g_quark_from_static_string ("fuzzy check"));
 		}
 	}
 }
@@ -773,7 +773,7 @@ register_fuzzy_controller_call (struct controller_session *session, struct worke
 			s->fd = sock;
 			event_add (&s->ev, &s->tv);
 			(*saved)++;
-			register_async_event (session->s, fuzzy_learn_fin, s, FALSE);
+			register_async_event (session->s, fuzzy_learn_fin, s, g_quark_from_static_string ("fuzzy check"));
 			return TRUE;
 		}
 	}
diff --git a/src/plugins/surbl.c b/src/plugins/surbl.c
index 6e4cad8ce..3c4c09363 100644
--- a/src/plugins/surbl.c
+++ b/src/plugins/surbl.c
@@ -939,7 +939,7 @@ register_redirector_call (struct uri *url, struct worker_task *task,
 	timeout->tv_usec = (surbl_module_ctx->connect_timeout - timeout->tv_sec * 1000) * 1000;
 	event_set (&param->ev, s, EV_WRITE, redirector_callback, (void *)param);
 	event_add (&param->ev, timeout);
-	register_async_event (task->s, free_redirector_session, param, FALSE);
+	register_async_event (task->s, free_redirector_session, param, g_quark_from_static_string ("surbl"));
 
 	msg_info ("<%s> registered redirector call for %s to %s, according to rule: %s",
 			task->message_id, struri (url), selected->name, rule);