aboutsummaryrefslogtreecommitdiffstats
path: root/extras/filters/filter-rspamd/filter_rspamd.c
diff options
context:
space:
mode:
Diffstat (limited to 'extras/filters/filter-rspamd/filter_rspamd.c')
-rw-r--r--extras/filters/filter-rspamd/filter_rspamd.c11
1 files changed, 2 insertions, 9 deletions
diff --git a/extras/filters/filter-rspamd/filter_rspamd.c b/extras/filters/filter-rspamd/filter_rspamd.c
index b43ec0e..fe1077d 100644
--- a/extras/filters/filter-rspamd/filter_rspamd.c
+++ b/extras/filters/filter-rspamd/filter_rspamd.c
@@ -87,10 +87,6 @@ on_data(uint64_t id)
{
struct transaction *tx = filter_api_transaction(id);
- if (! rspamd_buffer(tx))
- return filter_api_reject_code(id, FILTER_FAIL, 421,
- "temporary failure");
-
if (! rspamd_connect(tx))
return filter_api_reject_code(id, FILTER_FAIL, 421,
"temporary failure");
@@ -102,11 +98,6 @@ static void
on_dataline(uint64_t id, const char *line)
{
struct transaction *tx = filter_api_transaction(id);
- ssize_t sz;
-
- sz = fprintf(tx->fp, "%s\n", line);
- if (sz == -1 || sz < (ssize_t)strlen(line) + 1)
- tx->error = 1;
rspamd_send_chunk(tx, line);
}
@@ -193,6 +184,8 @@ main(int argc, char **argv)
filter_api_transaction_allocator(transaction_allocator);
filter_api_transaction_destructor(transaction_destructor);
+ filter_api_data_buffered();
+
/*
if (c)
filter_api_set_chroot(c);