diff options
| author | Vsevolod Stakhov <vsevolod@highsecure.ru> | 2014-01-12 15:20:50 +0000 |
|---|---|---|
| committer | Vsevolod Stakhov <vsevolod@highsecure.ru> | 2014-01-12 15:20:50 +0000 |
| commit | 67b932ad9786743dc032ff2adc3788c5aadd3933 (patch) | |
| tree | 084872b519dc54beef83cbdade01af8bb639eafd /src/controller.c | |
| parent | d6b454eda97f6ffe8455ec83ab8da6293e7b9c07 (diff) | |
| download | rspamd-67b932ad9786743dc032ff2adc3788c5aadd3933.tar.gz rspamd-67b932ad9786743dc032ff2adc3788c5aadd3933.zip | |
Start moving to HTTP world.
Diffstat (limited to 'src/controller.c')
| -rw-r--r-- | src/controller.c | 12 |
1 files changed, 3 insertions, 9 deletions
diff --git a/src/controller.c b/src/controller.c index d3f0f2855..a43b14203 100644 --- a/src/controller.c +++ b/src/controller.c @@ -1411,9 +1411,7 @@ controller_read_socket (f_str_t * in, void *arg) session->learn_buf = in; task = construct_task (session->worker); - task->msg = memory_pool_alloc (task->task_pool, sizeof (f_str_t)); - task->msg->begin = in->begin; - task->msg->len = in->len; + task->msg = g_string_new_len (in->begin, in->len); task->ev_base = session->ev_base; r = process_message (task); @@ -1476,9 +1474,7 @@ controller_read_socket (f_str_t * in, void *arg) session->learn_buf = in; task = construct_task (session->worker); - task->msg = memory_pool_alloc (task->task_pool, sizeof (f_str_t)); - task->msg->begin = in->begin; - task->msg->len = in->len; + task->msg = g_string_new_len (in->begin, in->len); task->resolver = session->resolver; task->ev_base = session->ev_base; @@ -1538,9 +1534,7 @@ controller_read_socket (f_str_t * in, void *arg) session->learn_buf = in; task = construct_task (session->worker); - task->msg = memory_pool_alloc (task->task_pool, sizeof (f_str_t)); - task->msg->begin = in->begin; - task->msg->len = in->len; + task->msg = g_string_new_len (in->begin, in->len); task->ev_base = session->ev_base; r = process_message (task); |