task->task_pool->tag.tagname, task->task_pool->tag.uid, \
RSPAMD_LOG_FUNC, \
__VA_ARGS__)
+#define msg_info_task_lambda(...) rspamd_default_log_function (G_LOG_LEVEL_INFO, \
+ task->task_pool->tag.tagname, task->task_pool->tag.uid, \
+ log_func, \
+ __VA_ARGS__)
#define msg_debug_task(...) rspamd_conditional_debug_fast (NULL, task->from_addr, \
rspamd_task_log_id, "task", task->task_pool->tag.uid, \
RSPAMD_LOG_FUNC, \
disable_symbol(task, cache, sym);
});
+ /* Update required limit */
+ lim = rspamd_task_get_required_score(task, task->result);
+
return false;
}
{
auto saved_priority = std::numeric_limits<int>::min();
auto all_done = true;
+ auto log_func = RSPAMD_LOG_FUNC;
auto compare_functor = +[](int a, int b) { return a < b; };
auto proc_func = [&](cache_item *item) {
if (stage != RSPAMD_TASK_STAGE_IDEMPOTENT &&
!(item->flags & SYMBOL_TYPE_IGNORE_PASSTHROUGH)) {
if (check_metric_limit(task)) {
- msg_info_task("task has already the result being set, ignore further checks");
- return false;
+ msg_info_task_lambda("task has already the result being set, ignore further checks");
+
+ return true;
}
}