commit 106c94e
default
·
2023-02-02 03:47:59 +0000 UTC
parent ee77e45
queue() renamed to user_queue().
3 files changed,
+8,
-7
+1,
-1
1@@ -1163,7 +1163,7 @@ void process_queue_item(snac *snac, xs_dict *q_item)
2 void process_queue(snac *snac)
3 /* processes the queue */
4 {
5- xs *list = queue(snac);
6+ xs *list = user_queue(snac);
7
8 xs_list *p = list;
9 xs_str *fn;
M
data.c
+6,
-5
1@@ -1411,13 +1411,14 @@ void enqueue_message(snac *snac, xs_dict *msg)
2 }
3
4
5-d_char *queue(snac *snac)
6+xs_list *user_queue(snac *snac)
7 /* returns a list with filenames that can be dequeued */
8 {
9- xs *spec = xs_fmt("%s/queue/" "*.json", snac->basedir);
10- d_char *list = xs_list_new();
11- time_t t = time(NULL);
12- char *p, *v;
13+ xs *spec = xs_fmt("%s/queue/" "*.json", snac->basedir);
14+ xs_list *list = xs_list_new();
15+ time_t t = time(NULL);
16+ xs_list *p;
17+ xs_val *v;
18
19 xs *fns = xs_glob(spec, 0, 0);
20
M
snac.h
+1,
-1
1@@ -129,7 +129,7 @@ void enqueue_output_by_actor(snac *snac, xs_dict *msg, xs_str *actor, int retrie
2 void enqueue_email(snac *snac, xs_str *msg, int retries);
3 void enqueue_message(snac *snac, char *msg);
4
5-d_char *queue(snac *snac);
6+xs_list *user_queue(snac *snac);
7 xs_dict *dequeue(const char *fn);
8
9 void purge(snac *snac);