Browse Source

Controller sockets are owned by router do not export them to task.

tags/1.0.1
Vsevolod Stakhov 8 years ago
parent
commit
662ca2f0a4
1 changed files with 5 additions and 6 deletions
  1. 5
    6
      src/controller.c

+ 5
- 6
src/controller.c View File

task); task);
task->fin_arg = conn_ent; task->fin_arg = conn_ent;
task->http_conn = rspamd_http_connection_ref (conn_ent->conn);; task->http_conn = rspamd_http_connection_ref (conn_ent->conn);;
task->sock = conn_ent->conn->fd;
task->sock = -1;
session->task = task;
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->str, msg->body->len)) {
rspamd_controller_send_error (conn_ent, task->err->code, task->err->message); rspamd_controller_send_error (conn_ent, task->err->code, task->err->message);
rspamd_session_destroy (task->s);
return 0; return 0;
} }


if (!rspamd_task_process (task, RSPAMD_TASK_PROCESS_LEARN)) { if (!rspamd_task_process (task, RSPAMD_TASK_PROCESS_LEARN)) {
msg_warn_session ("message cannot be processed for %s", task->message_id);
msg_warn_session ("<%s> message cannot be processed", task->message_id);
rspamd_controller_send_error (conn_ent, task->err->code, task->err->message); rspamd_controller_send_error (conn_ent, task->err->code, task->err->message);
rspamd_session_destroy (task->s);
return 0; return 0;
} }


session->task = task;
session->cl = cl;
session->is_spam = is_spam; session->is_spam = is_spam;
rspamd_session_pending (task->s); rspamd_session_pending (task->s);


} }


rspamd_inet_address_destroy (session->from_addr); rspamd_inet_address_destroy (session->from_addr);
msg_debug_session ("destroy session %p", session);
g_slice_free1 (sizeof (struct rspamd_controller_session), session); g_slice_free1 (sizeof (struct rspamd_controller_session), session);
} }



Loading…
Cancel
Save