diff options
| author | Vsevolod Stakhov <vsevolod@rspamd.com> | 2022-05-07 13:33:35 +0100 |
|---|---|---|
| committer | Vsevolod Stakhov <vsevolod@rspamd.com> | 2022-05-07 13:33:35 +0100 |
| commit | ba5446deadb42fe772250471dc61b9b55df73102 (patch) | |
| tree | 0dc6b71a935a1a9170556f87a66b7862f9967923 | |
| parent | 47cf9c8082000be8b63fbeb4c6d35c7b2bd05af5 (diff) | |
| download | rspamd-ba5446deadb42fe772250471dc61b9b55df73102.tar.gz rspamd-ba5446deadb42fe772250471dc61b9b55df73102.zip | |
[Minor] Fix filters processing
| -rw-r--r-- | src/libserver/symcache/symcache_runtime.cxx | 6 |
1 files changed, 3 insertions, 3 deletions
diff --git a/src/libserver/symcache/symcache_runtime.cxx b/src/libserver/symcache/symcache_runtime.cxx index 1e334230b..401cdb027 100644 --- a/src/libserver/symcache/symcache_runtime.cxx +++ b/src/libserver/symcache/symcache_runtime.cxx @@ -424,7 +424,7 @@ symcache_runtime::process_filters(struct rspamd_task *task, symcache &cache, int auto all_done = true; for (const auto [idx, item] : rspamd::enumerate(order->d)) { - if (item->type == symcache_item_type::CLASSIFIER) { + if (item->type == symcache_item_type::CLASSIFIER || item->type == symcache_item_type::COMPOSITE) { continue; } @@ -438,7 +438,7 @@ symcache_runtime::process_filters(struct rspamd_task *task, symcache &cache, int msg_debug_cache_task("blocked execution of %d(%s) unless deps are " "resolved", item->id, item->symbol.c_str()); - break; + continue; } process_symbol(task, cache, item.get(), dyn_item); @@ -447,7 +447,7 @@ symcache_runtime::process_filters(struct rspamd_task *task, symcache &cache, int /* Delay */ has_slow = false; - break; + return false; } } |