diff options
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); } } |