diff options
author | Vsevolod Stakhov <vsevolod@rspamd.com> | 2022-05-07 13:49:08 +0100 |
---|---|---|
committer | Vsevolod Stakhov <vsevolod@rspamd.com> | 2022-05-07 13:49:08 +0100 |
commit | e8fc5a0fa1dfb01857dd8de69c6b3eb015098155 (patch) | |
tree | 1baee92e7a3a27f3627fe2f638657c12eb78cc7a | |
parent | ba5446deadb42fe772250471dc61b9b55df73102 (diff) | |
download | rspamd-e8fc5a0fa1dfb01857dd8de69c6b3eb015098155.tar.gz rspamd-e8fc5a0fa1dfb01857dd8de69c6b3eb015098155.zip |
[Minor] Fix composites processing
-rw-r--r-- | src/libserver/composites/composites.cxx | 2 | ||||
-rw-r--r-- | src/libserver/symcache/symcache_c.cxx | 2 |
2 files changed, 3 insertions, 1 deletions
diff --git a/src/libserver/composites/composites.cxx b/src/libserver/composites/composites.cxx index f1d742ca9..12af51514 100644 --- a/src/libserver/composites/composites.cxx +++ b/src/libserver/composites/composites.cxx @@ -802,6 +802,8 @@ composites_foreach_callback(gpointer key, gpointer value, void *data) cd->composite = comp; task = cd->task; + msg_debug_composites("process composite %s", str_key); + if (!cd->checked[cd->composite->id * 2]) { if (rspamd_symcache_is_checked(cd->task, cd->task->cfg->cache, str_key)) { diff --git a/src/libserver/symcache/symcache_c.cxx b/src/libserver/symcache/symcache_c.cxx index 82ef7c164..d6e1bc6f2 100644 --- a/src/libserver/symcache/symcache_c.cxx +++ b/src/libserver/symcache/symcache_c.cxx @@ -536,7 +536,7 @@ rspamd_symcache_composites_foreach(struct rspamd_task *task, real_cache->composites_foreach([&](const auto *item) { auto *dyn_item = cache_runtime->get_dynamic_item(item->id, false); - if (dyn_item->started) { + if (!dyn_item->started) { func((void *)item->get_name().c_str(), item->get_cbdata(), fd); dyn_item->finished = true; } |