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),
}
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 */
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()
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
})