Browse Source

[Fix] Use proper syntax for making DNS requests

tags/1.8.2
Vsevolod Stakhov 5 years ago
parent
commit
aacb706648
3 changed files with 10 additions and 4 deletions
  1. 6
    1
      src/libserver/events.c
  2. 3
    2
      src/plugins/lua/asn.lua
  3. 1
    1
      test/functional/lua/prepostfilters.lua

+ 6
- 1
src/libserver/events.c View File

@@ -172,7 +172,7 @@ rspamd_session_add_event (struct rspamd_async_session *session,
new_event->user_data = user_data;
new_event->subsystem = subsystem;

msg_debug_session ("added event: %p, pending %d events, "
msg_debug_session ("added event: %p, pending %d (+1) events, "
"subsystem: %s",
user_data,
kh_size (session->events),
@@ -222,6 +222,11 @@ rspamd_session_remove_event (struct rspamd_async_session *session,
}

found_ev = kh_key (session->events, k);
msg_debug_session ("removed event: %p, pending %d (-1) events, "
"subsystem: %s",
ud,
kh_size (session->events),
g_quark_to_string (found_ev->subsystem));
kh_del (rspamd_events_hash, session->events, k);

/* Remove event */

+ 3
- 2
src/plugins/lua/asn.lua View File

@@ -74,8 +74,9 @@ local function asn_check(task)
asn_set(parts[1], parts[2], parts[3])
end

task:get_resolver():resolve_txt(task:get_session(), task:get_mempool(),
req_name, rspamd_dns_cb)
task:get_resolver():resolve_txt({task = task,
name = req_name,
callback = rspamd_dns_cb})
end

local ip = task:get_from_ip()

+ 1
- 1
test/functional/lua/prepostfilters.lua View File

@@ -16,7 +16,7 @@ for i = 1,10 do
end
if task:has_symbol('TEST_PRE') then
local r = task:get_resolver()
r:resolve_a(task:get_session(), task:get_mempool(), 'example.com', dns_cb)
r:resolve_a({task = task, name = 'example.com', callback = dns_cb})
end
end
})

Loading…
Cancel
Save