mirrors/snac2
3
0
Fork 0
mirror of https://codeberg.org/grunfink/snac2.git synced 2024-09-19 18:00:23 +03:00
Code Issues Packages Projects Releases Wiki Activity

Rewritten queue() using xs_glob().

Browse Source
This commit is contained in:
default 2022-10-18 11:40:10 +02:00
parent abca46d037
commit a62cde3d9d
1 changed files with 14 additions and 18 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

32
data.c
View File

@ -978,31 +978,27 @@ void enqueue_output(snac *snac, char *msg, char *actor, int retries)
d_char *queue(snac *snac)
/* returns a list with filenames that can be dequeued */
{
xs *spec = xs_fmt("%s/queue/" "*.json", snac->basedir);
xs *spec = xs_fmt("%s/queue/" "*.json", snac->basedir);
d_char *list = xs_list_new();
glob_t globbuf;
time_t t = time(NULL);
time_t t = time(NULL);
char *p, *v;
if (glob(spec, 0, NULL, &globbuf) == 0) {
int n;
char *p;
xs *fns = xs_glob(spec, 0, 0);
for (n = 0; (p = globbuf.gl_pathv[n]) != NULL; n++) {
/* get the retry time from the basename */
char *bn = strrchr(p, '/');
time_t t2 = atol(bn + 1);
p = fns;
while (xs_list_iter(&p, &v)) {
/* get the retry time from the basename */
char *bn = strrchr(v, '/');
time_t t2 = atol(bn + 1);
if (t2 > t)
snac_debug(snac, 2, xs_fmt("queue not yet time for %s", p));
else {
list = xs_list_append(list, p);
snac_debug(snac, 2, xs_fmt("queue ready for %s", p));
}
if (t2 > t)
snac_debug(snac, 2, xs_fmt("queue not yet time for %s", v));
else {
list = xs_list_append(list, v);
snac_debug(snac, 2, xs_fmt("queue ready for %s", v));
}
}
globfree(&globbuf);
return list;
}