commit 3deecad: [Minor] Slightly improve session events logging
Vsevolod Stakhov
vsevolod at highsecure.ru
Tue Dec 28 20:21:04 UTC 2021
Author: Vsevolod Stakhov
Date: 2021-12-28 20:15:50 +0000
URL: https://github.com/rspamd/rspamd/commit/3deecad150f2ec11679cb85265c55df948e7c2bc (HEAD -> master)
[Minor] Slightly improve session events logging
---
src/lua/lua_http.c | 14 ++++++++++----
src/lua/lua_tcp.c | 8 +++++++-
src/lua/lua_udp.c | 10 ++++++++--
3 files changed, 25 insertions(+), 7 deletions(-)
diff --git a/src/lua/lua_http.c b/src/lua/lua_http.c
index e4a3bedb1..ce2a48d63 100644
--- a/src/lua/lua_http.c
+++ b/src/lua/lua_http.c
@@ -389,7 +389,6 @@ lua_http_make_connection (struct lua_http_cbdata *cbd)
{
rspamd_inet_address_set_port (cbd->addr, cbd->msg->port);
unsigned http_opts = RSPAMD_HTTP_CLIENT_SIMPLE;
- struct rspamd_http_message *msg = cbd->msg;
if (cbd->msg->flags & RSPAMD_HTTP_FLAG_WANT_SSL) {
http_opts |= RSPAMD_HTTP_CLIENT_SSL;
@@ -440,9 +439,16 @@ lua_http_make_connection (struct lua_http_cbdata *cbd)
}
if (cbd->session) {
- rspamd_session_add_event (cbd->session,
- (event_finalizer_t) lua_http_fin, cbd,
- M);
+ if (cbd->item) {
+ rspamd_session_add_event_full (cbd->session,
+ (event_finalizer_t) lua_http_fin, cbd,
+ M, rspamd_symcache_item_name (cbd->item));
+ }
+ else {
+ rspamd_session_add_event (cbd->session,
+ (event_finalizer_t) lua_http_fin, cbd,
+ M);
+ }
cbd->flags |= RSPAMD_LUA_HTTP_FLAG_RESOLVED;
}
diff --git a/src/lua/lua_tcp.c b/src/lua/lua_tcp.c
index f15e25399..37f535850 100644
--- a/src/lua/lua_tcp.c
+++ b/src/lua/lua_tcp.c
@@ -1231,7 +1231,13 @@ 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, M);
+ if (cbd->item) {
+ cbd->async_ev = rspamd_session_add_event_full (cbd->session, fin, cbd, M,
+ rspamd_symcache_item_name (cbd->item));
+ }
+ else {
+ cbd->async_ev = rspamd_session_add_event (cbd->session, fin, cbd, M);
+ }
if (!cbd->async_ev) {
return FALSE;
diff --git a/src/lua/lua_udp.c b/src/lua/lua_udp.c
index 5d1fd8c62..656d80349 100644
--- a/src/lua/lua_udp.c
+++ b/src/lua/lua_udp.c
@@ -236,8 +236,14 @@ static gboolean
lua_udp_maybe_register_event (struct lua_udp_cbdata *cbd)
{
if (cbd->s && !cbd->async_ev) {
- cbd->async_ev = rspamd_session_add_event (cbd->s, lua_udp_cbd_fin,
- cbd, M);
+ if (cbd->item) {
+ cbd->async_ev = rspamd_session_add_event_full (cbd->s, lua_udp_cbd_fin,
+ cbd, M, rspamd_symcache_item_name (cbd->item));
+ }
+ else {
+ cbd->async_ev = rspamd_session_add_event (cbd->s, lua_udp_cbd_fin,
+ cbd, M);
+ }
if (!cbd->async_ev) {
return FALSE;
More information about the Commits
mailing list