X-Git-Url: https://git.octo.it/?a=blobdiff_plain;ds=inline;f=src%2Flua.c;h=d10b4ea737417a0f207ad3122a9683438e4c9955;hb=3e36ac34460b6be8388ac376ab7a4e2e990870ec;hp=b89c824001f6bffc1770ae80914a8145e7f9484d;hpb=336c20760f0fcdf709bdd988b951640baed19a47;p=collectd.git diff --git a/src/lua.c b/src/lua.c index b89c8240..d10b4ea7 100644 --- a/src/lua.c +++ b/src/lua.c @@ -62,11 +62,6 @@ typedef struct { int callback_id; } clua_callback_data_t; -typedef struct { - const char *name; - lua_CFunction func; -} lua_c_function_t; - static char base_path[PATH_MAX]; static lua_script_t *scripts; @@ -308,15 +303,13 @@ static int lua_cb_register_read(lua_State *L) /* {{{ */ cb->lua_function_name = strdup(function_name); pthread_mutex_init(&cb->lock, NULL); - user_data_t ud = { - .data = cb - }; - int status = plugin_register_complex_read(/* group = */ "lua", /* name = */ function_name, /* callback = */ clua_read, /* interval = */ 0, - /* user_data = */ &ud); + &(user_data_t) { + .data = cb, + }); if (status != 0) return luaL_error(L, "%s", "plugin_register_complex_read failed"); @@ -354,20 +347,18 @@ static int lua_cb_register_write(lua_State *L) /* {{{ */ cb->lua_function_name = strdup(function_name); pthread_mutex_init(&cb->lock, NULL); - user_data_t ud = { - .data = cb - }; - int status = plugin_register_write(/* name = */ function_name, /* callback = */ clua_write, - /* user_data = */ &ud); + &(user_data_t) { + .data = cb, + }); if (status != 0) return luaL_error(L, "%s", "plugin_register_write failed"); return 0; } /* }}} int lua_cb_register_write */ -static lua_c_function_t lua_c_functions[] = { +static const luaL_Reg collectdlib[] = { {"log_debug", lua_cb_log_debug}, {"log_error", lua_cb_log_error}, {"log_info", lua_cb_log_info}, @@ -375,7 +366,19 @@ static lua_c_function_t lua_c_functions[] = { {"log_warning", lua_cb_log_warning}, {"dispatch_values", lua_cb_dispatch_values}, {"register_read", lua_cb_register_read}, - {"register_write", lua_cb_register_write}}; + {"register_write", lua_cb_register_write}, + {NULL, NULL} +}; + +static int open_collectd(lua_State *L) /* {{{ */ +{ +#if LUA_VERSION_NUM < 502 + luaL_register(L, "collectd", collectdlib); +#else + luaL_newlib(L, collectdlib); +#endif + return 1; +} /* }}} */ static void lua_script_free(lua_script_t *script) /* {{{ */ { @@ -409,13 +412,15 @@ static int lua_script_init(lua_script_t *script) /* {{{ */ /* Open up all the standard Lua libraries. */ luaL_openlibs(script->lua_state); - /* Register all the functions we implement in C */ - lua_newtable(script->lua_state); - for (size_t i = 0; i < STATIC_ARRAY_SIZE(lua_c_functions); i++) { - lua_pushcfunction(script->lua_state, lua_c_functions[i].func); - lua_setfield(script->lua_state, -2, lua_c_functions[i].name); - } - lua_setglobal(script->lua_state, "collectd"); + /* Load the 'collectd' library */ +#if LUA_VERSION_NUM < 502 + lua_pushcfunction(script->lua_state, open_collectd); + lua_pushstring(script->lua_state, "collectd"); + lua_call(script->lua_state, 1, 0); +#else + luaL_requiref(script->lua_state, "collectd", open_collectd, 1); + lua_pop(script->lua_state, 1); +#endif /* Prepend BasePath to package.path */ if (base_path[0] != '\0') { @@ -576,7 +581,7 @@ static int lua_shutdown(void) /* {{{ */ return (0); } /* }}} int lua_shutdown */ -void module_register() { +void module_register(void) { plugin_register_complex_config("lua", lua_config); plugin_register_shutdown("lua", lua_shutdown); }