diff options
author | Vsevolod Stakhov <vsevolod@highsecure.ru> | 2018-10-26 16:06:12 +0100 |
---|---|---|
committer | Vsevolod Stakhov <vsevolod@highsecure.ru> | 2018-10-26 16:06:12 +0100 |
commit | 0c20729f33f07cdcef5f7c10bde04f262c4a4574 (patch) | |
tree | 66853c7d49a7e51715ce1bc73ab12998bc28c7a9 /src/lua/lua_dns_resolver.c | |
parent | 2ae394086bb5385ae4bc216cf694fe35692522a3 (diff) | |
download | rspamd-0c20729f33f07cdcef5f7c10bde04f262c4a4574.tar.gz rspamd-0c20729f33f07cdcef5f7c10bde04f262c4a4574.zip |
[Rework] Add more traces to async events, get rid of GQuarks
Diffstat (limited to 'src/lua/lua_dns_resolver.c')
-rw-r--r-- | src/lua/lua_dns_resolver.c | 11 |
1 files changed, 7 insertions, 4 deletions
diff --git a/src/lua/lua_dns_resolver.c b/src/lua/lua_dns_resolver.c index c95d7bbba..6c46c12cf 100644 --- a/src/lua/lua_dns_resolver.c +++ b/src/lua/lua_dns_resolver.c @@ -40,6 +40,9 @@ local function symbol_callback(task) task:get_resolver():resolve_a({task = task, name = host, callback = dns_cb}) end */ + +static const gchar *M = "rspamd lua dns resolver"; + struct rspamd_dns_resolver * lua_check_dns_resolver (lua_State * L); void luaopen_dns_resolver (lua_State * L); @@ -204,7 +207,7 @@ lua_dns_resolver_callback (struct rdns_reply *reply, gpointer arg) lua_thread_pool_restore_callback (&cbs); if (cd->item) { - rspamd_symcache_item_async_dec_check (cd->task, cd->item); + rspamd_symcache_item_async_dec_check (cd->task, cd->item, M); } if (!cd->pool) { @@ -447,7 +450,7 @@ lua_dns_resolver_resolve_common (lua_State *L, * lua_dns_resolver_callback without switching to the event loop */ if (cbdata->item) { - rspamd_symcache_item_async_inc (task, cbdata->item); + rspamd_symcache_item_async_inc (task, cbdata->item, M); } if (forced) { @@ -469,7 +472,7 @@ lua_dns_resolver_resolve_common (lua_State *L, cbdata->item = rspamd_symbols_cache_get_cur_item (task); if (cbdata->item) { - rspamd_symcache_item_async_inc (task, cbdata->item); + rspamd_symcache_item_async_inc (task, cbdata->item, M); } /* callback was set up */ lua_pushboolean (L, TRUE); @@ -479,7 +482,7 @@ lua_dns_resolver_resolve_common (lua_State *L, } if (cbdata->item) { - rspamd_symcache_item_async_dec_check (task, cbdata->item); + rspamd_symcache_item_async_dec_check (task, cbdata->item, M); } } } |