[Minor] Fix composites processing

diff --git a/src/libserver/composites/composites.cxx b/src/libserver/composites/composites.cxx
index f1d742ca95bd97316d88448164092ee4efe95b5a..12af51514acd30c80e6804974725ab0dd44e9c9e 100644 (file)
--- 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 82ef7c164dbcd154122b8c703d9c8e366591e188..d6e1bc6f2233b8ee2525788180ac650d6a2c4094 100644 (file)
--- 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;
                }