aboutsummaryrefslogtreecommitdiffstats
path: root/src
diff options
context:
space:
mode:
authorVsevolod Stakhov <vsevolod@highsecure.ru>2015-10-07 17:00:06 +0100
committerVsevolod Stakhov <vsevolod@highsecure.ru>2015-10-07 17:00:06 +0100
commitacabad508f5d9684d23c1f6662c7dc98f48e0227 (patch)
treebcc7e51c1b5fa512896ee01884bcd98778532030 /src
parent083e5d7a92f19ac44d0e17d97e434dd1bc212808 (diff)
downloadrspamd-acabad508f5d9684d23c1f6662c7dc98f48e0227.tar.gz
rspamd-acabad508f5d9684d23c1f6662c7dc98f48e0227.zip
Fix encryption in controller.
Diffstat (limited to 'src')
-rw-r--r--src/controller.c10
1 files changed, 5 insertions, 5 deletions
diff --git a/src/controller.c b/src/controller.c
index 6daf0bc57..871037b32 100644
--- a/src/controller.c
+++ b/src/controller.c
@@ -1274,7 +1274,7 @@ rspamd_controller_handle_learn_common (
session->cl = cl;
- if (!rspamd_task_load_message (task, msg, msg->body->str, msg->body->len)) {
+ if (!rspamd_task_load_message (task, msg, msg->body_buf.begin, msg->body_buf.len)) {
rspamd_controller_send_error (conn_ent, task->err->code, task->err->message);
return 0;
}
@@ -1366,7 +1366,7 @@ rspamd_controller_handle_scan (struct rspamd_http_connection_entry *conn_ent,
task->flags |= RSPAMD_TASK_FLAG_MIME;
task->resolver = ctx->resolver;
- if (!rspamd_task_load_message (task, msg, msg->body->str, msg->body->len)) {
+ if (!rspamd_task_load_message (task, msg, msg->body_buf.begin, msg->body_buf.len)) {
rspamd_controller_send_error (conn_ent, task->err->code, task->err->message);
rspamd_session_destroy (task->s);
return 0;
@@ -1441,7 +1441,7 @@ rspamd_controller_handle_saveactions (
}
parser = ucl_parser_new (0);
- ucl_parser_add_chunk (parser, msg->body->str, msg->body->len);
+ ucl_parser_add_chunk (parser, msg->body_buf.begin, msg->body_buf.len);
if ((error = ucl_parser_get_error (parser)) != NULL) {
msg_err_session ("cannot parse input: %s", error);
@@ -1555,7 +1555,7 @@ rspamd_controller_handle_savesymbols (
}
parser = ucl_parser_new (0);
- ucl_parser_add_chunk (parser, msg->body->str, msg->body->len);
+ ucl_parser_add_chunk (parser, msg->body_buf.begin, msg->body_buf.len);
if ((error = ucl_parser_get_error (parser)) != NULL) {
msg_err_session ("cannot parse input: %s", error);
@@ -1703,7 +1703,7 @@ rspamd_controller_handle_savemap (struct rspamd_http_connection_entry *conn_ent,
return 0;
}
- if (write (fd, msg->body->str, msg->body->len) == -1) {
+ if (write (fd, msg->body_buf.begin, msg->body_buf.len) == -1) {
msg_info_session ("map %s write error: %s", map->uri, strerror (errno));
close (fd);
g_atomic_int_set (map->locked, 0);