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_tcp.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_tcp.c')
| -rw-r--r-- | src/lua/lua_tcp.c | 11 |
1 files changed, 6 insertions, 5 deletions
diff --git a/src/lua/lua_tcp.c b/src/lua/lua_tcp.c index c6e96825b..375867df6 100644 --- a/src/lua/lua_tcp.c +++ b/src/lua/lua_tcp.c @@ -19,6 +19,8 @@ #include "unix-std.h" #include <math.h> +static const gchar *M = "rspamd lua tcp"; + /*** * @module rspamd_tcp * Rspamd TCP module represents generic TCP asynchronous client available from LUA code. @@ -483,7 +485,7 @@ lua_tcp_maybe_free (struct lua_tcp_cbdata *cbd) */ if (cbd->item) { - rspamd_symcache_item_async_dec_check (cbd->task, cbd->item); + rspamd_symcache_item_async_dec_check (cbd->task, cbd->item, M); cbd->item = NULL; } @@ -495,7 +497,7 @@ lua_tcp_maybe_free (struct lua_tcp_cbdata *cbd) } else { if (cbd->item) { - rspamd_symcache_item_async_dec_check (cbd->task, cbd->item); + rspamd_symcache_item_async_dec_check (cbd->task, cbd->item, M); cbd->item = NULL; } @@ -1161,8 +1163,7 @@ lua_tcp_register_event (struct lua_tcp_cbdata *cbd) if (cbd->session) { event_finalizer_t fin = IS_SYNC (cbd) ? lua_tcp_void_finalyser : lua_tcp_fin; - cbd->async_ev = rspamd_session_add_event (cbd->session, fin, cbd, - g_quark_from_static_string ("lua tcp")); + cbd->async_ev = rspamd_session_add_event (cbd->session, fin, cbd, M); if (!cbd->async_ev) { return FALSE; @@ -1176,7 +1177,7 @@ static void lua_tcp_register_watcher (struct lua_tcp_cbdata *cbd) { if (cbd->item) { - rspamd_symcache_item_async_inc (cbd->task, cbd->item); + rspamd_symcache_item_async_inc (cbd->task, cbd->item, M); } } |