Skip to content

Commit

Permalink
cron: tidying and more chatty debugging
Browse files Browse the repository at this point in the history
  • Loading branch information
nwf committed Dec 30, 2021
1 parent 4bcb4bd commit 474e6a7
Showing 1 changed file with 26 additions and 9 deletions.
35 changes: 26 additions & 9 deletions app/modules/cron.c
Original file line number Diff line number Diff line change
Expand Up @@ -12,6 +12,14 @@
#include "rtc/rtctime.h"
#include "mem.h"

static const char *CRON_ENTRY_METATABLE = "cron.entry";

#if 0
# define cron_dbg(...) printf(__VA_ARGS__)
#else
# define cron_dbg(...)
#endif

struct cronent_desc {
uint64_t min; // Minutes repeat - bits 0-59
uint32_t hour; // Hours repeat - bits 0-23
Expand Down Expand Up @@ -51,15 +59,14 @@ static uint64_t lcron_parsepart(lua_State *L, char *str, char **end, uint8_t min
}
} else {
uint32_t val;
while (1) {
do {
val = strtol(str, end, 10);
if (val < min || val > max) {
return luaL_error(L, "invalid spec (val %d out of range %d..%d)", val, min, max);
}
res |= (uint64_t)1 << (val - min);
if (**end != ',') break;
str = *end + 1;
}
} while (**end == ',');
}
return res;
}
Expand Down Expand Up @@ -101,7 +108,7 @@ static int lcron_create(lua_State *L) {
// Allocate userdata onto the stack
cronent_ud_t *ud = lua_newuserdata(L, sizeof(cronent_ud_t));
// Set metatable
luaL_getmetatable(L, "cron.entry");
luaL_getmetatable(L, CRON_ENTRY_METATABLE);
lua_setmetatable(L, -2);
// Set callback
lua_pushvalue(L, 2);
Expand Down Expand Up @@ -134,7 +141,7 @@ static size_t lcron_findindex(lua_State *L, cronent_ud_t *ud) {
}

static int lcron_schedule(lua_State *L) {
cronent_ud_t *ud = luaL_checkudata(L, 1, "cron.entry");
cronent_ud_t *ud = luaL_checkudata(L, 1, CRON_ENTRY_METATABLE);
char *strdesc = (char*)luaL_optstring(L, 2, NULL);

if (strdesc != NULL) {
Expand All @@ -145,14 +152,16 @@ static int lcron_schedule(lua_State *L) {

size_t i = lcron_findindex(L, ud);

cron_dbg("cron: schedule %p at index %d\n", ud, i);

lua_pushvalue(L, 1); // copy ud to top of stack
lua_rawseti(L, -2, i); // install into table

return 0;
}

static int lcron_handler(lua_State *L) {
cronent_ud_t *ud = luaL_checkudata(L, 1, "cron.entry");
cronent_ud_t *ud = luaL_checkudata(L, 1, CRON_ENTRY_METATABLE);
luaL_checktype(L, 2, LUA_TFUNCTION);
lua_pushvalue(L, 2);
luaL_unref(L, LUA_REGISTRYINDEX, ud->cb_ref);
Expand All @@ -161,9 +170,11 @@ static int lcron_handler(lua_State *L) {
}

static int lcron_unschedule(lua_State *L) {
cronent_ud_t *ud = luaL_checkudata(L, 1, "cron.entry");
cronent_ud_t *ud = luaL_checkudata(L, 1, CRON_ENTRY_METATABLE);
size_t i = lcron_findindex(L, ud);

cron_dbg("cron: unschedule %p at index %d\n", ud, i);

lua_pushnil(L);
lua_rawseti(L, -2, i);

Expand All @@ -172,7 +183,7 @@ static int lcron_unschedule(lua_State *L) {

// scheduled entries are pinned, so we cannot arrive at the __gc metamethod
static int lcron_delete(lua_State *L) {
cronent_ud_t *ud = luaL_checkudata(L, 1, "cron.entry");
cronent_ud_t *ud = luaL_checkudata(L, 1, CRON_ENTRY_METATABLE);
luaL_unref(L, LUA_REGISTRYINDEX, ud->cb_ref);
return 0;
}
Expand All @@ -182,6 +193,8 @@ static int lcron_reset(lua_State *L) {
luaL_unref(L, LUA_REGISTRYINDEX, cronent_table_ref);
cronent_table_ref = luaL_ref(L, LUA_REGISTRYINDEX);

cron_dbg("cron: cronent_table_ref is %d\n", cronent_table_ref);

return 0;
}

Expand All @@ -198,10 +211,14 @@ static void cron_handle_time(uint8_t mon, uint8_t dom, uint8_t dow, uint8_t hour
size_t count = lua_objlen(L, -1);

for (size_t i = 1; i <= count; i++) {
cron_dbg("cron: handle_time index %d (of %d; top %d)\n", i, count, lua_gettop(L));

lua_rawgeti(L, -1, i);
cronent_ud_t *ent = lua_touserdata(L, -1);
lua_pop(L, 1);

cron_dbg(" ... is %p\n", ent);

if ((ent->desc.mon & desc.mon ) == 0) continue;
if ((ent->desc.dom & desc.dom ) == 0) continue;
if ((ent->desc.dow & desc.dow ) == 0) continue;
Expand Down Expand Up @@ -261,7 +278,7 @@ int luaopen_cron( lua_State *L ) {
//cron_handle_tmr determines when to execute a scheduled cron job
//My guess: To be sure to give the other modules required by cron enough time to get to a ready state, restart cron_timer.
os_timer_arm(&cron_timer, 1000, 0);
luaL_rometatable(L, "cron.entry", LROT_TABLEREF(cronent));
luaL_rometatable(L, CRON_ENTRY_METATABLE, LROT_TABLEREF(cronent));

cronent_table_ref = LUA_NOREF;
lcron_reset(L);
Expand Down

0 comments on commit 474e6a7

Please sign in to comment.