summaryrefslogtreecommitdiffstats
path: root/src/plugins/surbl.c
diff options
context:
space:
mode:
authorVsevolod Stakhov <vsevolod@rambler-co.ru>2009-03-11 19:45:57 +0300
committerVsevolod Stakhov <vsevolod@rambler-co.ru>2009-03-11 19:45:57 +0300
commit512154c538336e68b59ef0ed2c87ef9ba1e94151 (patch)
tree9aa7ca19d9207d17d6bb58252a8219aa0d7cc2d9 /src/plugins/surbl.c
parent847e20651fd679b45e90fd7e0f2dc43dd746a90c (diff)
downloadrspamd-512154c538336e68b59ef0ed2c87ef9ba1e94151.tar.gz
rspamd-512154c538336e68b59ef0ed2c87ef9ba1e94151.zip
* Add log line for each message in SA style
Diffstat (limited to 'src/plugins/surbl.c')
-rw-r--r--src/plugins/surbl.c12
1 files changed, 6 insertions, 6 deletions
diff --git a/src/plugins/surbl.c b/src/plugins/surbl.c
index a5ea46865..11abc49d9 100644
--- a/src/plugins/surbl.c
+++ b/src/plugins/surbl.c
@@ -387,12 +387,12 @@ dns_callback (int result, char type, int count, int ttl, void *addresses, void *
/* If we have result from DNS server, this url exists in SURBL, so increase score */
if (result == DNS_ERR_NONE && type == DNS_IPv4_A) {
msg_info ("surbl_check: <%s> url %s is in surbl %s",
- param->task->queue_id, param->url->host, param->suffix->suffix);
+ param->task->message_id, param->url->host, param->suffix->suffix);
process_dns_results (param->task, param->suffix, param->url->host, (uint32_t)(((in_addr_t *)addresses)[0]));
}
else {
msg_debug ("surbl_check: <%s> url %s is not in surbl %s",
- param->task->queue_id, param->url->host, param->suffix->suffix);
+ param->task->message_id, param->url->host, param->suffix->suffix);
}
*(param->url->host + param->url->hostlen) = c;
@@ -556,7 +556,7 @@ redirector_callback (int fd, short what, void *arg)
else {
event_del (&param->ev);
msg_info ("redirector_callback: <%s> connection to redirector timed out while waiting for write",
- param->task->queue_id);
+ param->task->message_id);
param->task->save.saved --;
make_surbl_requests (param->url, param->task, param->tree);
@@ -581,7 +581,7 @@ redirector_callback (int fd, short what, void *arg)
}
if (*p == '\0') {
msg_info ("redirector_callback: <%s> got reply from redirector: '%s' -> '%s'",
- param->task->queue_id, struri (param->url), c);
+ param->task->message_id, struri (param->url), c);
parse_uri (param->url, c, param->task->task_pool);
}
}
@@ -597,7 +597,7 @@ redirector_callback (int fd, short what, void *arg)
else {
event_del (&param->ev);
msg_info ("redirector_callback: <%s> reading redirector timed out, while waiting for read",
- param->task->queue_id);
+ param->task->message_id);
param->task->save.saved --;
make_surbl_requests (param->url, param->task, param->tree);
if (param->task->save.saved == 0) {
@@ -622,7 +622,7 @@ register_redirector_call (struct uri *url, struct worker_task *task, GTree *url_
if (s == -1) {
msg_info ("register_redirector_call: <%s> cannot create tcp socket failed: %s",
- task->queue_id, strerror (errno));
+ task->message_id, strerror (errno));
task->save.saved --;
make_surbl_requests (url, task, url_tree);
return;