diff options
| author | Vsevolod Stakhov <vsevolod@highsecure.ru> | 2016-09-06 13:06:56 +0100 |
|---|---|---|
| committer | Vsevolod Stakhov <vsevolod@highsecure.ru> | 2016-09-06 13:06:56 +0100 |
| commit | 24a938191c782716712d2e68dc304b60968af71e (patch) | |
| tree | b7f85342bf12b6630f59da7ab3a96c4d2eb51024 /src/fuzzy_storage.c | |
| parent | 7cfddfbd2230e79ce07b2c1c0b65a0f67edb576d (diff) | |
| download | rspamd-24a938191c782716712d2e68dc304b60968af71e.tar.gz rspamd-24a938191c782716712d2e68dc304b60968af71e.zip | |
[Minor] Create updates queue befroe periodic updates
Diffstat (limited to 'src/fuzzy_storage.c')
| -rw-r--r-- | src/fuzzy_storage.c | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/src/fuzzy_storage.c b/src/fuzzy_storage.c index bdb5f4aa4..feac6e11b 100644 --- a/src/fuzzy_storage.c +++ b/src/fuzzy_storage.c @@ -2236,7 +2236,6 @@ fuzzy_peer_rep (struct rspamd_worker *worker, rspamd_fuzzy_peer_io, ctx); event_base_set (ctx->ev_base, &ctx->peer_ev); event_add (&ctx->peer_ev, NULL); - ctx->updates_pending = g_queue_new (); } } @@ -2284,6 +2283,7 @@ start_fuzzy (struct rspamd_worker *worker) } if (worker->index == 0) { + ctx->updates_pending = g_queue_new (); rspamd_fuzzy_backend_start_update (ctx->backend, ctx->sync_timeout, rspamd_fuzzy_storage_periodic_callback, ctx); } |