diff options
| author | Vsevolod Stakhov <vsevolod@rambler-co.ru> | 2009-01-12 18:04:47 +0300 |
|---|---|---|
| committer | Vsevolod Stakhov <vsevolod@rambler-co.ru> | 2009-01-12 18:04:47 +0300 |
| commit | 2dd1125642e3fad0390c8477bc1d2084aa59a630 (patch) | |
| tree | e879cc366ad428ba54b2494e731abd57a94c91c6 /src/filter.c | |
| parent | 640b2981e165356ea0609a740cc3e937cf6ab6d5 (diff) | |
| download | rspamd-2dd1125642e3fad0390c8477bc1d2084aa59a630.tar.gz rspamd-2dd1125642e3fad0390c8477bc1d2084aa59a630.zip | |
* Try to fix output from delayed filters processing
Diffstat (limited to 'src/filter.c')
| -rw-r--r-- | src/filter.c | 5 |
1 files changed, 5 insertions, 0 deletions
diff --git a/src/filter.c b/src/filter.c index 64d492e62..290769c54 100644 --- a/src/filter.c +++ b/src/filter.c @@ -188,6 +188,9 @@ continue_process_filters (struct worker_task *task) cur = LIST_NEXT (cur, next); } /* All done */ + bufferevent_enable (task->bev, EV_WRITE); + evbuffer_drain (task->bev->output, EVBUFFER_LENGTH (task->bev->output)); + process_statfiles (task); return 1; } } @@ -439,6 +442,8 @@ process_statfiles (struct worker_task *task) g_hash_table_destroy (cd.tokens); g_hash_table_destroy (cd.metrics); + + task->state = WRITE_REPLY; } static void |