summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorGravatar default2023-02-02 04:47:59 +0100
committerGravatar default2023-02-02 04:47:59 +0100
commit106c94ef86c5c8eb05c3e8ac62f1af3504d8aba0 (patch)
tree799ec3ee51df63ffcb9314965d54cab438770d4c
parentdequeue() does not need a snac argument. (diff)
downloadsnac2-106c94ef86c5c8eb05c3e8ac62f1af3504d8aba0.tar.gz
snac2-106c94ef86c5c8eb05c3e8ac62f1af3504d8aba0.tar.xz
snac2-106c94ef86c5c8eb05c3e8ac62f1af3504d8aba0.zip
queue() renamed to user_queue().
-rw-r--r--activitypub.c2
-rw-r--r--data.c11
-rw-r--r--snac.h2
3 files changed, 8 insertions, 7 deletions
diff --git a/activitypub.c b/activitypub.c
index bd99c26..b2f42f2 100644
--- a/activitypub.c
+++ b/activitypub.c
@@ -1163,7 +1163,7 @@ void process_queue_item(snac *snac, xs_dict *q_item)
1163void process_queue(snac *snac) 1163void process_queue(snac *snac)
1164/* processes the queue */ 1164/* processes the queue */
1165{ 1165{
1166 xs *list = queue(snac); 1166 xs *list = user_queue(snac);
1167 1167
1168 xs_list *p = list; 1168 xs_list *p = list;
1169 xs_str *fn; 1169 xs_str *fn;
diff --git a/data.c b/data.c
index 8e91579..1adf4cd 100644
--- a/data.c
+++ b/data.c
@@ -1411,13 +1411,14 @@ void enqueue_message(snac *snac, xs_dict *msg)
1411} 1411}
1412 1412
1413 1413
1414d_char *queue(snac *snac) 1414xs_list *user_queue(snac *snac)
1415/* returns a list with filenames that can be dequeued */ 1415/* returns a list with filenames that can be dequeued */
1416{ 1416{
1417 xs *spec = xs_fmt("%s/queue/" "*.json", snac->basedir); 1417 xs *spec = xs_fmt("%s/queue/" "*.json", snac->basedir);
1418 d_char *list = xs_list_new(); 1418 xs_list *list = xs_list_new();
1419 time_t t = time(NULL); 1419 time_t t = time(NULL);
1420 char *p, *v; 1420 xs_list *p;
1421 xs_val *v;
1421 1422
1422 xs *fns = xs_glob(spec, 0, 0); 1423 xs *fns = xs_glob(spec, 0, 0);
1423 1424
diff --git a/snac.h b/snac.h
index 4b01064..0e5da16 100644
--- a/snac.h
+++ b/snac.h
@@ -129,7 +129,7 @@ void enqueue_output_by_actor(snac *snac, xs_dict *msg, xs_str *actor, int retrie
129void enqueue_email(snac *snac, xs_str *msg, int retries); 129void enqueue_email(snac *snac, xs_str *msg, int retries);
130void enqueue_message(snac *snac, char *msg); 130void enqueue_message(snac *snac, char *msg);
131 131
132d_char *queue(snac *snac); 132xs_list *user_queue(snac *snac);
133xs_dict *dequeue(const char *fn); 133xs_dict *dequeue(const char *fn);
134 134
135void purge(snac *snac); 135void purge(snac *snac);