commit ee77e45
default
·
2023-02-02 03:44:30 +0000 UTC
parent 56c4711
dequeue() does not need a snac argument.
3 files changed,
+4,
-4
+1,
-1
1@@ -1169,7 +1169,7 @@ void process_queue(snac *snac)
2 xs_str *fn;
3
4 while (xs_list_iter(&p, &fn)) {
5- xs *q_item = dequeue(snac, fn);
6+ xs *q_item = dequeue(fn);
7
8 if (q_item == NULL) {
9 snac_log(snac, xs_fmt("process_queue q_item error"));
M
data.c
+2,
-2
1@@ -1439,11 +1439,11 @@ d_char *queue(snac *snac)
2 }
3
4
5-d_char *dequeue(snac *snac, char *fn)
6+xs_dict *dequeue(const char *fn)
7 /* dequeues a message */
8 {
9 FILE *f;
10- d_char *obj = NULL;
11+ xs_dict *obj = NULL;
12
13 if ((f = fopen(fn, "r")) != NULL) {
14 /* delete right now */
M
snac.h
+1,
-1
1@@ -130,7 +130,7 @@ void enqueue_email(snac *snac, xs_str *msg, int retries);
2 void enqueue_message(snac *snac, char *msg);
3
4 d_char *queue(snac *snac);
5-d_char *dequeue(snac *snac, char *fn);
6+xs_dict *dequeue(const char *fn);
7
8 void purge(snac *snac);
9 void purge_all(void);