Lines Matching refs:conn_ent

719 rspamd_controller_handle_auth (struct rspamd_http_connection_entry *conn_ent,  in rspamd_controller_handle_auth()  argument
722 struct rspamd_controller_session *session = conn_ent->ud; in rspamd_controller_handle_auth()
728 if (!rspamd_controller_check_password (conn_ent, session, msg, FALSE)) { in rspamd_controller_handle_auth()
769 rspamd_controller_send_ucl (conn_ent, obj); in rspamd_controller_handle_auth()
791 rspamd_controller_handle_symbols (struct rspamd_http_connection_entry *conn_ent, in rspamd_controller_handle_symbols() argument
794 struct rspamd_controller_session *session = conn_ent->ud; in rspamd_controller_handle_symbols()
801 if (!rspamd_controller_check_password (conn_ent, session, msg, FALSE)) { in rspamd_controller_handle_symbols()
857 rspamd_controller_send_ucl (conn_ent, top); in rspamd_controller_handle_symbols()
873 rspamd_controller_handle_actions (struct rspamd_http_connection_entry *conn_ent, in rspamd_controller_handle_actions() argument
876 struct rspamd_controller_session *session = conn_ent->ud; in rspamd_controller_handle_actions()
880 if (!rspamd_controller_check_password (conn_ent, session, msg, FALSE)) { in rspamd_controller_handle_actions()
897 rspamd_controller_send_ucl (conn_ent, top); in rspamd_controller_handle_actions()
942 rspamd_controller_handle_maps (struct rspamd_http_connection_entry *conn_ent, in rspamd_controller_handle_maps() argument
945 struct rspamd_controller_session *session = conn_ent->ud; in rspamd_controller_handle_maps()
953 if (!rspamd_controller_check_password (conn_ent, session, msg, FALSE)) { in rspamd_controller_handle_maps()
991 rspamd_controller_send_ucl (conn_ent, top); in rspamd_controller_handle_maps()
1004 rspamd_controller_handle_get_map (struct rspamd_http_connection_entry *conn_ent, in rspamd_controller_handle_get_map() argument
1007 struct rspamd_controller_session *session = conn_ent->ud; in rspamd_controller_handle_get_map()
1018 if (!rspamd_controller_check_password (conn_ent, session, msg, FALSE)) { in rspamd_controller_handle_get_map()
1026 rspamd_controller_send_error (conn_ent, 400, "Id header missing"); in rspamd_controller_handle_get_map()
1032 rspamd_controller_send_error (conn_ent, 400, "Invalid map id"); in rspamd_controller_handle_get_map()
1053 rspamd_controller_send_error (conn_ent, 404, "Map not found"); in rspamd_controller_handle_get_map()
1073 rspamd_controller_send_error (conn_ent, 500, "Map read error"); in rspamd_controller_handle_get_map()
1085 rspamd_http_connection_reset (conn_ent->conn); in rspamd_controller_handle_get_map()
1086 rspamd_http_router_insert_headers (conn_ent->rt, reply); in rspamd_controller_handle_get_map()
1087 rspamd_http_connection_write_message (conn_ent->conn, reply, NULL, in rspamd_controller_handle_get_map()
1088 "text/plain", conn_ent, in rspamd_controller_handle_get_map()
1089 conn_ent->rt->timeout); in rspamd_controller_handle_get_map()
1090 conn_ent->is_reply = TRUE; in rspamd_controller_handle_get_map()
1130 struct rspamd_http_connection_entry *conn_ent, in rspamd_controller_handle_pie_chart() argument
1133 struct rspamd_controller_session *session = conn_ent->ud; in rspamd_controller_handle_pie_chart()
1140 if (!rspamd_controller_check_password (conn_ent, session, msg, FALSE)) { in rspamd_controller_handle_pie_chart()
1169 rspamd_controller_send_ucl (conn_ent, top); in rspamd_controller_handle_pie_chart()
1226 struct rspamd_http_connection_entry *conn_ent, in rspamd_controller_handle_graph() argument
1230 struct rspamd_controller_session *session = conn_ent->ud; in rspamd_controller_handle_graph()
1249 if (!rspamd_controller_check_password (conn_ent, session, msg, FALSE)) { in rspamd_controller_handle_graph()
1255 rspamd_controller_send_error (conn_ent, 404, "No rrd configured for graphs"); in rspamd_controller_handle_graph()
1266 rspamd_controller_send_error (conn_ent, 400, "Absent graph type"); in rspamd_controller_handle_graph()
1292 rspamd_controller_send_error (conn_ent, 400, "Invalid graph type"); in rspamd_controller_handle_graph()
1301 rspamd_controller_send_error (conn_ent, 500, "Cannot query rrd"); in rspamd_controller_handle_graph()
1362 rspamd_controller_send_ucl (conn_ent, res); in rspamd_controller_handle_graph()
1374 struct rspamd_http_connection_entry *conn_ent, in rspamd_controller_handle_legacy_history() argument
1479 rspamd_controller_send_ucl (conn_ent, top); in rspamd_controller_handle_legacy_history()
1494 struct rspamd_http_connection_entry *conn_ent, in rspamd_controller_handle_lua_history() argument
1544 task->fin_arg = conn_ent; in rspamd_controller_handle_lua_history()
1550 *pconn_ent = conn_ent; in rspamd_controller_handle_lua_history()
1565 task->http_conn = rspamd_http_connection_ref (conn_ent->conn);; in rspamd_controller_handle_lua_history()
1593 rspamd_controller_send_error (conn_ent, 500, "Internal error"); in rspamd_controller_handle_lua_history()
1603 rspamd_controller_handle_healthy (struct rspamd_http_connection_entry *conn_ent, in rspamd_controller_handle_healthy() argument
1606 struct rspamd_controller_session *session = conn_ent->ud; in rspamd_controller_handle_healthy()
1608 if (!rspamd_controller_check_password (conn_ent, session, msg, FALSE)) { in rspamd_controller_handle_healthy()
1613 rspamd_controller_send_error (conn_ent, 500, in rspamd_controller_handle_healthy()
1617 rspamd_controller_send_string (conn_ent, "{\"success\":true}"); in rspamd_controller_handle_healthy()
1630 rspamd_controller_handle_ready (struct rspamd_http_connection_entry *conn_ent, in rspamd_controller_handle_ready() argument
1633 struct rspamd_controller_session *session = conn_ent->ud; in rspamd_controller_handle_ready()
1635 if (!rspamd_controller_check_password (conn_ent, session, msg, FALSE)) { in rspamd_controller_handle_ready()
1640 rspamd_controller_send_error (conn_ent, 500, "no healthy scanner workers are running"); in rspamd_controller_handle_ready()
1643 rspamd_controller_send_string (conn_ent, "{\"success\":true}"); in rspamd_controller_handle_ready()
1660 rspamd_controller_handle_history (struct rspamd_http_connection_entry *conn_ent, in rspamd_controller_handle_history() argument
1663 struct rspamd_controller_session *session = conn_ent->ud; in rspamd_controller_handle_history()
1668 if (!rspamd_controller_check_password (conn_ent, session, msg, FALSE)) { in rspamd_controller_handle_history()
1675 rspamd_controller_handle_legacy_history (session, ctx, conn_ent, msg); in rspamd_controller_handle_history()
1678 rspamd_controller_handle_lua_history (L, session, ctx, conn_ent, msg, in rspamd_controller_handle_history()
1695 rspamd_controller_handle_errors (struct rspamd_http_connection_entry *conn_ent, in rspamd_controller_handle_errors() argument
1698 struct rspamd_controller_session *session = conn_ent->ud; in rspamd_controller_handle_errors()
1704 if (!rspamd_controller_check_password (conn_ent, session, msg, TRUE)) { in rspamd_controller_handle_errors()
1709 rspamd_controller_send_ucl (conn_ent, top); in rspamd_controller_handle_errors()
1722 rspamd_controller_handle_neighbours (struct rspamd_http_connection_entry *conn_ent, in rspamd_controller_handle_neighbours() argument
1725 struct rspamd_controller_session *session = conn_ent->ud; in rspamd_controller_handle_neighbours()
1730 if (!rspamd_controller_check_password (conn_ent, session, msg, FALSE)) { in rspamd_controller_handle_neighbours()
1734 rspamd_controller_send_ucl (conn_ent, ctx->cfg->neighbours); in rspamd_controller_handle_neighbours()
1741 rspamd_controller_handle_history_reset (struct rspamd_http_connection_entry *conn_ent, in rspamd_controller_handle_history_reset() argument
1744 struct rspamd_controller_session *session = conn_ent->ud; in rspamd_controller_handle_history_reset()
1753 if (!rspamd_controller_check_password (conn_ent, session, msg, TRUE)) { in rspamd_controller_handle_history_reset()
1778 rspamd_controller_send_string (conn_ent, "{\"success\":true}"); in rspamd_controller_handle_history_reset()
1781 rspamd_controller_handle_lua_history (L, session, ctx, conn_ent, msg, in rspamd_controller_handle_history_reset()
1792 struct rspamd_http_connection_entry *conn_ent; in rspamd_controller_lua_fin_task() local
1794 conn_ent = task->fin_arg; in rspamd_controller_lua_fin_task()
1797 rspamd_controller_send_error (conn_ent, task->err->code, "%s", in rspamd_controller_lua_fin_task()
1805 rspamd_controller_handle_lua (struct rspamd_http_connection_entry *conn_ent, in rspamd_controller_handle_lua() argument
1808 struct rspamd_controller_session *session = conn_ent->ud; in rspamd_controller_handle_lua()
1818 if (!rspamd_controller_check_password (conn_ent, session, msg, TRUE)) { in rspamd_controller_handle_lua()
1846 rspamd_controller_send_error (conn_ent, 404, "Cannot find path: %s", in rspamd_controller_handle_lua()
1855 rspamd_controller_send_error (conn_ent, 500, "Cannot load path: %s", in rspamd_controller_handle_lua()
1863 rspamd_controller_send_error (conn_ent, 501, "Cannot run path: %s", in rspamd_controller_handle_lua()
1871 rspamd_controller_send_error (conn_ent, 502, "Bad return type: %s", in rspamd_controller_handle_lua()
1880 rspamd_controller_send_error (conn_ent, 404, "Empty path is not permitted"); in rspamd_controller_handle_lua()
1894 task->fin_arg = conn_ent; in rspamd_controller_handle_lua()
1895 task->http_conn = rspamd_http_connection_ref (conn_ent->conn);; in rspamd_controller_handle_lua()
1901 rspamd_controller_send_error (conn_ent, task->err->code, "%s", in rspamd_controller_handle_lua()
1913 *pconn = conn_ent; in rspamd_controller_handle_lua()
1916 rspamd_controller_send_error (conn_ent, 503, "Cannot run callback: %s", in rspamd_controller_handle_lua()
1933 struct rspamd_http_connection_entry *conn_ent; in rspamd_controller_learn_fin_task() local
1935 conn_ent = task->fin_arg; in rspamd_controller_learn_fin_task()
1936 session = conn_ent->ud; in rspamd_controller_learn_fin_task()
1941 rspamd_controller_send_error (conn_ent, task->err->code, "%s", in rspamd_controller_learn_fin_task()
1953 rspamd_controller_send_string (conn_ent, "{\"success\":true}"); in rspamd_controller_learn_fin_task()
1962 rspamd_controller_send_error (conn_ent, task->err->code, "%s", in rspamd_controller_learn_fin_task()
1966 rspamd_controller_send_error (conn_ent, 500, in rspamd_controller_learn_fin_task()
1973 rspamd_controller_send_error (conn_ent, task->err->code, "%s", in rspamd_controller_learn_fin_task()
1981 rspamd_controller_send_string (conn_ent, "{\"success\":true}"); in rspamd_controller_learn_fin_task()
1995 struct rspamd_http_connection_entry *conn_ent; in rspamd_controller_scan_reply() local
1997 conn_ent = task->fin_arg; in rspamd_controller_scan_reply()
2002 rspamd_http_connection_reset (conn_ent->conn); in rspamd_controller_scan_reply()
2003 rspamd_http_router_insert_headers (conn_ent->rt, msg); in rspamd_controller_scan_reply()
2004 rspamd_http_connection_write_message (conn_ent->conn, msg, NULL, in rspamd_controller_scan_reply()
2005 "application/json", conn_ent, conn_ent->rt->timeout); in rspamd_controller_scan_reply()
2006 conn_ent->is_reply = TRUE; in rspamd_controller_scan_reply()
2013 struct rspamd_http_connection_entry *conn_ent; in rspamd_controller_check_fin_task() local
2016 conn_ent = task->fin_arg; in rspamd_controller_check_fin_task()
2021 rspamd_controller_send_error (conn_ent, task->err->code, "%s", in rspamd_controller_check_fin_task()
2047 struct rspamd_http_connection_entry *conn_ent, in rspamd_controller_handle_learn_common() argument
2051 struct rspamd_controller_session *session = conn_ent->ud; in rspamd_controller_handle_learn_common()
2058 if (!rspamd_controller_check_password (conn_ent, session, msg, TRUE)) { in rspamd_controller_handle_learn_common()
2064 rspamd_controller_send_error (conn_ent, in rspamd_controller_handle_learn_common()
2079 task->fin_arg = conn_ent; in rspamd_controller_handle_learn_common()
2080 task->http_conn = rspamd_http_connection_ref (conn_ent->conn);; in rspamd_controller_handle_learn_common()
2120 struct rspamd_http_connection_entry *conn_ent, in rspamd_controller_handle_learnspam() argument
2123 return rspamd_controller_handle_learn_common (conn_ent, msg, TRUE); in rspamd_controller_handle_learnspam()
2134 struct rspamd_http_connection_entry *conn_ent, in rspamd_controller_handle_learnham() argument
2137 return rspamd_controller_handle_learn_common (conn_ent, msg, FALSE); in rspamd_controller_handle_learnham()
2148 rspamd_controller_handle_scan (struct rspamd_http_connection_entry *conn_ent, in rspamd_controller_handle_scan() argument
2151 struct rspamd_controller_session *session = conn_ent->ud; in rspamd_controller_handle_scan()
2157 if (!rspamd_controller_check_password (conn_ent, session, msg, FALSE)) { in rspamd_controller_handle_scan()
2170 task->fin_arg = conn_ent; in rspamd_controller_handle_scan()
2171 task->http_conn = rspamd_http_connection_ref (conn_ent->conn); in rspamd_controller_handle_scan()
2172 task->sock = conn_ent->conn->fd; in rspamd_controller_handle_scan()
2212 struct rspamd_http_connection_entry *conn_ent, in rspamd_controller_handle_saveactions() argument
2215 struct rspamd_controller_session *session = conn_ent->ud; in rspamd_controller_handle_saveactions()
2228 if (!rspamd_controller_check_password (conn_ent, session, msg, TRUE)) { in rspamd_controller_handle_saveactions()
2234 rspamd_controller_send_error (conn_ent, in rspamd_controller_handle_saveactions()
2244 rspamd_controller_send_error (conn_ent, 400, "Cannot parse input"); in rspamd_controller_handle_saveactions()
2250 rspamd_controller_send_error (conn_ent, 400, "Cannot parse input"); in rspamd_controller_handle_saveactions()
2260 rspamd_controller_send_error (conn_ent, 400, "Cannot parse input"); in rspamd_controller_handle_saveactions()
2313 rspamd_controller_send_string (conn_ent, "{\"success\":true}"); in rspamd_controller_handle_saveactions()
2316 rspamd_controller_send_error (conn_ent, 500, "Save error"); in rspamd_controller_handle_saveactions()
2333 struct rspamd_http_connection_entry *conn_ent, in rspamd_controller_handle_savesymbols() argument
2336 struct rspamd_controller_session *session = conn_ent->ud; in rspamd_controller_handle_savesymbols()
2349 if (!rspamd_controller_check_password (conn_ent, session, msg, TRUE)) { in rspamd_controller_handle_savesymbols()
2355 rspamd_controller_send_error (conn_ent, in rspamd_controller_handle_savesymbols()
2365 rspamd_controller_send_error (conn_ent, 400, "Cannot parse input"); in rspamd_controller_handle_savesymbols()
2371 rspamd_controller_send_error (conn_ent, 400, "Cannot parse input"); in rspamd_controller_handle_savesymbols()
2381 rspamd_controller_send_error (conn_ent, 400, "Cannot parse input"); in rspamd_controller_handle_savesymbols()
2391 rspamd_controller_send_error (conn_ent, 400, "Cannot parse input"); in rspamd_controller_handle_savesymbols()
2408 rspamd_controller_send_error (conn_ent, 506, in rspamd_controller_handle_savesymbols()
2434 rspamd_controller_send_string (conn_ent, "{\"success\":true}"); in rspamd_controller_handle_savesymbols()
2437 rspamd_controller_send_error (conn_ent, 500, "Save error"); in rspamd_controller_handle_savesymbols()
2441 rspamd_controller_send_string (conn_ent, "{\"success\":true}"); in rspamd_controller_handle_savesymbols()
2446 rspamd_controller_send_error (conn_ent, 404, "No symbols to save"); in rspamd_controller_handle_savesymbols()
2462 rspamd_controller_handle_savemap (struct rspamd_http_connection_entry *conn_ent, in rspamd_controller_handle_savemap() argument
2465 struct rspamd_controller_session *session = conn_ent->ud; in rspamd_controller_handle_savemap()
2478 if (!rspamd_controller_check_password (conn_ent, session, msg, TRUE)) { in rspamd_controller_handle_savemap()
2484 rspamd_controller_send_error (conn_ent, in rspamd_controller_handle_savemap()
2494 rspamd_controller_send_error (conn_ent, 400, "Map id not specified"); in rspamd_controller_handle_savemap()
2500 rspamd_controller_send_error (conn_ent, 400, "Map id is invalid"); in rspamd_controller_handle_savemap()
2520 rspamd_controller_send_error (conn_ent, 404, "Map id not found"); in rspamd_controller_handle_savemap()
2529 rspamd_controller_send_error (conn_ent, 404, in rspamd_controller_handle_savemap()
2539 rspamd_controller_send_error (conn_ent, 500, "Map write error: %s", in rspamd_controller_handle_savemap()
2549 rspamd_controller_send_error (conn_ent, 500, "Map rename error: %s", in rspamd_controller_handle_savemap()
2559 rspamd_controller_send_string (conn_ent, "{\"success\":true}"); in rspamd_controller_handle_savemap()
2565 struct rspamd_http_connection_entry *conn_ent; member
2576 struct rspamd_http_connection_entry *conn_ent; in rspamd_controller_stat_fin_task() local
2581 conn_ent = cbdata->conn_ent; in rspamd_controller_stat_fin_task()
2608 rspamd_controller_send_ucl (conn_ent, top); in rspamd_controller_stat_fin_task()
2631 struct rspamd_http_connection_entry *conn_ent, in rspamd_controller_handle_stat_common() argument
2635 struct rspamd_controller_session *session = conn_ent->ud; in rspamd_controller_handle_stat_common()
2656 cbdata->conn_ent = conn_ent; in rspamd_controller_handle_stat_common()
2667 task->http_conn = rspamd_http_connection_ref (conn_ent->conn);; in rspamd_controller_handle_stat_common()
2668 task->sock = conn_ent->conn->fd; in rspamd_controller_handle_stat_common()
2760 rspamd_controller_handle_stat (struct rspamd_http_connection_entry *conn_ent, in rspamd_controller_handle_stat() argument
2763 struct rspamd_controller_session *session = conn_ent->ud; in rspamd_controller_handle_stat()
2765 if (!rspamd_controller_check_password (conn_ent, session, msg, FALSE)) { in rspamd_controller_handle_stat()
2769 return rspamd_controller_handle_stat_common (conn_ent, msg, FALSE); in rspamd_controller_handle_stat()
2774 struct rspamd_http_connection_entry *conn_ent, in rspamd_controller_handle_statreset() argument
2777 struct rspamd_controller_session *session = conn_ent->ud; in rspamd_controller_handle_statreset()
2779 if (!rspamd_controller_check_password (conn_ent, session, msg, TRUE)) { in rspamd_controller_handle_statreset()
2785 return rspamd_controller_handle_stat_common (conn_ent, msg, TRUE); in rspamd_controller_handle_statreset()
2798 struct rspamd_http_connection_entry *conn_ent; in rspamd_controller_metrics_fin_task() local
2805 conn_ent = cbdata->conn_ent; in rspamd_controller_metrics_fin_task()
3021 rspamd_controller_send_openmetrics (conn_ent, output); in rspamd_controller_metrics_fin_task()
3028 struct rspamd_http_connection_entry *conn_ent, in rspamd_controller_handle_metrics_common() argument
3032 struct rspamd_controller_session *session = conn_ent->ud; in rspamd_controller_handle_metrics_common()
3053 cbdata->conn_ent = conn_ent; in rspamd_controller_handle_metrics_common()
3064 task->http_conn = rspamd_http_connection_ref (conn_ent->conn);; in rspamd_controller_handle_metrics_common()
3065 task->sock = conn_ent->conn->fd; in rspamd_controller_handle_metrics_common()
3162 rspamd_controller_handle_metrics (struct rspamd_http_connection_entry *conn_ent, in rspamd_controller_handle_metrics() argument
3165 struct rspamd_controller_session *session = conn_ent->ud; in rspamd_controller_handle_metrics()
3167 if (!rspamd_controller_check_password (conn_ent, session, msg, FALSE)) { in rspamd_controller_handle_metrics()
3170 return rspamd_controller_handle_metrics_common (conn_ent, msg, FALSE); in rspamd_controller_handle_metrics()
3182 struct rspamd_http_connection_entry *conn_ent, in rspamd_controller_handle_counters() argument
3185 struct rspamd_controller_session *session = conn_ent->ud; in rspamd_controller_handle_counters()
3189 if (!rspamd_controller_check_password (conn_ent, session, msg, FALSE)) { in rspamd_controller_handle_counters()
3197 rspamd_controller_send_ucl (conn_ent, top); in rspamd_controller_handle_counters()
3201 rspamd_controller_send_error (conn_ent, 500, "Invalid cache"); in rspamd_controller_handle_counters()
3208 rspamd_controller_handle_custom (struct rspamd_http_connection_entry *conn_ent, in rspamd_controller_handle_custom() argument
3211 struct rspamd_controller_session *session = conn_ent->ud; in rspamd_controller_handle_custom()
3240 rspamd_controller_send_error (conn_ent, 404, "No command associated"); in rspamd_controller_handle_custom()
3244 if (!rspamd_controller_check_password (conn_ent, session, msg, in rspamd_controller_handle_custom()
3250 rspamd_controller_send_error (conn_ent, in rspamd_controller_handle_custom()
3283 return cmd->handler (conn_ent, msg, cmd->ctx); in rspamd_controller_handle_custom()
3287 rspamd_controller_handle_plugins (struct rspamd_http_connection_entry *conn_ent, in rspamd_controller_handle_plugins() argument
3290 struct rspamd_controller_session *session = conn_ent->ud; in rspamd_controller_handle_plugins()
3296 if (!rspamd_controller_check_password (conn_ent, session, msg, in rspamd_controller_handle_plugins()
3327 rspamd_controller_send_ucl (conn_ent, plugins); in rspamd_controller_handle_plugins()
3334 rspamd_controller_handle_ping (struct rspamd_http_connection_entry *conn_ent, in rspamd_controller_handle_ping() argument
3346 rspamd_http_connection_reset (conn_ent->conn); in rspamd_controller_handle_ping()
3347 rspamd_http_router_insert_headers (conn_ent->rt, rep_msg); in rspamd_controller_handle_ping()
3348 rspamd_http_connection_write_message (conn_ent->conn, in rspamd_controller_handle_ping()
3352 conn_ent, in rspamd_controller_handle_ping()
3353 conn_ent->rt->timeout); in rspamd_controller_handle_ping()
3354 conn_ent->is_reply = TRUE; in rspamd_controller_handle_ping()
3364 rspamd_controller_handle_unknown (struct rspamd_http_connection_entry *conn_ent, in rspamd_controller_handle_unknown() argument
3380 rspamd_http_connection_reset (conn_ent->conn); in rspamd_controller_handle_unknown()
3381 rspamd_http_router_insert_headers (conn_ent->rt, rep); in rspamd_controller_handle_unknown()
3382 rspamd_http_connection_write_message (conn_ent->conn, in rspamd_controller_handle_unknown()
3386 conn_ent, in rspamd_controller_handle_unknown()
3387 conn_ent->rt->timeout); in rspamd_controller_handle_unknown()
3388 conn_ent->is_reply = TRUE; in rspamd_controller_handle_unknown()
3396 rspamd_http_connection_reset (conn_ent->conn); in rspamd_controller_handle_unknown()
3397 rspamd_http_router_insert_headers (conn_ent->rt, rep); in rspamd_controller_handle_unknown()
3398 rspamd_http_connection_write_message (conn_ent->conn, in rspamd_controller_handle_unknown()
3402 conn_ent, in rspamd_controller_handle_unknown()
3403 conn_ent->rt->timeout); in rspamd_controller_handle_unknown()
3404 conn_ent->is_reply = TRUE; in rspamd_controller_handle_unknown()
3411 rspamd_controller_handle_lua_plugin (struct rspamd_http_connection_entry *conn_ent, in rspamd_controller_handle_lua_plugin() argument
3414 struct rspamd_controller_session *session = conn_ent->ud; in rspamd_controller_handle_lua_plugin()
3445 rspamd_controller_send_error (conn_ent, 404, "No command associated"); in rspamd_controller_handle_lua_plugin()
3452 if (!rspamd_controller_check_password (conn_ent, session, msg, in rspamd_controller_handle_lua_plugin()
3458 rspamd_controller_send_error (conn_ent, in rspamd_controller_handle_lua_plugin()
3473 task->fin_arg = conn_ent; in rspamd_controller_handle_lua_plugin()
3474 task->http_conn = rspamd_http_connection_ref (conn_ent->conn);; in rspamd_controller_handle_lua_plugin()
3480 rspamd_controller_send_error (conn_ent, task->err->code, "%s", in rspamd_controller_handle_lua_plugin()
3497 *pconn = conn_ent; in rspamd_controller_handle_lua_plugin()
3521 rspamd_controller_send_error (conn_ent, 503, "Cannot run callback: %s", in rspamd_controller_handle_lua_plugin()
3535 rspamd_controller_error_handler (struct rspamd_http_connection_entry *conn_ent, in rspamd_controller_error_handler() argument
3538 struct rspamd_controller_session *session = conn_ent->ud; in rspamd_controller_error_handler()
3544 rspamd_controller_finish_handler (struct rspamd_http_connection_entry *conn_ent) in rspamd_controller_finish_handler() argument
3546 struct rspamd_controller_session *session = conn_ent->ud; in rspamd_controller_finish_handler()