diff options
| author | Vsevolod Stakhov <vsevolod@rambler-co.ru> | 2010-09-02 20:24:41 +0400 |
|---|---|---|
| committer | Vsevolod Stakhov <vsevolod@rambler-co.ru> | 2010-09-02 20:24:41 +0400 |
| commit | 07a2e0b3c8ac8249f35423ab79b23b6b5ab11c51 (patch) | |
| tree | 231437d521e228e95de289f15b1fcc4878db4b03 /src/buffer.c | |
| parent | 5086821ae43d0283ed8b839c847ca267c3c81d2c (diff) | |
| download | rspamd-07a2e0b3c8ac8249f35423ab79b23b6b5ab11c51.tar.gz rspamd-07a2e0b3c8ac8249f35423ab79b23b6b5ab11c51.zip | |
* Many fixes to statfile syncronization system
* Fixed statfile pool initialization and synchronization with disk
Diffstat (limited to 'src/buffer.c')
| -rw-r--r-- | src/buffer.c | 4 |
1 files changed, 4 insertions, 0 deletions
diff --git a/src/buffer.c b/src/buffer.c index d0c36f8ea..c5b775dfc 100644 --- a/src/buffer.c +++ b/src/buffer.c @@ -403,6 +403,10 @@ read_buffers (int fd, rspamd_io_dispatcher_t * d, gboolean skip_read) b = d->in_buf->data->begin; c = b; } + else { + d->in_buf->data->len = 0; + d->in_buf->pos = d->in_buf->data->begin; + } if (d->policy != saved_policy && len != r) { debug_ip (d->peer_addr, "policy changed during callback, restart buffer's processing"); read_buffers (fd, d, TRUE); |