}
if (task->queue_id) {
- msg_info_task ("loaded message; id: <%s>; queue-id: <%s>",
- task->message_id, task->queue_id);
+ msg_info_task ("loaded message; id: <%s>; queue-id: <%s>; size: %z",
+ task->message_id, task->queue_id, task->msg.len);
}
else {
- msg_info_task ("loaded message; id: <%s>",
- task->message_id);
+ msg_info_task ("loaded message; id: <%s>; size: %z",
+ task->message_id, task->msg.len);
}
return TRUE;
}
}
-static inline gboolean
+static inline gint
register_fuzzy_controller_call (struct rspamd_http_connection_entry *entry,
struct fuzzy_rule *rule,
struct rspamd_task *task,
rspamd_inet_addr_t *addr;
struct rspamd_controller_session *session = entry->ud;
gint sock;
- gboolean ret = FALSE;
+ gint ret = -1;
/* Get upstream */
event_add (&s->timev, &s->tv);
(*saved)++;
- ret = TRUE;
+ ret = 1;
}
}