diff options
| author | Vsevolod Stakhov <vsevolod@highsecure.ru> | 2019-06-17 16:25:07 +0100 |
|---|---|---|
| committer | Vsevolod Stakhov <vsevolod@highsecure.ru> | 2019-06-22 10:57:29 +0100 |
| commit | 4b75d23d067118e2874ec3b8726d49e3f185b811 (patch) | |
| tree | b97d01b8b2cf4d1d6cb05a0e5b2fed32f368fa5a /src/lua/lua_util.c | |
| parent | de721b490bce9f95385ab451da1190f934cf3425 (diff) | |
| download | rspamd-4b75d23d067118e2874ec3b8726d49e3f185b811.tar.gz rspamd-4b75d23d067118e2874ec3b8726d49e3f185b811.zip | |
[Project] Adopt Lua API
Diffstat (limited to 'src/lua/lua_util.c')
| -rw-r--r-- | src/lua/lua_util.c | 12 |
1 files changed, 6 insertions, 6 deletions
diff --git a/src/lua/lua_util.c b/src/lua/lua_util.c index 8ef0bc2fb..8e6403972 100644 --- a/src/lua/lua_util.c +++ b/src/lua/lua_util.c @@ -699,7 +699,7 @@ lua_util_create_event_base (lua_State *L) pev_base = lua_newuserdata (L, sizeof (struct ev_loop *)); rspamd_lua_setclass (L, "rspamd{ev_base}", -1); - *pev_base = event_init (); + *pev_base = ev_default_loop (EVFLAG_SIGNALFD); return 1; } @@ -848,7 +848,7 @@ lua_util_process_message (lua_State *L) message = luaL_checklstring (L, 2, &mlen); if (cfg != NULL && message != NULL) { - base = event_init (); + base = ev_loop_new (EVFLAG_SIGNALFD); rspamd_init_filters (cfg, FALSE); task = rspamd_task_new (NULL, cfg, NULL, NULL, base); task->msg.begin = rspamd_mempool_alloc (task->task_pool, mlen); @@ -865,7 +865,7 @@ lua_util_process_message (lua_State *L) } else { if (rspamd_task_process (task, RSPAMD_TASK_PROCESS_ALL)) { - event_base_loop (base, 0); + ev_loop (base, 0); if (res != NULL) { ucl_object_push_lua (L, res, true); @@ -885,7 +885,7 @@ lua_util_process_message (lua_State *L) } } - event_base_free (base); + ev_loop_destroy (base); } else { lua_pushnil (L); @@ -3799,10 +3799,10 @@ lua_ev_base_loop (lua_State *L) ev_base = lua_check_ev_base (L, 1); if (lua_isnumber (L, 2)) { - flags = lua_tonumber (L, 2); + flags = lua_tointeger (L, 2); } - int ret = event_base_loop (ev_base, flags); + int ret = ev_run (ev_base, flags); lua_pushinteger (L, ret); return 1; |