radio95/rds95
0
1
Fork 0
mirror of https://github.com/radio95-rnt/rds95.git synced 2026-07-31 01:09:17 +02:00
Code Issues Wiki Activity

debug

Browse Source
This commit is contained in:
kuba
2025-12-25 22:18:24 +01:00
parent aca1aa1d41
commit f830ff3e74
1 changed files with 14 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files
src/lua_rds.c
+12 -1
View File
@@ -5,6 +5,7 @@ static RDSModulator* mod = NULL;
static lua_State *L = NULL; static lua_State *L = NULL;
static pthread_mutex_t lua_mutex; static pthread_mutex_t lua_mutex;
static uint8_t unload_refs[33] = {LUA_REFNIL}; static uint8_t unload_refs[33] = {LUA_REFNIL};
static int in_set_defaults = 0;
int lua_get_userdata(lua_State *localL) { int lua_get_userdata(lua_State *localL) {
lua_pushlstring(localL, (const char*)&mod->enc->data[mod->enc->program].lua_data, LUA_USER_DATA); lua_pushlstring(localL, (const char*)&mod->enc->data[mod->enc->program].lua_data, LUA_USER_DATA);
@@ -48,11 +49,17 @@ int lua_force_save(lua_State *localL) {
int lua_set_rds_program_defaults(lua_State *localL) { int lua_set_rds_program_defaults(lua_State *localL) {
(void)localL; (void)localL;
if (in_set_defaults) {
fprintf(stderr, "Warning: Recursive call to lua_set_rds_program_defaults blocked\n");
return 0;
}
in_set_defaults = 1;
for (int i = 1; i < *unload_refs; i++) luaL_unref(L, LUA_REGISTRYINDEX, unload_refs[i]); for (int i = 1; i < *unload_refs; i++) luaL_unref(L, LUA_REGISTRYINDEX, unload_refs[i]);
unload_refs[0] = 1; unload_refs[0] = 1;
set_rds_defaults(mod->enc, mod->enc->program); set_rds_defaults(mod->enc, mod->enc->program);
lua_call_function("on_init"); lua_call_function("on_init");
lua_call_function("on_state"); lua_call_function("on_state");
in_set_defaults = 0;
return 0; return 0;
} }
@@ -718,7 +725,11 @@ void lua_group_ref(RDSGroup* group, int ref) {
} }
void lua_call_function(const char* function) { void lua_call_function(const char* function) {
pthread_mutex_lock(&lua_mutex); int need_lock = (pthread_mutex_trylock(&lua_mutex) == 0);
if (!need_lock) {
fprintf(stderr, "Warning: lua_mutex already locked when calling %s\n", function);
return;
}
lua_getglobal(L, function); lua_getglobal(L, function);
if (lua_isfunction(L, -1)) { if (lua_isfunction(L, -1)) {