peter/infix
1
0
Fork 0
mirror of https://github.com/kernelkit/infix.git synced 2026-07-22 01:13:00 +02:00
Code Issues Packages Projects Releases Wiki Activity

confd: schedule: generate in change, apply in done

Browse Source 
Write the crontab to admin.next on change and promote it on done, drop it
on abort.

Signed-off-by: Mattias Walström <lazzer@gmail.com>
This commit is contained in:
Mattias Walström
2026-06-26 13:33:44 +02:00
parent 7030f85484
commit f866cf15b4
1 changed files with 42 additions and 13 deletions
Download Patch File Download Diff File Expand all files Collapse all files
src/confd/src/schedule.c
+42 -13
View File
@@ -11,7 +11,9 @@
#include "core.h"
#define XPATH_BASE "/ietf-system:system/infix-schedule:schedules"
#define CRONTAB_FILE "/var/spool/cron/crontabs/admin"
#define CRONTAB_DIR "/var/spool/cron/crontabs"
#define CRONTAB_FILE CRONTAB_DIR "/admin"
#define CRONTAB_NEXT CRONTAB_DIR "/admin.next"
/* Features register a consumer to run a command on a schedule. */
static const struct cron_consumer **consumers;
@@ -219,21 +221,23 @@ static int schedule_to_cron(struct lyd_node *config, const char *name,
}
/*
* Rebuild the crontab from every registered consumer. Each consumer points
* at a feature container holding a schedule-ref; we resolve that to cron
* fields and emit one line running the consumer's own command.
* Generate the next crontab from every registered consumer. Each consumer
* points at a feature container holding a schedule-ref; we resolve that to
* cron fields and emit one line running the consumer's own command. Written
* to CRONTAB_NEXT, promoted in SR_EV_DONE. Returns the active job count;
* CRONTAB_NEXT is removed when there are none, so DONE knows to stop crond.
*/
static void apply_schedules(struct lyd_node *config)
static int gen_schedules(struct lyd_node *config)
{
int count = 0;
FILE *fp;
size_t i;
makepath("/var/spool/cron/crontabs");
fp = fopen(CRONTAB_FILE, "w");
makepath(CRONTAB_DIR);
fp = fopen(CRONTAB_NEXT, "w");
if (!fp) {
ERROR("schedule: failed to open %s", CRONTAB_FILE);
return;
ERROR("schedule: failed to open %s", CRONTAB_NEXT);
return -1;
}
fprintf(fp, "# Managed by infix-schedule\n");
@@ -269,16 +273,41 @@ static void apply_schedules(struct lyd_node *config)
out:
fclose(fp);
crond_apply(count > 0);
NOTE("schedule: %d active job(s) written to crontab", count);
if (!count)
(void)remove(CRONTAB_NEXT);
return count;
}
int schedule_change(sr_session_ctx_t *session, struct lyd_node *config,
struct lyd_node *diff, sr_event_t event, struct confd *confd)
{
if (event != SR_EV_DONE && event != SR_EV_ENABLED)
if (diff && !lydx_get_xpathf(diff, XPATH_BASE))
return SR_ERR_OK;
apply_schedules(config);
switch (event) {
case SR_EV_ENABLED: /* first time, on register */
case SR_EV_CHANGE: /* regular change */
gen_schedules(config);
break;
case SR_EV_ABORT: /* user abort, or another plugin failed */
(void)remove(CRONTAB_NEXT);
break;
case SR_EV_DONE:
if (fexist(CRONTAB_NEXT)) {
(void)rename(CRONTAB_NEXT, CRONTAB_FILE);
crond_apply(1);
} else {
(void)remove(CRONTAB_FILE);
crond_apply(0);
}
break;
default:
break;
}
return SR_ERR_OK;
}