diff options
author | Vsevolod Stakhov <vsevolod@rspamd.com> | 2024-03-18 18:56:33 +0000 |
---|---|---|
committer | Vsevolod Stakhov <vsevolod@rspamd.com> | 2024-03-18 18:56:33 +0000 |
commit | 14c13854d3cae9d93c3d148be30fb72f1eaffe55 (patch) | |
tree | 7b1a3e41b75490fac4d45722c90a1847543c6796 /src/lua/lua_worker.c | |
parent | 6b2b4167187fee09365271cca182866ecb029af3 (diff) | |
download | rspamd-14c13854d3cae9d93c3d148be30fb72f1eaffe55.tar.gz rspamd-14c13854d3cae9d93c3d148be30fb72f1eaffe55.zip |
[Rework] Further types conversion (no functional changes)
Diffstat (limited to 'src/lua/lua_worker.c')
-rw-r--r-- | src/lua/lua_worker.c | 66 |
1 files changed, 33 insertions, 33 deletions
diff --git a/src/lua/lua_worker.c b/src/lua/lua_worker.c index 2b9856b08..b18e9e515 100644 --- a/src/lua/lua_worker.c +++ b/src/lua/lua_worker.c @@ -61,14 +61,14 @@ const luaL_reg worker_reg[] = { {NULL, NULL}}; static struct rspamd_worker * -lua_check_worker(lua_State *L, gint pos) +lua_check_worker(lua_State *L, int pos) { void *ud = rspamd_lua_check_udata(L, pos, rspamd_worker_classname); luaL_argcheck(L, ud != NULL, pos, "'worker' expected"); return ud ? *((struct rspamd_worker **) ud) : NULL; } -static gint +static int lua_worker_get_stat(lua_State *L) { struct rspamd_worker *w = lua_check_worker(L, 1); @@ -77,7 +77,7 @@ lua_worker_get_stat(lua_State *L) rspamd_mempool_stat_t mem_st; struct rspamd_stat *stat, stat_copy; ucl_object_t *top, *sub; - gint i; + int i; uint64_t spam = 0, ham = 0; memset(&mem_st, 0, sizeof(mem_st)); @@ -150,7 +150,7 @@ lua_worker_get_stat(lua_State *L) return 1; } -static gint +static int lua_worker_get_name(lua_State *L) { struct rspamd_worker *w = lua_check_worker(L, 1); @@ -165,7 +165,7 @@ lua_worker_get_name(lua_State *L) return 1; } -static gint +static int lua_worker_get_index(lua_State *L) { struct rspamd_worker *w = lua_check_worker(L, 1); @@ -180,7 +180,7 @@ lua_worker_get_index(lua_State *L) return 1; } -static gint +static int lua_worker_get_count(lua_State *L) { struct rspamd_worker *w = lua_check_worker(L, 1); @@ -195,7 +195,7 @@ lua_worker_get_count(lua_State *L) return 1; } -static gint +static int lua_worker_get_pid(lua_State *L) { struct rspamd_worker *w = lua_check_worker(L, 1); @@ -211,7 +211,7 @@ lua_worker_get_pid(lua_State *L) } -static gint +static int lua_worker_is_scanner(lua_State *L) { struct rspamd_worker *w = lua_check_worker(L, 1); @@ -226,7 +226,7 @@ lua_worker_is_scanner(lua_State *L) return 1; } -static gint +static int lua_worker_is_primary_controller(lua_State *L) { struct rspamd_worker *w = lua_check_worker(L, 1); @@ -249,8 +249,8 @@ struct rspamd_control_cbdata { struct ev_loop *event_loop; struct rspamd_async_session *session; enum rspamd_control_type cmd; - gint cbref; - gint fd; + int cbref; + int fd; }; static gboolean @@ -284,8 +284,8 @@ lua_worker_control_session_dtor(void *ud) static gboolean lua_worker_control_handler(struct rspamd_main *rspamd_main, struct rspamd_worker *worker, - gint fd, - gint attached_fd, + int fd, + int attached_fd, struct rspamd_control_command *cmd, gpointer ud) { @@ -293,7 +293,7 @@ lua_worker_control_handler(struct rspamd_main *rspamd_main, struct rspamd_control_cbdata *cbd = (struct rspamd_control_cbdata *) ud; rspamd_mempool_t *pool; lua_State *L; - gint err_idx, status; + int err_idx, status; L = cbd->L; pool = cbd->pool; @@ -403,13 +403,13 @@ lua_worker_control_handler(struct rspamd_main *rspamd_main, return TRUE; } -static gint +static int lua_worker_add_control_handler(lua_State *L) { struct rspamd_worker *w = lua_check_worker(L, 1); struct rspamd_config *cfg = lua_check_config(L, 2); struct ev_loop *event_loop = lua_check_ev_base(L, 3); - const gchar *cmd_name = luaL_checkstring(L, 4); + const char *cmd_name = luaL_checkstring(L, 4); enum rspamd_control_type cmd; struct rspamd_control_cbdata *cbd; @@ -454,7 +454,7 @@ lua_worker_jemalloc_stats_cb(void *ud, const char *msg) } #endif -static gint +static int lua_worker_get_mem_stats(lua_State *L) { struct rspamd_worker *w = lua_check_worker(L, 1); @@ -474,9 +474,9 @@ lua_worker_get_mem_stats(lua_State *L) } struct rspamd_lua_process_cbdata { - gint sp[2]; - gint func_cbref; - gint cb_cbref; + int sp[2]; + int func_cbref; + int cb_cbref; gboolean replied; gboolean is_error; pid_t cpid; @@ -494,7 +494,7 @@ static void rspamd_lua_execute_lua_subprocess(lua_State *L, struct rspamd_lua_process_cbdata *cbdata) { - gint err_idx, r; + int err_idx, r; uint64_t wlen = 0; lua_pushcfunction(L, &rspamd_lua_traceback); @@ -503,7 +503,7 @@ rspamd_lua_execute_lua_subprocess(lua_State *L, lua_rawgeti(L, LUA_REGISTRYINDEX, cbdata->func_cbref); if (lua_pcall(L, 0, 1, err_idx) != 0) { - const gchar *s = lua_tostring(L, -1); + const char *s = lua_tostring(L, -1); gsize slen = strlen(s); msg_err("call to subprocess failed: %s", s); @@ -549,10 +549,10 @@ rspamd_lua_execute_lua_subprocess(lua_State *L, static void rspamd_lua_call_on_complete(lua_State *L, struct rspamd_lua_process_cbdata *cbdata, - const gchar *err_msg, - const gchar *data, gsize datalen) + const char *err_msg, + const char *data, gsize datalen) { - gint err_idx; + int err_idx; lua_pushcfunction(L, &rspamd_lua_traceback); err_idx = lua_gettop(L); @@ -588,7 +588,7 @@ rspamd_lua_cld_handler(struct rspamd_worker_signal_handler *sigh, void *ud) struct rspamd_srv_command srv_cmd; lua_State *L; pid_t died; - gint res = 0; + int res = 0; /* Are we called by a correct children ? */ died = waitpid(cbdata->cpid, &res, WNOHANG); @@ -673,7 +673,7 @@ rspamd_lua_subprocess_io(EV_P_ ev_io *w, int revents) cbdata->io_buf->len += r; if (cbdata->io_buf->len == sizeof(uint64_t)) { - memcpy((guchar *) &sz, cbdata->io_buf->str, sizeof(sz)); + memcpy((unsigned char *) &sz, cbdata->io_buf->str, sizeof(sz)); if (sz & (1ULL << 63)) { cbdata->is_error = TRUE; @@ -718,7 +718,7 @@ rspamd_lua_subprocess_io(EV_P_ ev_io *w, int revents) cbdata->io_buf->len += r; if (cbdata->io_buf->len == cbdata->sz) { - gchar rep[4]; + char rep[4]; ev_io_stop(cbdata->event_loop, &cbdata->ev); /* Finished reading data */ @@ -742,18 +742,18 @@ rspamd_lua_subprocess_io(EV_P_ ev_io *w, int revents) } } -static gint +static int lua_worker_spawn_process(lua_State *L) { struct rspamd_worker *w = lua_check_worker(L, 1); struct rspamd_lua_process_cbdata *cbdata; struct rspamd_abstract_worker_ctx *actx; struct rspamd_srv_command srv_cmd; - const gchar *cmdline = NULL, *input = NULL, *proctitle = NULL; + const char *cmdline = NULL, *input = NULL, *proctitle = NULL; gsize inputlen = 0; pid_t pid; GError *err = NULL; - gint func_cbref, cb_cbref; + int func_cbref, cb_cbref; if (!rspamd_lua_parse_table_arguments(L, 2, &err, RSPAMD_LUA_PARSE_ARGUMENTS_DEFAULT, @@ -806,8 +806,8 @@ lua_worker_spawn_process(lua_State *L) } else if (pid == 0) { /* Child */ - gint rc; - gchar inbuf[4]; + int rc; + char inbuf[4]; rspamd_log_on_fork(w->cf->type, w->srv->cfg, w->srv->logger); rc = ottery_init(w->srv->cfg->libs_ctx->ottery_cfg); |